Searched defs:socket (Results 76 - 100 of 184) sorted by relevance

12345678

/external/chromium/testing/gtest/scripts/
H A Dupload.py42 import socket namespace
313 old_timeout = socket.getdefaulttimeout()
314 socket.setdefaulttimeout(timeout)
341 socket.setdefaulttimeout(old_timeout)
/external/chromium/third_party/libjingle/source/talk/base/
H A Dasyncsocket.h33 #include "talk/base/socket.h"
39 // Provides the ability to perform socket I/O asynchronously.
55 // The adapted socket may explicitly be NULL, and later assigned using Attach.
59 explicit AsyncSocketAdapter(AsyncSocket* socket);
61 void Attach(AsyncSocket* socket);
115 virtual void OnConnectEvent(AsyncSocket* socket) { argument
118 virtual void OnReadEvent(AsyncSocket* socket) { argument
121 virtual void OnWriteEvent(AsyncSocket* socket) { argument
124 virtual void OnCloseEvent(AsyncSocket* socket, int err) { argument
H A Dasynctcpsocket.cc53 // This will still return a socket even if we failed to listen on
55 // connections on this socket, the corresponding port is still
63 AsyncTCPSocket::AsyncTCPSocket(AsyncSocket* socket, bool listen) argument
64 : socket_(socket),
213 void AsyncTCPSocket::OnConnectEvent(AsyncSocket* socket) { argument
217 void AsyncTCPSocket::OnReadEvent(AsyncSocket* socket) { argument
218 ASSERT(socket_.get() == socket);
222 talk_base::AsyncSocket* new_socket = socket->Accept(&address);
256 void AsyncTCPSocket::OnWriteEvent(AsyncSocket* socket) { argument
257 ASSERT(socket_.get() == socket);
264 OnCloseEvent(AsyncSocket* socket, int error) argument
[all...]
H A Dfirewallsocketserver.cc40 FirewallSocket(FirewallSocketServer* server, AsyncSocket* socket, int type) argument
41 : AsyncSocketAdapter(socket), server_(server), type_(type) {
205 LOG(LS_VERBOSE) << "FirewallSocketServer socket creation denied";
H A Dsocketadapters.cc58 BufferedReadAdapter::BufferedReadAdapter(AsyncSocket* socket, size_t size) argument
59 : AsyncSocketAdapter(socket), buffer_size_(size),
109 void BufferedReadAdapter::OnReadEvent(AsyncSocket * socket) { argument
110 ASSERT(socket == socket_);
113 AsyncSocketAdapter::OnReadEvent(socket);
177 AsyncSSLSocket::AsyncSSLSocket(AsyncSocket* socket) argument
178 : BufferedReadAdapter(socket, 1024) {
188 void AsyncSSLSocket::OnConnectEvent(AsyncSocket * socket) { argument
189 ASSERT(socket == socket_);
214 // FIX: if SignalConnect causes the socket t
219 AsyncSSLServerSocket(AsyncSocket* socket) argument
250 AsyncHttpsProxySocket(AsyncSocket* socket, const std::string& user_agent, const SocketAddress& proxy, const std::string& username, const CryptString& password) argument
301 OnConnectEvent(AsyncSocket * socket) argument
311 OnCloseEvent(AsyncSocket * socket, int err) argument
517 AsyncSocksProxySocket(AsyncSocket* socket, const SocketAddress& proxy, const std::string& username, const CryptString& password) argument
555 OnConnectEvent(AsyncSocket* socket) argument
[all...]
H A Dsocketadapters.h45 // Implements a socket adapter that can buffer and process data internally,
47 // protocol before commencing normal socket behavior.
50 BufferedReadAdapter(AsyncSocket* socket, size_t buffer_size);
64 virtual void OnReadEvent(AsyncSocket * socket);
78 AsyncProxyServerSocket(AsyncSocket* socket, size_t buffer_size) argument
79 : BufferedReadAdapter(socket, buffer_size) {}
87 // Implements a socket adapter that performs the client side of a
91 explicit AsyncSSLSocket(AsyncSocket* socket);
96 virtual void OnConnectEvent(AsyncSocket* socket);
101 // Implements a socket adapte
[all...]
/external/chromium/third_party/libjingle/source/talk/p2p/base/
H A Drelayserver.h64 void AddInternalSocket(talk_base::AsyncPacketSocket* socket);
65 void RemoveInternalSocket(talk_base::AsyncPacketSocket* socket);
70 void AddExternalSocket(talk_base::AsyncPacketSocket* socket);
71 void RemoveExternalSocket(talk_base::AsyncPacketSocket* socket);
75 // internal socket will be added.
76 void AddInternalServerSocket(talk_base::AsyncSocket* socket,
79 // Removes this server socket from the list.
80 void RemoveInternalServerSocket(talk_base::AsyncSocket* socket);
104 void OnInternalPacket(talk_base::AsyncPacketSocket* socket,
107 void OnExternalPacket(talk_base::AsyncPacketSocket* socket,
155 talk_base::AsyncPacketSocket* socket() { return socket_; } function in class:cricket::RelayServerConnection
[all...]
H A Dstunport.cc145 LOG_J(LS_WARNING, this) << "UDP socket creation failed";
204 void StunPort::OnReadPacket(talk_base::AsyncPacketSocket* socket, argument
207 ASSERT(socket == socket_);
H A Dtcpport.cc48 // Treat failure to create or bind a TCP socket as fatal. This
54 LOG_J(LS_ERROR, this) << "TCP socket creation failed.";
84 if (talk_base::AsyncPacketSocket* socket =
86 socket->SignalReadPacket.disconnect(this);
87 conn = new TCPConnection(this, address, socket);
112 talk_base::AsyncPacketSocket * socket = NULL; local
114 socket = conn->socket();
116 socket = GetIncoming(addr);
118 if (!socket) {
141 OnNewConnection(talk_base::AsyncPacketSocket* socket, talk_base::AsyncPacketSocket* new_socket) argument
157 talk_base::AsyncPacketSocket* socket = NULL; local
170 OnReadPacket(talk_base::AsyncPacketSocket* socket, const char* data, size_t size, const talk_base::SocketAddress& remote_addr) argument
176 OnAddresReady(talk_base::AsyncPacketSocket* socket, const talk_base::SocketAddress& address) argument
181 TCPConnection(TCPPort* port, const Candidate& candidate, talk_base::AsyncPacketSocket* socket) argument
241 OnConnect(talk_base::AsyncPacketSocket* socket) argument
248 OnClose(talk_base::AsyncPacketSocket* socket, int error) argument
255 OnReadPacket(talk_base::AsyncPacketSocket* socket, const char* data, size_t size, const talk_base::SocketAddress& remote_addr) argument
[all...]
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/example/
H A Decho_client.py71 import socket namespace
130 def _receive_bytes(socket, length):
134 received_bytes = socket.recv(remaining)
187 self._ssl = socket.ssl(raw_socket)
287 def __init__(self, socket, options):
290 self._socket = socket
296 """Performs opening handshake on the specified socket.
494 def __init__(self, socket, options):
497 self._socket = socket
503 """Performs opening handshake on the specified socket
[all...]
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/mod_pywebsocket/
H A Dutil.py55 import socket namespace
346 """A wrapper class for socket object to intercept send and recv to perform
353 def __init__(self, socket):
354 self._socket = socket
362 """Receives data from the socket specified on the construction up
435 # socket._fileobject.read also blocks until length bytes was read
460 # Set the socket non-blocking.
466 # Drain until the socket is closed or no data is immediately
474 except socket.error, e:
477 # the errors that indicates that the socket block
[all...]
/external/chromium-trace/trace-viewer/third_party/pywebsocket/src/test/
H A Dmux_client_for_testing.py52 import socket namespace
508 self._socket = socket.socket()
H A Dtest_endtoend.py39 import socket namespace
170 s = socket.socket()
/external/javassist/src/main/javassist/tools/web/
H A DWebserver.java37 private ServerSocket socket; field in class:Webserver
102 socket = new ServerSocket(port);
132 * Closes the socket.
135 socket.close();
180 ServiceThread th = new ServiceThread(this, socket.accept());
/external/libppp/src/
H A Dmp.h65 struct sockaddr_un socket; /* On this socket */ member in struct:mpserver
82 struct mpserver server; /* Our ``sharing'' socket */
/external/libvpx/libvpx/third_party/googletest/src/scripts/
H A Dupload.py42 import socket namespace
313 old_timeout = socket.getdefaulttimeout()
314 socket.setdefaulttimeout(timeout)
341 socket.setdefaulttimeout(old_timeout)
/external/mockwebserver/src/main/java/com/google/mockwebserver/
H A DMockWebServer.java219 logger.log(Level.WARNING, "MockWebServer server socket close failed", e);
226 logger.log(Level.WARNING, "MockWebServer socket close failed", e);
238 Socket socket;
240 socket = serverSocket.accept();
247 socket.close();
249 openClientSockets.add(socket);
250 serveConnection(socket);
277 Socket socket;
287 socket = sslSocketFactory.createSocket(
289 ((SSLSocket) socket)
389 readRequest(Socket socket, InputStream in, int sequenceNumber) argument
[all...]
/external/okhttp/src/main/java/com/squareup/okhttp/
H A DConnection.java84 private Socket socket; field in class:Connection
109 socket = (proxy.type() != Proxy.Type.HTTP) ? new Socket(proxy) : new Socket();
110 socket.connect(inetSocketAddress, connectTimeout);
111 socket.setSoTimeout(readTimeout);
112 in = socket.getInputStream();
113 out = socket.getOutputStream();
119 // Buffer the socket stream to permit efficient parsing of HTTP headers and chunk sizes.
138 // Create the wrapper over connected socket.
139 socket = address.sslSocketFactory
140 .createSocket(socket, addres
[all...]
/external/okhttp/src/main/java/com/squareup/okhttp/internal/
H A DPlatform.java62 public void tagSocket(Socket socket) throws SocketException { argument
65 public void untagSocket(Socket socket) throws SocketException { argument
77 public void enableTlsExtensions(SSLSocket socket, String uriHost) { argument
84 public void supportTlsIntolerantServer(SSLSocket socket) { argument
85 socket.setEnabledProtocols(new String[] {"SSLv3"});
89 public byte[] getNpnSelectedProtocol(SSLSocket socket) { argument
94 * Sets client-supported protocols on a socket to send to a server. The
95 * protocols are only sent if the socket implementation supports NPN.
97 public void setNpnProtocols(SSLSocket socket, byte[] npnProtocols) { argument
186 @Override public void enableTlsExtensions(SSLSocket socket, Strin argument
214 setNpnProtocols(SSLSocket socket, byte[] npnProtocols) argument
227 getNpnSelectedProtocol(SSLSocket socket) argument
259 setNpnProtocols(SSLSocket socket, byte[] npnProtocols) argument
280 getNpnSelectedProtocol(SSLSocket socket) argument
[all...]
H A DUtil.java115 * Closes {@code socket}, ignoring any checked exceptions. Does nothing if
116 * {@code socket} is null.
118 public static void closeQuietly(Socket socket) { argument
119 if (socket != null) {
121 socket.close();
/external/okhttp/src/test/java/com/squareup/okhttp/internal/spdy/
H A DMockSpdyPeer.java47 private Socket socket; field in class:MockSpdyPeer
93 if (socket != null) throw new IllegalStateException();
94 socket = serverSocket.accept();
95 OutputStream out = socket.getOutputStream();
96 InputStream in = socket.getInputStream();
129 Util.closeQuietly(socket);
137 Socket socket = this.socket;
138 if (socket != null) {
139 socket
[all...]
/external/quake/quake/src/WinQuake/
H A Dnet_mp.cpp35 static int net_acceptsocket = -1; // socket for fielding new connections
100 Sys_Error("MPATH_Init: Unable to open control socket\n");
136 Sys_Error ("MPATH_Listen: Unable to open accept socket\n");
155 if ((newsocket = socket (PF_INET, SOCK_DGRAM, IPPROTO_UDP)) == -1)
176 int MPATH_CloseSocket (int socket) argument
178 if (socket == net_broadcastsocket)
180 return closesocket (socket);
243 int MPATH_Connect (int socket, struct qsockaddr *addr) argument
264 int MPATH_Read (int socket, byte *buf, int len, struct qsockaddr *addr) argument
269 ret = recvfrom (socket, bu
283 MPATH_MakeSocketBroadcastCapable(int socket) argument
297 MPATH_Broadcast(int socket, byte *buf, int len) argument
318 MPATH_Write(int socket, byte *buf, int len, struct qsockaddr *addr) argument
362 MPATH_GetSocketAddr(int socket, struct qsockaddr *addr) argument
[all...]
H A Dnet_wipx.cpp31 static int net_acceptsocket = -1; // socket for fielding new connections
102 Con_Printf("WIPX_Init: Unable to open control socket\n");
145 Sys_Error ("WIPX_Listen: Unable to open accept socket\n");
201 int socket = ipxsocket[handle]; local
204 ret = pclosesocket (socket);
240 int socket = ipxsocket[handle]; local
243 ret = precvfrom (socket, packetBuffer, len+4, 0, (struct sockaddr *)addr, &addrlen);
274 int socket = ipxsocket[handle]; local
283 ret = psendto (socket, packetBuffer, len, 0, (struct sockaddr *)addr, sizeof(struct qsockaddr));
353 int socket local
[all...]
/external/antlr/antlr-3.4/runtime/CSharp2/Sources/Antlr3.Runtime/Antlr.Runtime.Debug/
H A DDebugEventSocketProxy.cs46 * A proxy debug event listener that forwards events over a socket to
48 * one event per line. ANTLRWorks listens on server socket with a
50 * 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
99 socket = serverSocket.AcceptSocket();
100 socket.NoDelay = true;
103 socket.Send(encoding.GetBytes("ANTLR " + DebugEventListenerConstants.ProtocolVersion + "\n"));
104 socket.Send(encoding.GetBytes("grammar \"" + grammarFileName + "\n"));
108 //socket = serverSocket.accept();
109 //socket
[all...]
/external/antlr/antlr-3.4/runtime/Java/src/main/java/org/antlr/runtime/debug/
H A DDebugEventSocketProxy.java39 /** A proxy debug event listener that forwards events over a socket to
41 * one event per line. ANTLRWorks listens on server socket with a
43 * be kept in sync. New events must be handled on both sides of socket.
49 protected Socket socket; field in class:DebugEventSocketProxy
76 socket = serverSocket.accept();
77 socket.setTcpNoDelay(true);
78 OutputStream os = socket.getOutputStream();
81 InputStream is = socket.getInputStream();
99 socket.close();

Completed in 1127 milliseconds

12345678