/external/chromium/net/socket/ |
H A D | transport_client_socket_pool.cc | 5 #include "net/socket/transport_client_socket_pool.h" 17 #include "net/socket/client_socket_factory.h" 18 #include "net/socket/client_socket_handle.h" 19 #include "net/socket/client_socket_pool_base.h" 20 #include "net/socket/tcp_client_socket.h" 491 ClientSocket* socket, 493 base_.ReleaseSocket(group_name, socket, id); 489 ReleaseSocket( const std::string& group_name, ClientSocket* socket, int id) argument
|
H A D | ssl_client_socket_pool.cc | 5 #include "net/socket/ssl_client_socket_pool.h" 15 #include "net/socket/client_socket_factory.h" 16 #include "net/socket/client_socket_handle.h" 17 #include "net/socket/socks_client_socket_pool.h" 18 #include "net/socket/ssl_client_socket.h" 19 #include "net/socket/ssl_host_info.h" 20 #include "net/socket/transport_client_socket_pool.h" 158 if (transport_socket_handle_->socket()) 314 ClientSocket* socket = transport_socket_handle_->socket(); local 576 ReleaseSocket(const std::string& group_name, ClientSocket* socket, int id) argument [all...] |
H A D | tcp_client_socket_win.cc | 5 #include "net/socket/tcp_client_socket_win.h" 67 explicit Core(TCPClientSocketWin* socket); 128 // The socket that created this object. 141 // When doing reads from the socket, we try to mirror TCP's slow start. 152 TCPClientSocketWin* socket) 154 socket_(socket), 238 void TCPClientSocketWin::AdoptSocket(SOCKET socket) { argument 240 socket_ = socket; 336 // WSAEventSelect sets the socket to non-blocking mode as a side effect. 337 // Our connect() and recv() calls require that the socket b 151 Core( TCPClientSocketWin* socket) argument [all...] |
/external/chromium/net/socket_stream/ |
H A D | socket_stream_unittest.cc | 15 #include "net/socket/socket_test_util.h" 30 : event_type(type), socket(socket_stream), number(num), data(str), 34 net::SocketStream* socket; member in struct:SocketStreamEvent 73 virtual void OnConnected(net::SocketStream* socket, argument 77 socket, num_pending_send_allowed, std::string(), 82 virtual void OnSentData(net::SocketStream* socket, argument 86 socket, amount_sent, std::string(), NULL)); 90 virtual void OnReceivedData(net::SocketStream* socket, argument 94 socket, len, std::string(data, len), NULL)); 98 virtual void OnClose(net::SocketStream* socket) { argument 107 OnAuthRequired(net::SocketStream* socket, net::AuthChallengeInfo* auth_info) argument [all...] |
H A D | socket_stream.h | 28 #include "net/socket/tcp_client_socket.h" 62 virtual int OnStartOpenConnection(SocketStream* socket, argument 67 // Called when socket stream has been connected. The socket stream accepts 68 // at most |max_pending_send_allowed| so that a client of the socket stream 71 virtual void OnConnected(SocketStream* socket, 75 virtual void OnSentData(SocketStream* socket, 79 virtual void OnReceivedData(SocketStream* socket, 82 // Called when the socket stream has been closed. 83 virtual void OnClose(SocketStream* socket) 88 OnAuthRequired(SocketStream* socket, AuthChallengeInfo* auth_info) argument 97 OnError(const SocketStream* socket, int error) argument [all...] |
/external/chromium/net/websockets/ |
H A D | websocket_unittest.cc | 13 #include "net/socket/socket_test_util.h" 27 : event_type(type), socket(websocket), msg(websocket_msg), 31 net::WebSocket* socket; member in struct:WebSocketEvent 61 virtual void OnOpen(net::WebSocket* socket) { argument 63 WebSocketEvent(WebSocketEvent::EVENT_OPEN, socket, 69 virtual void OnMessage(net::WebSocket* socket, const std::string& msg) { argument 71 WebSocketEvent(WebSocketEvent::EVENT_MESSAGE, socket, msg, false)); 75 virtual void OnError(net::WebSocket* socket) { argument 77 WebSocketEvent(WebSocketEvent::EVENT_ERROR, socket, 82 virtual void OnClose(net::WebSocket* socket, boo argument [all...] |
H A D | websocket_job_unittest.cc | 60 virtual void OnConnected(SocketStream* socket, int max_pending_send_allowed) { argument 62 virtual void OnSentData(SocketStream* socket, int amount_sent) { argument 65 virtual void OnReceivedData(SocketStream* socket, argument 69 virtual void OnClose(SocketStream* socket) { argument
|
/external/chromium/third_party/libjingle/source/talk/xmpp/ |
H A D | xmppclient.cc | 86 // slots for socket signals 93 XmppClient::Connect(const XmppClientSettings & settings, const std::string & lang, AsyncSocket * socket, PreXmppAuth * pre_auth) { argument 94 if (socket == NULL) 99 d_->socket_.reset(socket);
|
/external/chromium-trace/trace-viewer/examples/stream_server/ |
H A D | standalone.py | 121 import socket namespace 269 return socket._fileobject(self._connection, mode, bufsize) 282 socket object to self.socket before server_bind and server_activate, 315 (socket.AF_INET6, socket.SOCK_STREAM, '', '', ''), 316 (socket.AF_INET, socket.SOCK_STREAM, '', '', '')] 318 addrinfo_array = socket.getaddrinfo(self.server_name, 320 socket [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/ |
H A D | standalone.py | 121 import socket namespace 265 return socket._fileobject(self._connection, mode, bufsize) 278 socket object to self.socket before server_bind and server_activate, 311 (socket.AF_INET6, socket.SOCK_STREAM, '', '', ''), 312 (socket.AF_INET, socket.SOCK_STREAM, '', '', '')] 314 addrinfo_array = socket.getaddrinfo(self.server_name, 316 socket [all...] |
/external/clang/tools/scan-view/ |
H A D | ScanView.py | 12 import socket namespace 176 # Ignore socket errors 178 if info and isinstance(info[1], socket.error): 180 print >>sys.stderr, "%s: SERVER: ignored socket error." % (sys.argv[0],)
|
/external/dhcpcd/ |
H A D | dhcpcd.h | 31 #include <sys/socket.h> 76 int socket; member in struct:if_state
|
/external/kernel-headers/original/linux/ |
H A D | net.h | 22 #include <asm/socket.h> 49 SS_UNCONNECTED, /* unconnected to any socket */ 51 SS_CONNECTED, /* connected to socket */ 69 * @SOCK_STREAM: stream (connection) socket 70 * @SOCK_DGRAM: datagram (conn.less) socket 71 * @SOCK_RAW: raw socket 73 * @SOCK_SEQPACKET: sequential packet socket 74 * @SOCK_DCCP: Datagram Congestion Control Protocol socket 78 * When adding some new socket type please 79 * grep ARCH_HAS_SOCKET_TYPE include/asm-* /socket 107 struct socket { struct [all...] |
/external/qemu/proxy/ |
H A D | proxy_common.c | 61 int socket, 68 conn->socket = socket; 77 socket_set_nonblock(socket); 80 SocketType type = socket_get_type(socket); 85 sock_address_to_string(address), socket ); 99 if (conn->socket >= 0) { 100 socket_close(conn->socket); 101 conn->socket = -1; 313 int fd = conn->socket; 60 proxy_connection_init( ProxyConnection* conn, int socket, SockAddress* address, ProxyService* service, ProxyConnectionFreeFunc conn_free, ProxyConnectionSelectFunc conn_select, ProxyConnectionPollFunc conn_poll ) argument [all...] |
/external/quake/quake/src/WinQuake/ |
H A D | net_udp.cpp | 25 #include <sys/socket.h> 45 static int net_acceptsocket = -1; // socket for fielding new connections 69 ifc_ctl_sock = socket(AF_INET, SOCK_DGRAM, 0); 71 Con_Printf("socket() failed: %s\n", strerror(errno)); 172 Sys_Error("UDP_Init: Unable to open control socket\n"); 214 Sys_Error ("UDP_Listen: Unable to open accept socket\n"); 236 if ((newsocket = socket (PF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1) 257 int UDP_CloseSocket (int socket) argument 259 if (socket == net_broadcastsocket) 261 return close (socket); 324 UDP_Connect(int socket, struct qsockaddr *addr) argument 347 UDP_Read(int socket, byte *buf, int len, struct qsockaddr *addr) argument 360 UDP_MakeSocketBroadcastCapable(int socket) argument 374 UDP_Broadcast(int socket, byte *buf, int len) argument 395 UDP_Write(int socket, byte *buf, int len, struct qsockaddr *addr) argument 435 UDP_GetSocketAddr(int socket, struct qsockaddr *addr) argument [all...] |
/external/antlr/antlr-3.4/runtime/Python/antlr3/ |
H A D | debug.py | 31 import socket namespace 541 Across a socket for remote debugging, only the RecognitionException 614 sending events over a socket. A GUI for example will launch a thread 664 If you are receiving this event over a socket via 680 If you are receiving this event over a socket via 699 If you are receiving this event over a socket via 710 If you are receiving this event over a socket via 721 If you are receiving this event over a socket via 833 """A proxy debug event listener that forwards events over a socket to 835 one event per line. ANTLRWorks listens on server socket wit [all...] |
/external/chromium/net/http/ |
H A D | http_proxy_client_socket_pool.cc | 16 #include "net/socket/client_socket_factory.h" 17 #include "net/socket/client_socket_handle.h" 18 #include "net/socket/client_socket_pool_base.h" 19 #include "net/socket/ssl_client_socket.h" 20 #include "net/socket/ssl_client_socket_pool.h" 21 #include "net/socket/transport_client_socket_pool.h" 83 // top of the timeout for the transport socket. 244 if (transport_socket_handle_->socket()) 245 transport_socket_handle_->socket()->Disconnect(); 250 static_cast<SSLClientSocket*>(transport_socket_handle_->socket()); 472 ReleaseSocket(const std::string& group_name, ClientSocket* socket, int id) argument [all...] |
/external/chromium/net/server/ |
H A D | http_server.cc | 240 ST_WS_READY, // Ready to receive web socket frame 362 ListenSocket* socket) { 363 Connection* connection = new Connection(this, socket); 365 socket_to_connection_[socket] = connection; 368 void HttpServer::DidRead(ListenSocket* socket, argument 371 Connection* connection = FindConnection(socket); 418 void HttpServer::DidClose(ListenSocket* socket) { argument 419 Connection* connection = FindConnection(socket); 433 HttpServer::Connection* HttpServer::FindConnection(ListenSocket* socket) { argument 434 SocketToConnectionMap::iterator it = socket_to_connection_.find(socket); 361 DidAccept(ListenSocket* server, ListenSocket* socket) argument [all...] |
/external/chromium/net/tools/testserver/ |
H A D | testserver.py | 27 import socket namespace 70 self.socket.close() 141 except socket.error: 1390 server_data['port'] = server.socket.getsockname()[1]
|
/external/chromium/third_party/libjingle/source/talk/base/ |
H A D | openssladapter.cc | 60 "socket", 73 BIO* BIO_new_socket(talk_base::AsyncSocket* socket) { argument 78 ret->ptr = socket; 85 b->num = 0; // 1 means socket closed 99 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr); 101 int result = socket->Recv(out, outl); 106 } else if (socket->IsBlocking()) { 115 talk_base::AsyncSocket* socket = static_cast<talk_base::AsyncSocket*>(b->ptr); 117 int result = socket->Send(in, inl); 120 } else if (socket 237 OpenSSLAdapter(AsyncSocket* socket) argument 536 OnConnectEvent(AsyncSocket* socket) argument 551 OnReadEvent(AsyncSocket* socket) argument 581 OnWriteEvent(AsyncSocket* socket) argument 612 OnCloseEvent(AsyncSocket* socket, int err) argument [all...] |
H A D | schanneladapter.cc | 108 SChannelAdapter::SChannelAdapter(AsyncSocket* socket) argument 109 : SSLAdapter(socket), state_(SSL_NONE), 610 // socket api doesn't support nice shutdown at this point, we don't bother. 632 SChannelAdapter::OnConnectEvent(AsyncSocket* socket) { argument 636 AsyncSocketAdapter::OnConnectEvent(socket); 647 SChannelAdapter::OnReadEvent(AsyncSocket* socket) { argument 649 AsyncSocketAdapter::OnReadEvent(socket); 675 SChannelAdapter::OnWriteEvent(AsyncSocket* socket) { argument 677 AsyncSocketAdapter::OnWriteEvent(socket); 692 AsyncSocketAdapter::OnWriteEvent(socket); 697 OnCloseEvent(AsyncSocket* socket, int err) argument [all...] |
/external/chromium/third_party/libjingle/source/talk/p2p/base/ |
H A D | relayserver.cc | 51 // Calls SendTo on the given socket and logs any bad results. 52 void Send(talk_base::AsyncPacketSocket* socket, const char* bytes, size_t size, argument 54 int result = socket->SendTo(bytes, size, addr); 63 // Sends the given STUN message on the given socket. 65 talk_base::AsyncPacketSocket* socket, 69 Send(socket, buf.Data(), buf.Length(), addr); 72 // Constructs a STUN error response and sends it on the given socket. 73 void SendStunError(const StunMessage& msg, talk_base::AsyncPacketSocket* socket, argument 94 SendStun(err_msg, socket, remote_addr); 110 talk_base::AsyncSocket* socket local 64 SendStun(const StunMessage& msg, talk_base::AsyncPacketSocket* socket, const talk_base::SocketAddress& addr) argument 116 AddInternalSocket(talk_base::AsyncPacketSocket* socket) argument 123 RemoveInternalSocket(talk_base::AsyncPacketSocket* socket) argument 131 AddExternalSocket(talk_base::AsyncPacketSocket* socket) argument 138 RemoveExternalSocket(talk_base::AsyncPacketSocket* socket) argument 146 AddInternalServerSocket(talk_base::AsyncSocket* socket, cricket::ProtocolType proto) argument 154 RemoveInternalServerSocket( talk_base::AsyncSocket* socket) argument 188 OnReadEvent(talk_base::AsyncSocket* socket) argument 194 OnInternalPacket( talk_base::AsyncPacketSocket* socket, const char* bytes, size_t size, const talk_base::SocketAddress& remote_addr) argument 241 OnExternalPacket( talk_base::AsyncPacketSocket* socket, const char* bytes, size_t size, const talk_base::SocketAddress& remote_addr) argument 312 HandleStun( const char* bytes, size_t size, const talk_base::SocketAddress& remote_addr, talk_base::AsyncPacketSocket* socket, std::string* username, StunMessage* msg) argument 341 HandleStunAllocate( const char* bytes, size_t size, const talk_base::SocketAddressPair& ap, talk_base::AsyncPacketSocket* socket) argument 494 talk_base::AsyncPacketSocket* socket = external_sockets_[0]; local 558 talk_base::AsyncSocket* socket = local 592 RelayServerConnection( RelayServerBinding* binding, const talk_base::SocketAddressPair& addrs, talk_base::AsyncPacketSocket* socket) argument [all...] |
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/ |
H A D | client_for_testing.py | 54 import socket namespace 132 def receive_bytes(socket, length): 136 received_bytes = socket.recv(remaining) 152 def _read_fields(socket): 160 name = _read_name(socket) 165 ch = _skip_spaces(socket) 167 value = _read_value(socket, ch) 169 ch = receive_bytes(socket, 1) 184 def _read_name(socket): 189 ch = receive_bytes(socket, [all...] |
/external/netperf/ |
H A D | nettest_sdp.c | 51 #include <sys/socket.h> 118 -P local[,remote] Set the local/remote port for the data socket\n\ 120 -s send[,recv] Set local socket send/recv buffer sizes\n\ 121 -S send[,recv] Set remote socket send/recv buffer sizes\n\ 144 get_sdp_info(int socket, int * mss) 151 if (getsockopt(socket, 215 /* the size of the local senc socket buffer. We will want to deal */ 260 /* control socket, and since we want to be able to use different */ 297 /*set up the data socket */ 304 perror("netperf: send_sdp_stream: sdp stream data socket"); 142 get_sdp_info(int socket, int * mss) argument [all...] |
/external/openssl/ |
H A D | e_os.h | 232 # include <sys/socket.h> 509 # define socket(d,t,p) ((int)socket(d,t,p)) macro 535 # include <sys/socket.h> 565 # include <socket.h> 569 # include <sys/socket.h>
|