/external/chromium_org/tools/android/forwarder2/ |
H A D | command.cc | 16 #include "tools/android/forwarder2/socket.h" 43 bool ReadCommand(Socket* socket, argument 50 int bytes_read = socket->ReadNumBytes(command_buffer, kCommandStringSize); 57 LOG(ERROR) << "Read() error, not enough data received from the socket."; 80 bool SendCommand(command::Type command, int port, Socket* socket) { argument 85 return socket->WriteNumBytes(buffer, len) == len; 88 bool ReceivedCommand(command::Type command, Socket* socket) { argument 91 if (!ReadCommand(socket, &port, &received_command))
|
/external/chromium_org/jingle/glue/ |
H A D | proxy_resolving_client_socket.cc | 18 #include "net/socket/client_socket_handle.h" 19 #include "net/socket/client_socket_pool_manager.h" 39 // Assume that we intend to do TLS on this socket; all 104 if (transport_.get() && transport_->socket()) 105 return transport_->socket()->Read(buf, buf_len, callback); 114 if (transport_.get() && transport_->socket()) 115 return transport_->socket()->Write(buf, buf_len, callback); 121 if (transport_.get() && transport_->socket()) 122 return transport_->socket()->SetReceiveBufferSize(size); 128 if (transport_.get() && transport_->socket()) [all...] |
/external/chromium_org/remoting/host/ |
H A D | gnubby_auth_handler_posix_unittest.cc | 8 #include "net/socket/stream_listen_socket.h" 104 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local 106 delegate_->DidAccept(NULL, make_scoped_ptr(socket)); 107 ASSERT_TRUE(auth_handler_posix_->HasActiveSocketForTesting(socket)); 109 delegate_->DidClose(socket); 110 ASSERT_FALSE(auth_handler_posix_->HasActiveSocketForTesting(socket)); 116 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local 118 delegate_->DidAccept(NULL, make_scoped_ptr(socket)); 119 delegate_->DidRead(socket, 127 net::StreamListenSocket* socket local 137 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local 152 net::StreamListenSocket* socket = new MockStreamListenSocket(delegate_); local [all...] |
/external/chromium_org/third_party/usrsctp/usrsctplib/ |
H A D | user_socketvar.h | 98 * Kernel structure per socket. 115 * Locking key to struct socket: 125 struct socket { struct 127 short so_type; /* (a) generic type, see socket.h */ 128 short so_options; /* from socket call, see socket.h */ 137 * If so_head is 0, socket is not related to an accept. 138 * For head socket so_incomp queues partially completed connections, 143 * and limit on number of queued connections for this socket. 145 struct socket *so_hea [all...] |
/external/chromium_org/net/dns/ |
H A D | dns_socket_pool.cc | 14 #include "net/socket/client_socket_factory.h" 15 #include "net/socket/stream_socket.h" 23 // When we allocate a socket, we ensure we have at least kAllocateMinSize 73 scoped_ptr<DatagramClientSocket> socket; local 76 socket = socket_factory_->CreateDatagramClientSocket( 79 if (socket.get()) { 80 int rv = socket->Connect((*nameservers_)[server_index]); 82 VLOG(1) << "Failed to connect socket: " << rv; 83 socket.reset(); 86 LOG(WARNING) << "Failed to create socket 197 DatagramClientSocket* socket = pool[socket_index]; local 204 FreeSocket( unsigned server_index, scoped_ptr<DatagramClientSocket> socket) argument 214 DatagramClientSocket* socket = local [all...] |
/external/chromium_org/content/browser/renderer_host/ |
H A D | socket_stream_dispatcher_host.h | 50 virtual void OnConnected(net::SocketStream* socket, 52 virtual void OnSentData(net::SocketStream* socket, int amount_sent) OVERRIDE; 53 virtual void OnReceivedData(net::SocketStream* socket, 55 virtual void OnClose(net::SocketStream* socket) OVERRIDE; 56 virtual void OnError(const net::SocketStream* socket, int error) OVERRIDE; 57 virtual void OnSSLCertificateError(net::SocketStream* socket, 60 virtual bool CanGetCookies(net::SocketStream* socket,
|
/external/chromium_org/remoting/protocol/ |
H A D | secure_channel_factory.cc | 8 #include "net/socket/stream_socket.h" 52 scoped_ptr<net::StreamSocket> socket) { 53 if (!socket) { 62 socket.Pass(), 71 scoped_ptr<net::StreamSocket> socket) { 72 DCHECK((socket && error == net::OK) || (!socket && error != net::OK)); 79 callback.Run(socket.Pass()); 49 OnBaseChannelCreated( const std::string& name, const ChannelCreatedCallback& callback, scoped_ptr<net::StreamSocket> socket) argument 67 OnSecureChannelCreated( const std::string& name, const ChannelCreatedCallback& callback, int error, scoped_ptr<net::StreamSocket> socket) argument
|
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/webrtc/base/ |
H A D | testechoserver.h | 43 void OnAccept(AsyncSocket* socket) { argument 44 AsyncSocket* raw_socket = socket->Accept(NULL); 52 void OnPacket(AsyncPacketSocket* socket, const char* buf, size_t size, argument 56 socket->Send(buf, size, options); 58 void OnClose(AsyncPacketSocket* socket, int err) { argument 60 std::find(client_sockets_.begin(), client_sockets_.end(), socket); 62 Thread::Current()->Dispose(socket);
|
H A D | asynctcpsocket.cc | 34 // Binds and connects |socket| 36 rtc::AsyncSocket* socket, 39 rtc::scoped_ptr<rtc::AsyncSocket> owned_socket(socket); 40 if (socket->Bind(bind_address) < 0) { 41 LOG(LS_ERROR) << "Bind() failed with error " << socket->GetError(); 44 if (socket->Connect(remote_address) < 0) { 45 LOG(LS_ERROR) << "Connect() failed with error " << socket->GetError(); 51 AsyncTCPSocketBase::AsyncTCPSocketBase(AsyncSocket* socket, bool listen, argument 53 : socket_(socket), 173 void AsyncTCPSocketBase::OnConnectEvent(AsyncSocket* socket) { argument 35 ConnectSocket( rtc::AsyncSocket* socket, const rtc::SocketAddress& bind_address, const rtc::SocketAddress& remote_address) argument 177 OnReadEvent(AsyncSocket* socket) argument 216 OnWriteEvent(AsyncSocket* socket) argument 228 OnCloseEvent(AsyncSocket* socket, int error) argument 236 Create( AsyncSocket* socket, const SocketAddress& bind_address, const SocketAddress& remote_address) argument 244 AsyncTCPSocket(AsyncSocket* socket, bool listen) argument 295 HandleIncomingConnection(AsyncSocket* socket) argument [all...] |
H A D | sslsocketfactory.cc | 23 // the socket adapter is the more appropriate idiom for automatic proxy 125 AsyncSocket* socket = factory_->CreateAsyncSocket(family, type); local 126 if (!socket) 131 socket = new LoggingSocketAdapter(socket, logging_level_, 138 proxy_socket = new AsyncSocksProxySocket(socket, proxy.address, 143 new AsyncHttpsProxySocket(socket, agent_, proxy.address, 149 delete socket; 152 socket = proxy_socket; // for our purposes the proxy is now the socket [all...] |
H A D | openssladapter.h | 31 OpenSSLAdapter(AsyncSocket* socket); 39 // Note that the socket returns ST_CONNECTING while SSL is being negotiated. 43 virtual void OnConnectEvent(AsyncSocket* socket); 44 virtual void OnReadEvent(AsyncSocket* socket); 45 virtual void OnWriteEvent(AsyncSocket* socket); 46 virtual void OnCloseEvent(AsyncSocket* socket, int err); 74 // If true, socket will retain SSL configuration after Close.
|
H A D | schanneladapter.h | 25 SChannelAdapter(AsyncSocket* socket); 33 // Note that the socket returns ST_CONNECTING while SSL is being negotiated. 42 virtual void OnConnectEvent(AsyncSocket* socket); 43 virtual void OnReadEvent(AsyncSocket* socket); 44 virtual void OnWriteEvent(AsyncSocket* socket); 45 virtual void OnCloseEvent(AsyncSocket* socket, int err); 64 // If true, socket will retain SSL configuration after Close.
|
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/v8/tools/testrunner/server/ |
H A D | presence_handler.py | 29 import socket namespace 47 s = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 104 sock = socket.socket(socket.AF_INET, socket.SOCK_DGRAM) 109 sock = socket [all...] |
/external/chromium_org/chrome/browser/devtools/device/usb/ |
H A D | usb_device_provider.cc | 13 #include "net/socket/stream_socket.h" 24 scoped_ptr<net::StreamSocket> socket(socket_raw); 26 socket.reset(); 27 callback.Run(result, socket.Pass()); 30 void OnRead(net::StreamSocket* socket, argument 37 delete socket; 43 socket->Read(buffer.get(), 45 base::Bind(&OnRead, socket, buffer, new_data, callback)); 47 OnRead(socket, buffer, new_data, callback, result); 51 net::StreamSocket* socket, 50 OpenedForCommand(const UsbDeviceProvider::CommandCallback& callback, net::StreamSocket* socket, int result) argument 69 net::StreamSocket* socket = device->CreateSocket(command); local 120 net::StreamSocket* socket = it->second->CreateSocket(socket_name); local [all...] |
/external/chromium_org/ppapi/tests/ |
H A D | test_host_resolver_private.h | 31 std::string SyncConnect(pp::TCPSocketPrivate* socket, 34 std::string SyncConnect(pp::TCPSocketPrivate* socket, 36 std::string SyncRead(pp::TCPSocketPrivate* socket, 40 std::string SyncWrite(pp::TCPSocketPrivate* socket, 44 std::string CheckHTTPResponse(pp::TCPSocketPrivate* socket,
|
H A D | test_tcp_server_socket_private.h | 33 std::string SyncRead(pp::TCPSocketPrivate* socket, 36 std::string SyncWrite(pp::TCPSocketPrivate* socket, 39 std::string SyncConnect(pp::TCPSocketPrivate* socket, 41 void ForceConnect(pp::TCPSocketPrivate* socket, 43 std::string SyncListen(pp::TCPServerSocketPrivate* socket,
|
H A D | test_udp_socket_private.h | 24 std::string SetBroadcastOptions(pp::UDPSocketPrivate* socket); 25 std::string BindUDPSocket(pp::UDPSocketPrivate* socket, 27 std::string LookupPortAndBindUDPSocket(pp::UDPSocketPrivate* socket, 29 std::string BindUDPSocketFailure(pp::UDPSocketPrivate* socket, 31 std::string ReadSocket(pp::UDPSocketPrivate* socket,
|
H A D | test_host_resolver_private.cc | 49 std::string TestHostResolverPrivate::SyncConnect(pp::TCPSocketPrivate* socket, argument 54 socket->Connect(host.c_str(), port, callback.GetCallback())); 61 pp::TCPSocketPrivate* socket, 65 socket->ConnectWithNetAddress(&address, callback.GetCallback())); 71 std::string TestHostResolverPrivate::SyncRead(pp::TCPSocketPrivate* socket, argument 77 socket->Read(buffer, num_bytes, callback.GetCallback())); 84 std::string TestHostResolverPrivate::SyncWrite(pp::TCPSocketPrivate* socket, argument 90 socket->Write(buffer, num_bytes, callback.GetCallback())); 98 pp::TCPSocketPrivate* socket, 103 SyncWrite(socket, reques 60 SyncConnect( pp::TCPSocketPrivate* socket, const PP_NetAddress_Private& address) argument 97 CheckHTTPResponse( pp::TCPSocketPrivate* socket, const std::string& request, const std::string& response) argument [all...] |
H A D | test_tcp_socket_private_disallowed.cc | 38 PP_Resource socket = local 40 if (0 != socket) { 43 socket, kServerName, kPort,
|
H A D | test_udp_socket_private_disallowed.cc | 32 PP_Resource socket = local 34 if (0 != socket) { 39 callback.WaitForResult(udp_socket_private_interface_->Bind(socket, &addr,
|
/external/okhttp/okhttp/src/main/java/com/squareup/okhttp/ |
H A D | Connection.java | 70 private Socket socket; field in class:Connection 138 socket.close(); 146 socket = route.address.socketFactory.createSocket(); 148 socket = new Socket(route.proxy); 151 socket.setSoTimeout(readTimeout); 152 Platform.get().connectSocket(socket, route.inetSocketAddress, connectTimeout); 157 httpConnection = new HttpConnection(pool, this, socket); 174 // Create the wrapper over connected socket. 175 socket = route.address.sslSocketFactory 176 .createSocket(socket, rout [all...] |
/external/chromium_org/extensions/browser/api/bluetooth_socket/ |
H A D | bluetooth_socket_api.cc | 39 BluetoothApiSocket* socket) { 42 // This represents what we know about the socket, and does not call through 45 if (socket->name()) { 46 socket_info->name.reset(new std::string(*socket->name())); 48 socket_info->persistent = socket->persistent(); 49 if (socket->buffer_size() > 0) { 50 socket_info->buffer_size.reset(new int(socket->buffer_size())); 52 socket_info->paused = socket->paused(); 53 socket_info->connected = socket->IsConnected(); 55 if (socket 38 CreateSocketInfo(int socket_id, BluetoothApiSocket* socket) argument 62 SetSocketProperties(BluetoothApiSocket* socket, SocketProperties* properties) argument 159 AddSocket(BluetoothApiSocket* socket) argument 196 BluetoothApiSocket* socket = new BluetoothApiSocket(extension_id()); local 221 BluetoothApiSocket* socket = GetSocket(params_->socket_id); local 245 BluetoothApiSocket* socket = GetSocket(params_->socket_id); local 283 BluetoothApiSocket* socket = GetSocket(socket_id()); local 317 OnCreateService( scoped_refptr<device::BluetoothSocket> socket) argument 463 BluetoothApiSocket* socket = GetSocket(params_->socket_id); local 494 OnConnect( scoped_refptr<device::BluetoothSocket> socket) argument 551 BluetoothApiSocket* socket = GetSocket(params_->socket_id); local 579 BluetoothApiSocket* socket = GetSocket(params_->socket_id); local 606 BluetoothApiSocket* socket = GetSocket(params_->socket_id); local 643 BluetoothApiSocket* socket = GetSocket(params_->socket_id); local 668 BluetoothApiSocket* socket = GetSocket(socket_id); local [all...] |
/external/chromium_org/net/socket/ |
H A D | socks_client_socket.cc | 5 #include "net/socket/socks_client_socket.h" 15 #include "net/socket/client_socket_handle.h" 73 net_log_(transport_->socket()->NetLog()) {} 81 DCHECK(transport_->socket()); 105 transport_->socket()->Disconnect(); 114 return completed_handshake_ && transport_->socket()->IsConnected(); 118 return completed_handshake_ && transport_->socket()->IsConnectedAndIdle(); 126 if (transport_.get() && transport_->socket()) { 127 transport_->socket()->SetSubresourceSpeculation(); 134 if (transport_.get() && transport_->socket()) { [all...] |