Searched defs:socket (Results 101 - 125 of 168) sorted by relevance

1234567

/external/chromium/net/socket/
H A Dtransport_client_socket_pool.cc5 #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 Dssl_client_socket_pool.cc5 #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 Dtcp_client_socket_win.cc5 #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 Dsocket_stream_unittest.cc15 #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 Dsocket_stream.h28 #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 Dwebsocket_unittest.cc13 #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 Dwebsocket_job_unittest.cc60 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 Dxmppclient.cc86 // 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 Dstandalone.py121 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 Dstandalone.py121 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 DScanView.py12 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 Ddhcpcd.h31 #include <sys/socket.h>
76 int socket; member in struct:if_state
/external/kernel-headers/original/linux/
H A Dnet.h22 #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 Dproxy_common.c61 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 Dnet_udp.cpp25 #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 Ddebug.py31 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 Dhttp_proxy_client_socket_pool.cc16 #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 Dhttp_server.cc240 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 Dtestserver.py27 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 Dopenssladapter.cc60 "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 Dschanneladapter.cc108 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 Drelayserver.cc51 // 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 Dclient_for_testing.py54 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 Dnettest_sdp.c51 #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 De_os.h232 # 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>

Completed in 526 milliseconds

1234567