Searched defs:socket (Results 51 - 75 of 184) sorted by relevance

12345678

/external/chromium/net/udp/
H A Dudp_socket_win.h30 // Connect the socket to connect with a certain |address|.
34 // Bind the address/port for this socket to |address|. This is generally
39 // Close the socket.
53 // Read from the socket.
54 // Only usable from the client-side of a UDP socket, after the socket
58 // Write to the socket.
59 // Only usable from the client-side of a UDP socket, after the socket
63 // Read from a socket an
101 ReadDelegate(UDPSocketWin* socket) argument
113 WriteDelegate(UDPSocketWin* socket) argument
[all...]
/external/chromium/net/websockets/
H A Dwebsocket_throttle_unittest.cc23 net::SocketStream* socket, int max_pending_send_allowed) {}
24 virtual void OnSentData(net::SocketStream* socket, int amount_sent) {} argument
25 virtual void OnReceivedData(net::SocketStream* socket, argument
27 virtual void OnClose(net::SocketStream* socket) {} argument
65 SocketStream* socket, struct addrinfo* head) {
66 socket->CopyAddrInfo(head);
67 // In SocketStream::Connect(), it adds reference to socket, which is
73 // so Release() won't be called. Thus, we don't need socket->AddRef()
75 DCHECK_EQ(socket->next_state_, SocketStream::STATE_NONE);
22 OnConnected( net::SocketStream* socket, int max_pending_send_allowed) argument
64 MockSocketStreamConnect( SocketStream* socket, struct addrinfo* head) argument
H A Dwebsocket.h42 virtual void OnOpen(WebSocket* socket) = 0;
44 // Called when |msg| is received at |socket|.
46 virtual void OnMessage(WebSocket* socket, const std::string& msg) = 0;
49 virtual void OnError(WebSocket* socket) {} argument
51 // Called when |socket| is closed.
52 virtual void OnClose(WebSocket* socket, bool was_clean) = 0;
54 // Called when an error occured on |socket|.
55 virtual void OnSocketError(const WebSocket* socket, int error) {} argument
156 virtual void OnClose(SocketStream* socket);
157 virtual void OnError(const SocketStream* socket, in
[all...]
H A Dwebsocket_job.cc164 SocketStream* socket, CompletionCallback* callback) {
167 addresses_.Copy(socket->address_list().head(), true);
177 SocketStream* socket, int max_pending_send_allowed) {
182 delegate_->OnConnected(socket, max_pending_send_allowed);
185 void WebSocketJob::OnSentData(SocketStream* socket, int amount_sent) { argument
190 OnSentHandshakeRequest(socket, amount_sent);
202 // amount sent to |socket|.
207 delegate_->OnSentData(socket, amount_sent);
214 SocketStream* socket, const char* data, int len) {
219 OnReceivedHandshakeResponse(socket, dat
163 OnStartOpenConnection( SocketStream* socket, CompletionCallback* callback) argument
176 OnConnected( SocketStream* socket, int max_pending_send_allowed) argument
213 OnReceivedData( SocketStream* socket, const char* data, int len) argument
238 OnClose(SocketStream* socket) argument
257 OnAuthRequired( SocketStream* socket, AuthChallengeInfo* auth_info) argument
263 OnError(const SocketStream* socket, int error) argument
319 OnSentHandshakeRequest( SocketStream* socket, int amount_sent) argument
335 OnReceivedHandshakeResponse( SocketStream* socket, const char* data, int len) argument
[all...]
/external/chromium/third_party/libjingle/source/talk/base/
H A Dasyncudpsocket.cc41 scoped_ptr<AsyncSocket> socket(factory->CreateAsyncSocket(SOCK_DGRAM));
42 if (!socket.get())
44 if (socket->Bind(address)) {
45 LOG(LS_INFO) << "Failed to bind UDP socket " << socket->GetError();
48 return new AsyncUDPSocket(socket.release());
51 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket) argument
52 : socket_(socket) {
57 // The socket should start out readable but not writable.
108 void AsyncUDPSocket::OnReadEvent(AsyncSocket* socket) { argument
[all...]
/external/chromium/third_party/libjingle/source/talk/examples/login/
H A Dxmppsocket.cc50 talk_base::AsyncSocket* socket = local
55 socket = talk_base::SSLAdapter::Create(socket);
58 cricket_socket_ = socket;
65 cricket_socket_ = socket;
87 void XmppSocket::OnReadEvent(talk_base::AsyncSocket * socket) { argument
91 void XmppSocket::OnWriteEvent(talk_base::AsyncSocket * socket) { argument
105 void XmppSocket::OnConnectEvent(talk_base::AsyncSocket * socket) { argument
118 void XmppSocket::OnCloseEvent(talk_base::AsyncSocket * socket, int error) { argument
/external/chromium/third_party/libjingle/source/talk/p2p/base/
H A Dudpport.cc51 LOG_J(LS_WARNING, this) << "UDP socket creation failed";
101 void UDPPort::OnAddresReady(talk_base::AsyncPacketSocket* socket, argument
107 talk_base::AsyncPacketSocket* socket, const char* data, size_t size,
109 ASSERT(socket == socket_);
106 OnReadPacket( talk_base::AsyncPacketSocket* socket, const char* data, size_t size, const talk_base::SocketAddress& remote_addr) argument
/external/jmonkeyengine/engine/src/networking/com/jme3/network/kernel/udp/
H A DUdpKernel.java238 private DatagramSocket socket; field in class:UdpKernel.HostThread
251 return socket;
256 socket = new DatagramSocket( address );
266 socket.close();
283 socket.receive(packet);
/external/okhttp/src/test/java/com/squareup/okhttp/internal/mockspdyserver/
H A DMockSpdyServer.java128 logger.log(Level.WARNING, "MockWebServer server socket close failed", e);
135 logger.log(Level.WARNING, "MockWebServer socket close failed", e);
149 Socket socket;
151 socket = serverSocket.accept();
155 openClientSockets.add(socket);
156 new SocketHandler(sequenceNumber++, socket).serve();
168 private Socket socket; field in class:MockSpdyServer.SocketHandler
170 private SocketHandler(int sequenceNumber, Socket socket) throws IOException { argument
171 this.socket = socket;
182 doSsl(Socket socket) argument
[all...]
/external/qemu/proxy/
H A Dproxy_int.h62 /* action a proxy connection when select() returns certain events for its socket */
69 int socket; member in struct:ProxyConnection
97 int socket,
108 * close the corresponding socket unless the
123 /* try to send data from the connection's buffer to a socket.
127 * returns DATA_ERROR for a socket disconnection or error
141 /* try to read 'wanted' bytes into conn->str from a socket
145 * returns DATA_ERROR in case of socket disconnection or error
/external/qemu/slirp/
H A Dsocket.h17 * Our socket structure
20 struct socket { struct
21 struct socket *so_next,*so_prev; /* For a linked list of sockets */
23 int s; /* The actual socket */
38 u_int8_t so_emu; /* Is the socket emulated? */
40 u_char so_type; /* Type of socket, UDP or TCP */
44 u_int so_expire; /* When the socket will expire */
46 int so_queued; /* Number of packets queued from this socket */
72 #define SS_FACCEPTONCE 0x200 /* If set, the SS_FACCEPTCONN socket will die after one accept */
74 extern struct socket tc
[all...]
/external/qemu/slirp-android/
H A Dsocket.h17 * Our socket structure
20 struct socket { struct
21 struct socket *so_next,*so_prev; /* For a linked list of sockets */
23 int s; /* The actual socket */
39 u_int8_t so_emu; /* Is the socket emulated? */
41 u_char so_type; /* Type of socket, UDP or TCP */
45 u_int so_expire; /* When the socket will expire */
47 int so_queued; /* Number of packets queued from this socket */
73 #define SS_FACCEPTONCE 0x200 /* If set, the SS_FACCEPTCONN socket will die after one accept */
77 extern struct socket tc
[all...]
/external/smack/src/org/jivesoftware/smackx/bytestreams/socks5/
H A DSocks5Proxy.java80 /* server socket to accept SOCKS5 connections */
261 * Returns the socket for the given digest. A socket will be returned if the given digest has
266 * @return socket or null if there is no socket for the given digest
315 Socket socket = null;
325 socket = Socks5Proxy.this.serverSocket.accept();
328 establishConnection(socket);
333 * do nothing, if caused by closing the server socket, thread will terminate in
339 if (socket !
358 establishConnection(Socket socket) argument
[all...]
/external/v8/test/cctest/
H A Dtest-sockets.cc38 Socket* server_; // Server socket used for bind/accept.
40 Semaphore* listening_; // Signalled when the server socket is in listen mode.
47 // Create the server socket and bind it to the requested port.
71 static bool SendAll(Socket* socket, const char* data, int len) { argument
74 int status = socket->Send(data, len);
94 // Create a socket listener.
131 // Initialize socket support.
/external/webkit/Source/WebKit2/Platform/gtk/
H A DWorkQueueGtk.cpp73 static gboolean performWork(GSocket* socket, GIOCondition condition, EventSource* eventSource) argument
143 GRefPtr<GSocket> socket = adoptGRef(g_socket_new_from_fd(fileDescriptor, 0)); local
144 ASSERT(socket);
146 GRefPtr<GSource> dispatchSource = adoptGRef(g_socket_create_source(socket.get(), static_cast<GIOCondition>(condition), cancellable.get()));
/external/webkit/Source/WebCore/inspector/front-end/
H A Dinspector.js395 WebInspector.socket = new WebSocket("ws://" + host + "/devtools/page/" + page);
396 WebInspector.socket.onmessage = function(message) { InspectorBackend.dispatch(message.data); }
397 WebInspector.socket.onerror = function(error) { console.error(error); }
398 WebInspector.socket.onopen = function() {
399 InspectorFrontendHost.sendMessageToBackend = WebInspector.socket.send.bind(WebInspector.socket);
400 InspectorFrontendHost.loaded = WebInspector.socket.send.bind(WebInspector.socket, "loaded");
419 if (WebInspector.socket)
/external/antlr/antlr-3.4/runtime/C/include/
H A Dantlr3debugeventlistener.h69 /// The socket structure we receive after a successful accept on the serverSocket
71 SOCKET socket; member in struct:ANTLR3_DEBUG_EVENT_LISTENER_struct
203 * Across a socket for remote debugging, only the RecognitionException
269 * sending events over a socket. A GUI for example will launch a thread
286 /// is in the socket buffer and throw it away.
325 * If you are receiving this event over a socket via
338 * If you are receiving this event over a socket via
346 * If you are receiving this event over a socket via
363 * If you are receiving this event over a socket via
372 * If you are receiving this event over a socket vi
[all...]
/external/antlr/antlr-3.4/runtime/CSharp3/Sources/Antlr3.Runtime.Debug/
H A DDebugEventSocketProxy.cs45 * A proxy debug event listener that forwards events over a socket to
47 * one event per line. ANTLRWorks listens on server socket with a
49 * be kept in sync. New events must be handled on both sides of socket.
57 protected Socket socket; field in class:Antlr.Runtime.Debug.DebugEventSocketProxy
106 socket = serverSocket.AcceptSocket();
107 socket.NoDelay = true;
110 socket.Send( encoding.GetBytes( "ANTLR " + DebugEventListenerConstants.ProtocolVersion + "\n" ) );
111 socket.Send( encoding.GetBytes( "grammar \"" + grammarFileName + "\n" ) );
115 //socket = serverSocket.accept();
116 //socket
[all...]
/external/apache-harmony/nio/src/test/java/common/org/apache/harmony/nio/tests/java/nio/channels/
H A DServerSocketChannelTest.java118 // Test for socket()
122 * Test method for 'java.nio.channels.ServerSocketChannel.socket()'
127 ServerSocket s1 = this.serverChannel.socket();
130 ServerSocket s2 = this.serverChannel.socket();
134 // socket close makes the channel close
143 ServerSocket s1 = this.serverChannel.socket();
146 ServerSocket s2 = this.serverChannel.socket();
150 // socket close makes the channel close
160 ServerSocket s1 = this.serverChannel.socket();
163 ServerSocket s2 = this.serverChannel.socket();
469 Socket socket; field in class:ServerSocketChannelTest.WriteSocketThread
473 WriteSocketThread(Socket socket, byte[] buffer) argument
[all...]
/external/apache-harmony/support/src/test/java/tests/support/
H A DSupport_HttpServer.java115 Support_Socket socket = serversocket.accept();
116 Thread thread = new Thread(new ServerThread(socket));
178 Support_Socket socket; field in class:Support_HttpServer.ServerThread
181 socket = s;
218 InputStream in = socket.getInputStream();
292 socket.close();
304 OutputStream os = socket.getOutputStream();
320 OutputStream os = socket.getOutputStream();
341 OutputStream os = socket.getOutputStream();
376 OutputStream os = socket
[all...]
/external/chromium/base/
H A Dmessage_pump_libevent.cc26 // struct event (of which there is roughly one per socket).
27 // The socket's struct event is created in
177 // Tell libevent which message pump this socket will belong to when we add it.
182 // Add this socket to the list of monitored sockets.
342 void MessagePumpLibevent::OnWakeup(int socket, short flags, void* context) { argument
345 DCHECK(that->wakeup_pipe_out_ == socket);
349 int nread = HANDLE_EINTR(read(socket, &buf, 1));
/external/chromium/net/http/
H A Dhttp_stream_factory_impl_unittest.cc21 #include "net/socket/socket_test_util.h"
158 ClientSocket* socket,
157 ReleaseSocket(const std::string& group_name, ClientSocket* socket, int id) argument
/external/chromium/net/socket/
H A Dclient_socket_handle.h21 #include "net/socket/client_socket.h"
22 #include "net/socket/client_socket_pool.h"
30 // client socket objects.
35 UNUSED = 0, // unused socket that just finished connecting
36 UNUSED_IDLE, // unused socket that has been idle for awhile
37 REUSED_IDLE, // previously used socket
45 // ClientSocketPool to obtain a connected socket, possibly reusing one. This
49 // If this method succeeds, then the socket member will be set to an existing
50 // connected socket if an existing connected socket wa
134 ClientSocket* socket() { return socket_.get(); } function in class:net::ClientSocketHandle
[all...]
/external/chromium/net/tools/testserver/
H A Dxmppserver.py16 import socket namespace
356 socket). It does the XMPP handshake and also implements the (old)
369 sock: The socket to the client.
380 # it does, and that calling dispatcher.__init__ with socket=None
493 self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
/external/chromium/testing/gmock/scripts/
H A Dupload.py42 import socket namespace
313 old_timeout = socket.getdefaulttimeout()
314 socket.setdefaulttimeout(timeout)
341 socket.setdefaulttimeout(old_timeout)

Completed in 656 milliseconds

12345678