/external/chromium/testing/gtest/scripts/ |
H A D | upload.py | 42 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 D | asyncsocket.h | 33 #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 D | asynctcpsocket.cc | 53 // 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 D | firewallsocketserver.cc | 40 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 D | socketadapters.cc | 58 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 D | socketadapters.h | 45 // 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 D | relayserver.h | 64 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 D | stunport.cc | 145 LOG_J(LS_WARNING, this) << "UDP socket creation failed"; 204 void StunPort::OnReadPacket(talk_base::AsyncPacketSocket* socket, argument 207 ASSERT(socket == socket_);
|
H A D | tcpport.cc | 48 // 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 D | echo_client.py | 71 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 D | util.py | 55 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 D | mux_client_for_testing.py | 52 import socket namespace 508 self._socket = socket.socket()
|
H A D | test_endtoend.py | 39 import socket namespace 170 s = socket.socket()
|
/external/javassist/src/main/javassist/tools/web/ |
H A D | Webserver.java | 37 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 D | mp.h | 65 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 D | upload.py | 42 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 D | MockWebServer.java | 219 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 D | Connection.java | 84 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 D | Platform.java | 62 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 D | Util.java | 115 * 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 D | MockSpdyPeer.java | 47 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 D | net_mp.cpp | 35 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 D | net_wipx.cpp | 31 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 D | DebugEventSocketProxy.cs | 46 * 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 D | DebugEventSocketProxy.java | 39 /** 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();
|