/external/chromium_org/extensions/browser/api/bluetooth_socket/ |
H A D | bluetooth_socket_event_dispatcher.cc | 28 // kNotConnected is impossible since a socket has to be connected to be 46 // kNotListening is impossible since a socket has to be listening to be 87 << "There is no socket manager. " 142 BluetoothApiSocket* socket = local 144 if (!socket) { 145 // This can happen if the socket is closed while our callback is active. 149 if (socket->IsConnected()) { 160 BluetoothApiSocket* socket = local 162 if (!socket) { 163 // This can happen if the socket i 237 BluetoothApiSocket* socket = local 248 BluetoothApiSocket* socket = local 269 AcceptCallback( const SocketParams& params, const device::BluetoothDevice* device, scoped_refptr<device::BluetoothSocket> socket) argument 332 BluetoothApiSocket* socket = local [all...] |
/external/chromium_org/extensions/browser/api/cast_channel/ |
H A D | cast_transport.cc | 28 CastTransport::CastTransport(CastSocketInterface* socket, argument 31 : socket_(socket), 36 DCHECK(socket);
|
/external/chromium_org/extensions/browser/api/socket/ |
H A D | tls_socket.cc | 5 #include "extensions/browser/api/socket/tls_socket.h" 14 #include "net/socket/client_socket_factory.h" 15 #include "net/socket/client_socket_handle.h" 16 #include "net/socket/ssl_client_socket.h" 17 #include "net/socket/tcp_client_socket.h" 44 // No matter how the TLS connection attempt went, the underlying socket's 46 // which is promoted here to a new API-accessible socket (via a TLSSocket 53 // Wrap the StreamSocket in a TLSSocket, which matches the extension socket 54 // API. Set the handle of the socket to the new value, so that it can be 69 "Cannot listen on a socket tha 179 UpgradeSocketToTLS( Socket* socket, scoped_refptr<net::SSLConfigService> ssl_config_service, net::CertVerifier* cert_verifier, net::TransportSecurityState* transport_security_state, const std::string& extension_id, core_api::socket::SecureOptions* options, const TLSSocket::SecureCallback& callback) argument [all...] |
/external/chromium_org/extensions/browser/api/sockets_tcp_server/ |
H A D | sockets_tcp_server_api.cc | 8 #include "extensions/browser/api/socket/tcp_socket.h" 27 ResumableTCPServerSocket* socket) { 29 // This represents what we know about the socket, and does not call through 32 if (!socket->name().empty()) { 33 socket_info->name.reset(new std::string(socket->name())); 35 socket_info->persistent = socket->persistent(); 36 socket_info->paused = socket->paused(); 40 if (socket->GetLocalAddress(&localAddress)) { 49 void SetSocketProperties(ResumableTCPServerSocket* socket, argument 52 socket 26 CreateSocketInfo(int socket_id, ResumableTCPServerSocket* socket) argument 88 ResumableTCPServerSocket* socket = local 113 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 143 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 180 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 221 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 242 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 263 ResumableTCPServerSocket* socket = GetTcpSocket(params_->socket_id); local 288 ResumableTCPServerSocket* socket = GetTcpSocket(socket_id); local [all...] |
/external/chromium_org/google_apis/gcm/base/ |
H A D | socket_stream_unittest.cc | 13 #include "net/socket/socket_test_util.h" 34 // Build a socket with the expected reads and writes. 52 net::StreamSocket* socket() { return socket_.get(); } function in class:gcm::__anon8366::GCMSocketStreamTest 302 socket()->Disconnect(); 399 socket()->Disconnect();
|
/external/chromium_org/google_apis/gcm/engine/ |
H A D | connection_handler_impl.cc | 13 #include "net/socket/stream_socket.h" 27 // But, the protocol only allows for 4KiB payloads, and the socket stream buffer 30 // because the socket stream buffer overflowed or too many bytes were required 61 net::StreamSocket* socket) { 72 socket_ = socket; 151 // If the socket stream had an error, plumb it up, else plumb up FAILED. 185 // If the socket stream had an error, plumb it up, else plumb up FAILED. 238 // If the socket stream had an error, plumb it up, else plumb up FAILED. 59 Init( const mcs_proto::LoginRequest& login_request, net::StreamSocket* socket) argument
|
/external/chromium_org/jingle/glue/ |
H A D | pseudotcp_adapter.cc | 28 Core(net::Socket* socket); 113 PseudoTcpAdapter::Core::Core(net::Socket* socket) argument 115 socket_(socket), 359 // Our underlying socket is datagram-oriented, which means it should either 464 PseudoTcpAdapter::PseudoTcpAdapter(net::Socket* socket) argument 465 : core_(new Core(socket)) { 471 // Make sure that the underlying socket is destroyed before PseudoTcp.
|
/external/chromium_org/net/dns/ |
H A D | dns_session.cc | 19 #include "net/socket/stream_socket.h" 74 scoped_ptr<DatagramClientSocket> socket) 75 : session_(session), server_index_(server_index), socket_(socket.Pass()) {} 220 // Allocate a socket, already connected to the server address. 223 scoped_ptr<DatagramClientSocket> socket; local 225 socket = socket_pool_->AllocateSocket(server_index); 226 if (!socket.get()) 229 socket->NetLog().BeginEvent(NetLog::TYPE_SOCKET_IN_USE, 232 SocketLease* lease = new SocketLease(this, server_index, socket.Pass()); 241 // Release a socket 72 SocketLease(scoped_refptr<DnsSession> session, unsigned server_index, scoped_ptr<DatagramClientSocket> socket) argument 242 FreeSocket(unsigned server_index, scoped_ptr<DatagramClientSocket> socket) argument [all...] |
/external/chromium_org/net/socket/ |
H A D | client_socket_handle.h | 22 #include "net/socket/client_socket_pool.h" 23 #include "net/socket/stream_socket.h" 31 // client socket objects. 36 UNUSED = 0, // unused socket that just finished connecting 37 UNUSED_IDLE, // unused socket that has been idle for awhile 38 REUSED_IDLE, // previously used socket 46 // ClientSocketPool to obtain a connected socket, possibly reusing one. This 50 // If this method succeeds, then the socket member will be set to an existing 51 // connected socket if an existing connected socket wa 155 StreamSocket* socket() { return socket_.get(); } function in class:net::ClientSocketHandle [all...] |
H A D | socket_libevent.cc | 5 #include "net/socket/socket_libevent.h" 9 #include <sys/socket.h> 92 int SocketLibevent::AdoptConnectedSocket(SocketDescriptor socket, argument 97 socket_fd_ = socket; 143 int SocketLibevent::Accept(scoped_ptr<SocketLibevent>* socket, argument 148 DCHECK(socket); 151 int rv = DoAccept(socket); 162 accept_socket_ = socket; 363 int SocketLibevent::DoAccept(scoped_ptr<SocketLibevent>* socket) { argument 376 *socket [all...] |
/external/chromium_org/net/test/embedded_test_server/ |
H A D | embedded_test_server.cc | 312 StreamListenSocket* socket) { 316 connections_.find(socket); 311 FindConnection( StreamListenSocket* socket) argument
|
/external/chromium_org/net/tools/testserver/ |
H A D | testserver_base.py | 11 import socket namespace 79 if isinstance(value, socket.error): 104 self.socket.close()
|
/external/chromium_org/ppapi/tests/ |
H A D | test_tcp_socket.cc | 70 pp::TCPSocket socket(instance_); 73 cb.WaitForResult(socket.Connect(addr_, cb.GetCallback())); 78 local_addr = socket.GetLocalAddress(); 79 remote_addr = socket.GetRemoteAddress(); 85 socket.Close(); 89 // Connect a bound socket. 90 pp::TCPSocket socket(instance_); 96 cb.WaitForResult(socket.Bind(any_port_address, cb.GetCallback())); 100 cb.WaitForResult(socket.Connect(addr_, cb.GetCallback())); 105 local_addr = socket 317 PP_Resource socket = socket_interface_1_0_->Create(instance_->pp_instance()); local 337 ReadFirstLineFromSocket(pp::TCPSocket* socket, std::string* s) argument 358 ReadFirstLineFromSocket_1_0(PP_Resource socket, std::string* s) argument 381 ReadFromSocket(pp::TCPSocket* socket, char* buffer, size_t num_bytes) argument 397 WriteToSocket(pp::TCPSocket* socket, const std::string& s) argument 413 WriteToSocket_1_0( PP_Resource socket, const std::string& s) argument 444 StartListen(pp::TCPSocket* socket, int32_t backlog) argument [all...] |
H A D | test_udp_socket.cc | 89 pp::TCPSocket socket(instance_); 91 callback.WaitForResult(socket.Connect(address_, callback.GetCallback())); 94 *address = socket.GetLocalAddress(); 96 socket.Close(); 100 std::string TestUDPSocket::SetBroadcastOptions(pp::UDPSocket* socket) { argument 102 callback_1.WaitForResult(socket->SetOption( 109 callback_2.WaitForResult(socket->SetOption( 117 std::string TestUDPSocket::BindUDPSocket(pp::UDPSocket* socket, argument 120 callback.WaitForResult(socket->Bind(address, callback.GetCallback())); 127 pp::UDPSocket* socket, 126 LookupPortAndBindUDPSocket( pp::UDPSocket* socket, pp::NetAddress* address) argument 150 ReadSocket(pp::UDPSocket* socket, pp::NetAddress* address, size_t size, std::string* message) argument [all...] |
H A D | test_udp_socket_private.cc | 65 pp::TCPSocketPrivate socket(instance_); 68 socket.Connect(host_.c_str(), port_, callback.GetCallback())); 71 ASSERT_TRUE(socket.GetLocalAddress(address)); 72 socket.Disconnect(); 77 pp::UDPSocketPrivate* socket) { 78 int32_t rv = socket->SetSocketFeature( 83 rv = socket->SetSocketFeature(PP_UDPSOCKETFEATURE_PRIVATE_BROADCAST, 92 pp::UDPSocketPrivate* socket, 95 callback.WaitForResult(socket->Bind(address, callback.GetCallback())); 102 pp::UDPSocketPrivate* socket, 76 SetBroadcastOptions( pp::UDPSocketPrivate* socket) argument 91 BindUDPSocket( pp::UDPSocketPrivate* socket, PP_NetAddress_Private* address) argument 101 LookupPortAndBindUDPSocket( pp::UDPSocketPrivate* socket, PP_NetAddress_Private *address) argument 123 BindUDPSocketFailure( pp::UDPSocketPrivate* socket, PP_NetAddress_Private *address) argument 134 ReadSocket(pp::UDPSocketPrivate* socket, PP_NetAddress_Private* address, size_t size, std::string* message) argument [all...] |
/external/chromium_org/remoting/host/ |
H A D | gnubby_auth_handler_posix.cc | 17 #include "net/socket/unix_domain_listen_socket_posix.h" 37 // The name of the socket to listen for gnubby requests on. 44 explicit CompareSocket(net::StreamListenSocket* socket) : socket_(socket) {} argument 59 HOST_LOG << "Refused socket connection from uid " << credentials.user_id; 190 net::StreamListenSocket* socket) const { 193 CompareSocket(socket)) != active_sockets_.end(); 197 net::StreamListenSocket* socket) const { 199 active_sockets_.begin(), active_sockets_.end(), CompareSocket(socket)); 204 net::StreamListenSocket* socket) cons 210 DidAccept( net::StreamListenSocket* server, scoped_ptr<net::StreamListenSocket> socket) argument 223 DidRead(net::StreamListenSocket* socket, const char* data, int len) argument 245 DidClose(net::StreamListenSocket* socket) argument [all...] |
/external/chromium_org/remoting/protocol/ |
H A D | channel_multiplexer_unittest.cc | 11 #include "net/socket/socket.h" 12 #include "net/socket/stream_socket.h" 48 MOCK_METHOD1(OnConnectedPtr, void(net::StreamSocket* socket)); 49 void OnConnected(scoped_ptr<net::StreamSocket> socket) { argument 50 OnConnectedPtr(socket.release()); 116 scoped_ptr<net::StreamSocket> socket) { 117 *storage = socket.Pass(); 113 OnChannelConnected( scoped_ptr<net::StreamSocket>* storage, int* counter, scoped_ptr<net::StreamSocket> socket) argument
|
H A D | fake_authenticator.cc | 11 #include "net/socket/stream_socket.h" 31 scoped_ptr<net::StreamSocket> socket, 33 socket_ = socket.Pass(); 30 SecureAndAuthenticate( scoped_ptr<net::StreamSocket> socket, const DoneCallback& done_callback) argument
|
H A D | jingle_session_unittest.cc | 13 #include "net/socket/socket.h" 14 #include "net/socket/stream_socket.h" 90 MOCK_METHOD1(OnDone, void(net::StreamSocket* socket)); 115 void OnClientChannelCreated(scoped_ptr<net::StreamSocket> socket) { argument 116 client_channel_callback_.OnDone(socket.get()); 117 client_socket_ = socket.Pass(); 120 void OnHostChannelCreated(scoped_ptr<net::StreamSocket> socket) { argument 121 host_channel_callback_.OnDone(socket.get()); 122 host_socket_ = socket [all...] |
/external/chromium_org/remoting/signaling/ |
H A D | xmpp_signal_strategy.cc | 18 #include "net/socket/client_socket_factory.h" 94 buzz::AsyncSocket* socket = new jingle_glue::ChromeAsyncSocket( local 100 settings, std::string(), socket, CreatePreXmppAuth(settings));
|
/external/chromium_org/sync/tools/testserver/ |
H A D | sync_testserver.py | 18 import socket namespace 58 except socket.error:
|
H A D | xmppserver.py | 15 import socket namespace 368 socket). It does the XMPP handshake and also implements the (old) 381 sock: The socket to the client. 392 # it does, and that calling dispatcher.__init__ with socket=None 517 self.create_socket(socket.AF_INET, socket.SOCK_STREAM)
|
/external/chromium_org/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_org/third_party/WebKit/Tools/Scripts/webkitpy/performance_tests/ |
H A D | perftest.py | 37 import socket namespace
|
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/coverage/ |
H A D | control.py | 3 import atexit, os, random, socket, sys namespace 165 for m in (atexit, os, random, socket): 190 self.socket = socket 455 self.socket.gethostname(), self.os.getpid(),
|