/external/chromium/net/udp/ |
H A D | udp_socket_win.h | 30 // 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 D | websocket_throttle_unittest.cc | 23 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 D | websocket.h | 42 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 D | websocket_job.cc | 164 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 D | asyncudpsocket.cc | 41 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 D | xmppsocket.cc | 50 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 D | udpport.cc | 51 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 D | UdpKernel.java | 238 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 D | MockSpdyServer.java | 128 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 D | proxy_int.h | 62 /* 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 D | socket.h | 17 * 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 D | socket.h | 17 * 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 D | Socks5Proxy.java | 80 /* 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 D | test-sockets.cc | 38 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 D | WorkQueueGtk.cpp | 73 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 D | inspector.js | 395 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 D | antlr3debugeventlistener.h | 69 /// 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 D | DebugEventSocketProxy.cs | 45 * 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 D | ServerSocketChannelTest.java | 118 // 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 D | Support_HttpServer.java | 115 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 D | message_pump_libevent.cc | 26 // 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 D | http_stream_factory_impl_unittest.cc | 21 #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 D | client_socket_handle.h | 21 #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 D | xmppserver.py | 16 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 D | upload.py | 42 import socket namespace 313 old_timeout = socket.getdefaulttimeout() 314 socket.setdefaulttimeout(timeout) 341 socket.setdefaulttimeout(old_timeout)
|