Searched refs:socket (Results 76 - 100 of 1466) sorted by relevance

1234567891011>>

/external/chromium_org/tools/android/forwarder2/
H A Dcommand.cc16 #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 Dproxy_resolving_client_socket.cc18 #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 Dgnubby_auth_handler_posix_unittest.cc8 #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 Duser_socketvar.h98 * 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 Ddns_socket_pool.cc14 #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 Dsocket_stream_dispatcher_host.h50 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 Dsecure_channel_factory.cc8 #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 Dchannel_dispatcher_base.cc8 #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 Dtestechoserver.h43 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 Dasynctcpsocket.cc34 // 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 Dsslsocketfactory.cc23 // 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 Dopenssladapter.h31 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 Dschanneladapter.h25 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 Dtestclient_unittest.cc23 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 Dpresence_handler.py29 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 Dusb_device_provider.cc13 #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 Dtest_host_resolver_private.h31 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 Dtest_tcp_server_socket_private.h33 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 Dtest_udp_socket_private.h24 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 Dtest_host_resolver_private.cc49 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 Dtest_tcp_socket_private_disallowed.cc38 PP_Resource socket = local
40 if (0 != socket) {
43 socket, kServerName, kPort,
H A Dtest_udp_socket_private_disallowed.cc32 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 DConnection.java70 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 Dbluetooth_socket_api.cc39 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 Dsocks_client_socket.cc5 #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...]

Completed in 340 milliseconds

1234567891011>>