| /external/chromium_org/content/browser/renderer_host/pepper/ |
| pepper_tcp_socket_message_filter.cc | 67 socket_(new net::TCPSocket(NULL, net::NetLog::Source())),
95 socket_(socket.Pass()),
110 if (socket_)
111 socket_->Close();
272 if (socket_->GetPeerAddress(&peer_address) != net::OK)
277 new net::TCPClientSocket(socket_.Pass(), peer_address)));
324 if (socket_) {
326 net_result = socket_->Read(
407 int net_result = socket_->Accept(
424 // Make sure we get no further callbacks from |socket_| or |ssl_socket_|
[all...] |
| pepper_tcp_server_socket_message_filter.cc | 135 int net_result = socket_->Accept(
151 socket_.reset();
172 socket_.reset(new net::TCPSocket(NULL, net::NetLog::Source()));
176 net_result = socket_->Open(ip_end_point.GetFamily());
179 net_result = socket_->SetDefaultOptionsForServer();
182 net_result = socket_->Bind(ip_end_point);
185 net_result = socket_->Listen(backlog);
206 DCHECK(socket_.get());
212 NetErrorToPepperError(socket_->GetLocalAddress(&end_point));
|
| pepper_tcp_socket.cc | 70 socket_(socket) {
75 // Make sure no further callbacks from socket_.
76 if (socket_)
77 socket_->Disconnect();
147 handle->SetSocket(socket_.Pass());
154 socket_ = factory->CreateSSLClientSocket(
156 if (!socket_) {
162 int net_result = socket_->Connect(
189 int net_result = socket_->Read(
234 static_cast<net::TCPClientSocket*>(socket_.get())
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/base/ |
| testutils.h | 298 socket_->Connect(address);
301 AsyncSocket* socket() { return socket_.get(); }
317 if (Socket::CS_CONNECTED == socket_->GetState()) {
328 return (Socket::CS_CONNECTED == socket_->GetState());
331 return (Socket::CS_CLOSED == socket_->GetState());
342 socket_.reset(socket);
343 socket_->SignalConnectEvent.connect(this,
345 socket_->SignalReadEvent.connect(this, &SocketTestClient::OnReadEvent);
346 socket_->SignalWriteEvent.connect(this, &SocketTestClient::OnWriteEvent);
347 socket_->SignalCloseEvent.connect(this, &SocketTestClient::OnCloseEvent)
386 scoped_ptr<AsyncSocket> socket_; member in class:testing::SocketTestClient
429 scoped_ptr<AsyncSocket> socket_; member in class:testing::SocketTestServer
[all...] |
| asyncudpsocket.h | 72 scoped_ptr<AsyncSocket> socket_; member in class:talk_base::AsyncUDPSocket
|
| /external/chromium_org/chrome/browser/devtools/ |
| adb_client_socket.cc | 78 callback_.Run(net::OK, socket_.release());
100 : socket_(socket),
109 : socket_(socket),
123 int result = socket_->Write(
137 result = socket_->Read(response_buffer.get(),
186 socket_callback_.Run(net::OK, socket_.release());
191 result = socket_->Read(response_buffer.get(),
212 scoped_ptr<net::StreamSocket> socket_; member in class:__anon4545::HttpOverAdbSocket
347 socket_.reset(new net::TCPClientSocket(address_list, NULL,
349 int result = socket_->Connect(callback)
[all...] |
| /external/chromium_org/remoting/client/plugin/ |
| pepper_packet_socket_factory.cc | 77 pp::UDPSocket socket_; member in class:remoting::__anon10109::UdpPacketSocket
111 socket_(instance),
128 if (socket_.is_null()) {
144 int result = socket_.Bind(pp_local_address, callback);
160 pp::NetAddress address = socket_.GetBoundAddress();
176 int result = socket_.Bind(pp_local_address, callback);
233 socket_.Close();
265 int result = socket_.SendTo(
316 socket_.RecvFrom(&receive_buffer_[0], receive_buffer_.size(), callback);
|
| /external/chromium/third_party/libjingle/source/talk/p2p/base/ |
| tcpport.h | 107 talk_base::AsyncPacketSocket* socket_; member in class:cricket::TCPPort
124 talk_base::AsyncPacketSocket* socket() { return socket_; }
133 talk_base::AsyncPacketSocket* socket_; member in class:cricket::TCPConnection
|
| stunserver.h | 72 talk_base::scoped_ptr<talk_base::AsyncUDPSocket> socket_; member in class:cricket::StunServer
|
| /external/chromium_org/chrome/renderer/media/ |
| cast_session_delegate.cc | 74 socket_ = socket_factory_->Create();
75 socket_->SetDelegate(this);
113 socket_->SendWithDscp(
|
| /external/chromium_org/chrome/test/chromedriver/net/ |
| adb_client_socket.cc | 79 callback_.Run(net::OK, socket_.release());
138 socket_.reset(socket);
143 result = socket_->Write(
158 result = socket_->Read(response_buffer.get(),
206 socket_callback_.Run(net::OK, socket_.release());
211 result = socket_->Read(response_buffer.get(),
232 scoped_ptr<net::StreamSocket> socket_; member in class:__anon7001::HttpOverAdbSocket
374 socket_.reset(new net::TCPClientSocket(address_list, NULL,
376 int result = socket_->Connect(callback);
386 int result = socket_->Write(request_buffer.get()
[all...] |
| /external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
| tcpport.h | 116 talk_base::AsyncPacketSocket* socket_; member in class:cricket::TCPPort
134 talk_base::AsyncPacketSocket* socket() { return socket_; }
145 talk_base::AsyncPacketSocket* socket_; member in class:cricket::TCPConnection
|
| stunserver.h | 73 talk_base::scoped_ptr<talk_base::AsyncUDPSocket> socket_; member in class:cricket::StunServer
|
| /external/chromium/net/socket/ |
| tcp_server_socket_win.h | 42 SOCKET socket_; member in class:net::TCPServerSocketWin
|
| /external/chromium/third_party/libjingle/source/talk/base/ |
| asyncudpsocket.h | 64 scoped_ptr<AsyncSocket> socket_; member in class:talk_base::AsyncUDPSocket
|
| autodetectproxy.h | 84 AsyncSocket* socket_; member in class:talk_base::AutoDetectProxy
|
| /external/chromium_org/base/ |
| async_socket_io_handler.h | 24 // : socket_(socket), buffer_() {
25 // io_handler.Initialize(socket_->handle(),
43 // base::CancelableSyncSocket* socket_;
90 base::SyncSocket::Handle socket_; member in class:base::AsyncSocketIoHandler
|
| /external/chromium_org/content/browser/renderer_host/media/ |
| audio_input_sync_writer.h | 52 scoped_ptr<base::CancelableSyncSocket> socket_; member in class:content::AudioInputSyncWriter
|
| audio_sync_reader.h | 63 scoped_ptr<base::CancelableSyncSocket> socket_; member in class:content::AudioSyncReader
|
| /external/chromium_org/content/browser/renderer_host/p2p/ |
| socket_host_tcp_server.h | 57 scoped_ptr<net::ServerSocket> socket_; member in class:content::P2PSocketHostTcpServer
|
| /external/chromium_org/net/udp/ |
| udp_client_socket.h | 40 UDPSocket socket_; member in class:net::UDPClientSocket
|
| /external/chromium_org/remoting/protocol/ |
| channel_multiplexer.cc | 96 MuxSocket* socket_; member in class:remoting::protocol::ChannelMultiplexer::MuxChannel
204 socket_(NULL) {
209 DCHECK(!socket_);
214 DCHECK(!socket_); // Can't create more than one socket per channel.
216 socket_ = result.get();
226 if (socket_) {
228 socket_->OnPacketReceived();
234 if (socket_)
235 socket_->OnWriteFailed();
239 DCHECK(socket_);
[all...] |
| libjingle_transport_factory.cc | 117 // We own |socket_| until it is connected.
118 scoped_ptr<jingle_glue::PseudoTcpAdapter> socket_; member in class:remoting::protocol::__anon10232::LibjingleStreamTransport
141 DCHECK(!is_connected() || socket_.get() == NULL);
229 socket_.reset(
231 socket_->SetSendBufferSize(kTcpSendBufferSize);
232 socket_->SetReceiveBufferSize(kTcpReceiveBufferSize);
233 socket_->SetNoDelay(true);
234 socket_->SetAckDelay(kTcpAckDelayMilliseconds);
240 socket_->SetWriteWaitsForSend(true);
242 int result = socket_->Connect
[all...] |
| /external/chromium_org/google_apis/gcm/base/ |
| socket_stream.h | 110 net::StreamSocket* const socket_; member in class:gcm::SocketInputStream::net
183 net::StreamSocket* const socket_; member in class:gcm::SocketOutputStream::net
|
| /external/chromium_org/net/dns/ |
| dns_session.h | 50 DatagramClientSocket* socket() { return socket_.get(); }
55 scoped_ptr<DatagramClientSocket> socket_; member in class:net::DnsSession::SocketLease
|
