Searched defs:socket (Results 201 - 225 of 430) sorted by relevance

1234567891011>>

/external/chromium_org/extensions/browser/api/bluetooth_socket/
H A Dbluetooth_socket_event_dispatcher.cc28 // 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 Dcast_transport.cc28 CastTransport::CastTransport(CastSocketInterface* socket, argument
31 : socket_(socket),
36 DCHECK(socket);
/external/chromium_org/extensions/browser/api/socket/
H A Dtls_socket.cc5 #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 Dsockets_tcp_server_api.cc8 #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 Dsocket_stream_unittest.cc13 #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 Dconnection_handler_impl.cc13 #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 Dpseudotcp_adapter.cc28 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 Ddns_session.cc19 #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 Dclient_socket_handle.h22 #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 Dsocket_libevent.cc5 #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 Dembedded_test_server.cc312 StreamListenSocket* socket) {
316 connections_.find(socket);
311 FindConnection( StreamListenSocket* socket) argument
/external/chromium_org/net/tools/testserver/
H A Dtestserver_base.py11 import socket namespace
79 if isinstance(value, socket.error):
104 self.socket.close()
/external/chromium_org/ppapi/tests/
H A Dtest_tcp_socket.cc70 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 Dtest_udp_socket.cc89 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 Dtest_udp_socket_private.cc65 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 Dgnubby_auth_handler_posix.cc17 #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 Dchannel_multiplexer_unittest.cc11 #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 Dfake_authenticator.cc11 #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 Djingle_session_unittest.cc13 #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 Dxmpp_signal_strategy.cc18 #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 Dsync_testserver.py18 import socket namespace
58 except socket.error:
H A Dxmppserver.py15 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 Dupload.py42 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 Dperftest.py37 import socket namespace
/external/chromium_org/third_party/WebKit/Tools/Scripts/webkitpy/thirdparty/coverage/
H A Dcontrol.py3 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(),

Completed in 6319 milliseconds

1234567891011>>