/external/chromium_org/third_party/webrtc/base/ |
H A D | testclient_unittest.cc | 23 AsyncSocket* socket = main->socketserver() local 25 socket->Bind(loopback); 27 TestClient client(new AsyncUDPSocket(socket)); 39 AsyncSocket* socket = main->socketserver() local 42 socket, loopback, server.address());
|
/external/chromium_org/third_party/webrtc/test/channel_transport/ |
H A D | udp_socket_wrapper_unittest.cc | 49 // Creates a socket using the static constructor method and verifies that 50 // it's added to the socket manager. 53 // We can't test deletion of sockets without a socket manager. 56 UdpSocketWrapper* socket = local 63 socket->CloseBlocking();
|
/external/chromium_org/tools/android/common/ |
H A D | net.cc | 9 #include <sys/socket.h> 16 int DisableNagle(int socket) { argument 18 return setsockopt(socket, IPPROTO_TCP, TCP_NODELAY, &on, sizeof(on)); 21 int DeferAccept(int socket) { argument 23 return setsockopt(socket, IPPROTO_TCP, TCP_DEFER_ACCEPT, &on, sizeof(on));
|
/external/apache-http/src/org/apache/http/impl/io/ |
H A D | SocketInputBuffer.java | 59 private final Socket socket; field in class:SocketInputBuffer 62 final Socket socket, 66 if (socket == null) { 69 this.socket = socket; 75 init(socket.getInputStream(), 8192, params); 82 int oldtimeout = this.socket.getSoTimeout(); 84 this.socket.setSoTimeout(timeout); 92 socket.setSoTimeout(oldtimeout); 111 int oldTimeout = this.socket 61 SocketInputBuffer( final Socket socket, int buffersize, final HttpParams params) argument [all...] |
/external/chromium_org/base/ |
H A D | async_socket_io_handler_posix.cc | 24 void AsyncSocketIoHandler::OnFileCanReadWithoutBlocking(int socket) { argument 26 DCHECK_EQ(socket, socket_); 37 // We're getting notifications that we can read from the socket while 67 bool AsyncSocketIoHandler::Initialize(base::SyncSocket::Handle socket, argument 73 socket_ = socket; 77 int value = fcntl(socket, F_GETFL); 79 // Set the socket to be non-blocking so we can do async reads. 80 if (fcntl(socket, F_SETFL, O_NONBLOCK) == -1) {
|
H A D | async_socket_io_handler_win.cc | 58 bool AsyncSocketIoHandler::Initialize(base::SyncSocket::Handle socket, argument 65 socket_ = socket; 68 base::MessageLoopForIO::current()->RegisterIOHandler(socket, this);
|
/external/chromium_org/build/android/pylib/ |
H A D | ports.py | 13 import socket namespace 96 # socket and closing it would leave it in the TIME_WAIT state. Setting 170 except (httplib.HTTPException, socket.error) as e:
|
/external/chromium_org/chrome/test/chromedriver/server/ |
H A D | server.py | 7 import socket namespace 49 socket.create_connection(('127.0.0.1', port), 0.2).close() 50 except socket.error:
|
/external/chromium_org/ipc/ |
H A D | ipc_channel_handle.h | 27 // type that knows how to copy a socket endpoint over IPC. 48 : name(n), socket(s) {} 53 base::FileDescriptor socket; member in struct:IPC::ChannelHandle
|
/external/chromium_org/media/cast/test/utility/ |
H A D | netload.py | 9 import socket namespace 17 def Sink(socket): 20 tmp = socket.recv(4096) 25 def Spew(socket): 29 tmp = socket.send(data) 53 def Serve(socket, upload=True, download=True): 55 (s, addr) = socket.accept() 62 s = socket.socket(socket [all...] |
/external/chromium_org/mojo/services/network/ |
H A D | network_service_impl.cc | 32 void NetworkServiceImpl::CreateWebSocket(InterfaceRequest<WebSocket> socket) { argument 33 BindToRequest(new WebSocketImpl(context_), &socket);
|
/external/chromium_org/net/socket/ |
H A D | websocket_endpoint_lock_manager.h | 16 #include "net/socket/websocket_transport_client_socket_pool.h" 40 // Records the IPEndPoint associated with a particular socket. This is 43 // UnlockSocket() or UnlockEndpoint() is called. The |socket| pointer must not 46 void RememberSocket(StreamSocket* socket, const IPEndPoint& endpoint); 48 // Releases the lock on the endpoint that was associated with |socket| by 49 // RememberSocket(). If appropriate, triggers the next socket connection. 50 // Should be called exactly once for each |socket| that was passed to 53 void UnlockSocket(StreamSocket* socket); 56 // Removes any socket association that was recorded with RememberSocket(). If 88 StreamSocket* socket; member in struct:net::WebSocketEndpointLockManager::LockInfo [all...] |
/external/chromium_org/net/test/embedded_test_server/ |
H A D | http_connection.cc | 7 #include "net/socket/stream_listen_socket.h" 13 HttpConnection::HttpConnection(scoped_ptr<StreamListenSocket> socket, argument 15 : socket_(socket.Pass()),
|
/external/chromium_org/net/third_party/nss/ssl/ |
H A D | authcert.c | 27 PRFileDesc * socket, 38 proto_win = SSL_RevealPinArg(socket); 26 NSS_GetClientAuthData(void * arg, PRFileDesc * socket, struct CERTDistNamesStr * caNames, struct CERTCertificateStr ** pRetCert, struct SECKEYPrivateKeyStr **pRetKey) argument
|
H A D | sslreveal.c | 13 /* given PRFileDesc, returns a copy of certificate associated with the socket 33 /* given PRFileDesc, returns a pointer to PinArg associated with the socket 51 /* given PRFileDesc, returns a pointer to the URL associated with the socket 74 SSL_HandshakeNegotiatedExtension(PRFileDesc * socket, argument 86 sslsocket = ssl_FindSocket(socket); 88 SSL_DBG(("%d: SSL[%d]: bad socket in HandshakeNegotiatedExtension", 89 SSL_GETPID(), socket)); 98 /* now we know this socket went through ssl3_InitState() and
|
/external/chromium_org/ppapi/tests/ |
H A D | test_tcp_server_socket_private_disallowed.cc | 53 PP_Resource socket = local 55 ASSERT_TRUE(socket != 0); 56 ASSERT_TRUE(tcp_server_socket_private_interface_->IsTCPServerSocket(socket)); 64 socket,
|
/external/chromium_org/remoting/base/ |
H A D | socket_reader.cc | 13 #include "net/socket/socket.h" 29 void SocketReader::Init(net::Socket* socket, argument 31 DCHECK(socket); 34 socket_ = socket;
|
/external/chromium_org/remoting/protocol/ |
H A D | channel_dispatcher_base.cc | 8 #include "net/socket/stream_socket.h" 52 scoped_ptr<net::StreamSocket> socket) { 53 if (!socket.get()) { 59 channel_ = socket.Pass(); 51 OnChannelReady( scoped_ptr<net::StreamSocket> socket) argument
|
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/mod_pywebsocket/ |
H A D | _stream_base.py | 42 import socket namespace 121 except socket.error, e: 122 # Catch a socket.error. Because it's not a child class of the 127 'Receiving %d byte failed. socket.error (%s) occurred' %
|
/external/chromium_org/third_party/libevent/sample/ |
H A D | event-test.c | 74 HANDLE socket; local 76 socket = CreateFile("test.txt", // open File 84 if(socket == INVALID_HANDLE_VALUE) 90 int socket; 108 socket = open (fifo, O_RDWR | O_NONBLOCK, 0); 110 socket = open (fifo, O_RDONLY | O_NONBLOCK, 0); 113 if (socket == -1) { 125 event_set(&evfifo, (int)socket, EV_READ, fifo_read, &evfifo); 127 event_set(&evfifo, socket, EV_READ, fifo_read, &evfifo); 135 CloseHandle(socket); [all...] |
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
H A D | xmpppump.cc | 41 buzz::AsyncSocket* socket, 46 client_->Connect(xcs, "", socket, auth); 40 DoLogin(const buzz::XmppClientSettings & xcs, buzz::AsyncSocket* socket, buzz::PreXmppAuth* auth) argument
|
/external/chromium_org/third_party/libsrtp/srtp/include/ |
H A D | rtp_priv.h | 61 int socket; member in struct:rtp_sender_ctx_t 68 int socket; member in struct:rtp_receiver_ctx_t
|
/external/chromium_org/tools/gyp/pylib/gyp/ |
H A D | MSVSUserFile.py | 9 import socket # for gethostname namespace 103 'RemoteMachine': socket.gethostname(),
|
/external/chromium_org/tools/site_compare/utils/ |
H A D | browser_iterate.py | 23 import socket namespace 83 """Invoke the browser process and connect to the socket.""" 88 # Try to connect the socket. If it fails, wait and try 90 s = socket.socket(socket.AF_INET, socket.SOCK_STREAM, socket.IPPROTO_TCP) 95 except socket.error: 102 except socket [all...] |
/external/chromium_org/tools/telemetry/telemetry/core/backends/chrome/ |
H A D | inspector_websocket.py | 7 import socket namespace 122 except (socket.error, websocket.WebSocketException):
|