/external/chromium_org/device/bluetooth/ |
H A D | bluetooth_channel_mac.h | 53 BluetoothSocketMac* socket() { return socket_; } 57 BluetoothSocketMac* socket_; member in class:device::BluetoothChannelMac
|
/external/chromium_org/net/test/embedded_test_server/ |
H A D | http_connection.cc | 15 : socket_(socket.Pass()), 24 socket_->Send(response_string.c_str(), response_string.length());
|
/external/chromium_org/third_party/libjingle/source/talk/xmpp/ |
H A D | xmppclient.cc | 50 socket_(), 59 // We need to disconnect from socket_ before engine_ is destructed (by 68 rtc::scoped_ptr<AsyncSocket> socket_; member in class:buzz::XmppClient::Private 84 if (socket_) { 85 socket_->SignalConnected.disconnect(this); 86 socket_->SignalRead.disconnect(this); 87 socket_->SignalClosed.disconnect(this); 88 socket_.reset(NULL); 116 if (d_->socket_) 119 d_->socket_ [all...] |
/external/chromium_org/net/socket/ |
H A D | client_socket_handle.cc | 42 if (socket_) { 43 socket_->NetLog().EndEvent(NetLog::TYPE_SOCKET_IN_USE); 46 pool_->ReleaseSocket(group_name_, socket_.Pass(), pool_id_); 59 socket_.reset(); 121 if (!socket_) 124 load_timing_info->socket_log_id = socket_->NetLog().source().id; 136 socket_ = s.Pass(); 147 return socket_.Pass(); 155 if (!socket_.get()) 185 DCHECK(socket_ [all...] |
H A D | tcp_socket_unittest.cc | 30 TCPSocketTest() : socket_(NULL, NetLog::Source()) { 37 ASSERT_EQ(OK, socket_.Open(ADDRESS_FAMILY_IPV4)); 38 ASSERT_EQ(OK, socket_.Bind(address)); 39 ASSERT_EQ(OK, socket_.Listen(kListenBacklog)); 40 ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); 48 if (socket_.Open(ADDRESS_FAMILY_IPV6) != OK || 49 socket_.Bind(address) != OK || 50 socket_.Listen(kListenBacklog) != OK) { 55 ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); 72 socket_ 93 TCPSocket socket_; member in class:net::__anon9547::TCPSocketTest [all...] |
H A D | tcp_socket_win.cc | 147 void Detach() { socket_ = NULL; } 193 TCPSocketWin* socket_; member in class:net::TCPSocketWin::Core 212 socket_(socket), 249 if (core_->socket_) { 250 if (core_->socket_->waiting_connect_) 251 core_->socket_->DidCompleteConnect(); 253 core_->socket_->DidSignalRead(); 262 if (core_->socket_) 263 core_->socket_->DidCompleteWrite(); 272 : socket_(INVALID_SOCKE [all...] |
H A D | stream_listen_socket.cc | 55 socket_(s), 90 if (getsockname(socket_, storage.addr, &storage.addr_len)) { 105 if (getpeername(socket_, storage.addr, &storage.addr_len)) { 121 SocketDescriptor conn = HANDLE_EINTR(accept(socket_, NULL, NULL)); 133 int sent = HANDLE_EINTR(send(socket_, send_buf, len_left, 0)); 161 if (listen(socket_, backlog) == -1) { 175 len = HANDLE_EINTR(recv(socket_, buf, kReadBufSize, 0)); 215 if (socket_ != kInvalidSocket) { 218 closesocket(socket_); 220 close(socket_); [all...] |
H A D | tcp_server_socket_unittest.cc | 30 : socket_(NULL, NetLog::Source()) { 36 ASSERT_EQ(OK, socket_.Listen(address, kListenBacklog)); 37 ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); 44 if (socket_.Listen(address, kListenBacklog) != 0) { 49 ASSERT_EQ(OK, socket_.GetLocalAddress(&local_address_)); 71 TCPServerSocket socket_; member in class:net::__anon9545::TCPServerSocketTest 85 int result = socket_.Accept(&accepted_socket, accept_callback.callback()); 107 socket_.Accept(&accepted_socket, accept_callback.callback())); 132 socket_.Accept(&accepted_socket, accept_callback.callback())); 148 int result = socket_ [all...] |
/external/chromium_org/third_party/webrtc/base/ |
H A D | autodetectproxy.cc | 32 : agent_(user_agent), resolver_(NULL), socket_(NULL), next_(0) { 60 delete socket_; 72 OnCloseEvent(socket_, ETIMEDOUT); 155 if (socket_) { 158 socket_->Close(); 159 Thread::Current()->Dispose(socket_); 160 socket_ = NULL; 185 socket_ = 188 if (!socket_) { 192 socket_ [all...] |
H A D | testclient.cc | 22 : socket_(socket), ready_to_send_(false) { 24 socket_->SignalReadPacket.connect(this, &TestClient::OnPacket); 25 socket_->SignalReadyToSend.connect(this, &TestClient::OnReadyToSend); 29 delete socket_; 38 while (socket_->GetState() != state && TimeUntil(end) > 0) 40 return (socket_->GetState() == state); 45 return socket_->Send(buf, size, options); 51 return socket_->SendTo(buf, size, dest, options); 110 return socket_->GetError(); 114 return socket_ [all...] |
H A D | sslsocketfactory.cc | 39 ASSERT(NULL == socket_); 54 if (socket_) { 55 return socket_->GetError(); 60 if (socket_) { 61 return socket_->Close(); 70 if (socket_) { 71 return socket_->GetState(); 85 } else if (!IsBlockingError(socket_->GetError())) { 86 SignalCloseEvent(this, socket_->GetError());
|
H A D | socketstream.h | 30 AsyncSocket* GetSocket() { return socket_; } 48 AsyncSocket* socket_; member in class:rtc::SocketStream
|
H A D | testclient.h | 40 SocketAddress address() const { return socket_->GetLocalAddress(); } 41 SocketAddress remote_address() const { return socket_->GetRemoteAddress(); } 85 AsyncPacketSocket* socket_; member in class:rtc::TestClient
|
/external/chromium_org/tools/android/forwarder2/ |
H A D | socket.cc | 71 : socket_(-1), 86 PRESERVE_ERRNO_HANDLE_EINTR(shutdown(socket_, SHUT_RDWR)); 92 CloseFD(socket_); 93 socket_ = -1; 98 socket_ = socket(family_, SOCK_STREAM, 0); 99 if (socket_ < 0) { 103 tools::DisableNagle(socket_); 105 setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, &reuse_addr, 113 const int flags = fcntl(socket_, F_GETFL); 120 if (fcntl(socket_, F_SETF [all...] |
/external/chromium_org/extensions/browser/api/socket/ |
H A D | tcp_socket.cc | 52 socket_(tcp_client_socket), 104 socket_.reset( 108 result = socket_->Connect( 118 if (socket_.get()) 119 socket_->Disconnect(); 149 if (!socket_.get() || !IsConnected()) { 156 int result = socket_->Read( 180 if (!socket_.get()) 182 return socket_->SetKeepAlive(enable, delay); 186 if (!socket_ [all...] |
H A D | udp_socket.cc | 31 socket_(net::DatagramSocket::DEFAULT_BIND, 52 result = socket_.Connect(ip_end_point); 67 return socket_.Bind(ip_end_point); 72 socket_.Close(); 97 if (!socket_.is_connected()) { 103 result = socket_.Read( 117 if (!socket_.is_connected()) 120 return socket_.Write(io_buffer, io_buffer_size, callback); 143 if (!socket_.is_connected()) { 150 result = socket_ [all...] |
/external/chromium_org/net/websockets/ |
H A D | websocket_job.cc | 86 DCHECK(!socket_.get()); 90 DCHECK(socket_.get()); 93 socket_->Connect(); 139 socket_->RestartWithAuth(credentials); 151 if (socket_.get()) 152 socket_->DetachDelegate(); 153 socket_ = NULL; 252 socket_ = NULL; 281 DCHECK(socket_.get()); 303 delegate_->OnSentData(socket_ [all...] |
/external/chromium_org/remoting/base/ |
H A D | socket_reader.cc | 22 : socket_(NULL), 32 DCHECK(!socket_); 34 socket_ = socket; 42 int result = socket_->Read(
|
/external/chromium_org/third_party/libjingle/source/talk/examples/peerconnection/server/ |
H A D | data_socket.h | 54 SocketBase() : socket_(INVALID_SOCKET) { } 55 explicit SocketBase(int socket) : socket_(socket) { } 58 int socket() const { return socket_; } 59 bool valid() const { return socket_ != INVALID_SOCKET; } 65 int socket_; member in class:SocketBase
|
/external/chromium_org/net/udp/ |
H A D | udp_socket_libevent.cc | 67 : socket_(kInvalidSocket), 112 if (IGNORE_EINTR(close(socket_)) < 0) 115 socket_ = kInvalidSocket; 127 if (getpeername(socket_, storage.addr, &storage.addr_len)) 147 if (getsockname(socket_, storage.addr, &storage.addr_len)) 172 DCHECK_NE(kInvalidSocket, socket_); 183 socket_, true, base::MessageLoopForIO::WATCH_READ, 216 DCHECK_NE(kInvalidSocket, socket_); 226 socket_, true, base::MessageLoopForIO::WATCH_WRITE, 285 rv = HANDLE_EINTR(connect(socket_, storag [all...] |
/external/chromium_org/tools/android/forwarder/ |
H A D | forwarder.cc | 115 socket_(-1) { 155 if (socket_ >= 0) 156 shutdown(socket_, SHUT_RDWR); 183 int socket_; member in class:__anon16410::Server 267 int socket = HANDLE_EINTR(accept(server->socket_, 301 CloseSocket(server->socket_); 302 server->socket_ = -1; 319 socket_ = socket(AF_INET, SOCK_STREAM, 0); 320 if (socket_ < 0) { 324 tools::DisableNagle(socket_); [all...] |
/external/chromium_org/content/browser/renderer_host/p2p/ |
H A D | socket_host_tcp_server_unittest.cc | 93 socket_ = new FakeServerSocket(); 96 socket_host_->socket_.reset(socket_); 107 EXPECT_TRUE(socket_->listening()); 113 return host->socket_.get(); 117 FakeServerSocket* socket_; // Owned by |socket_host_|. member in class:content::P2PSocketHostTcpServerTest 130 socket_->AddIncoming(incoming); 156 socket_->AddIncoming(incoming1); 157 socket_->AddIncoming(incoming2);
|
/external/chromium_org/chrome/common/extensions/docs/examples/extensions/irc/servlet/src/org/chromium/ |
H A D | IRCProxyWebSocket.java | 39 Socket socket_ = null; field in class:IRCProxyWebSocket.ChatWebSocket 53 if (socket_ == null) { 58 socket_ = SocketFactory.getDefault().createSocket(tokens[0], 60 out_ = new OutputStreamWriter(socket_.getOutputStream()); 62 socket_.getInputStream()); 89 socket_.close();
|
/external/chromium_org/third_party/libjingle/source/talk/p2p/base/ |
H A D | stunport.cc | 185 socket_(socket), 199 socket_(NULL), 207 ASSERT(socket_ == NULL); 208 socket_ = socket_factory()->CreateUdpSocket( 210 if (!socket_) { 214 socket_->SignalReadPacket.connect(this, &UDPPort::OnReadPacket); 216 socket_->SignalReadyToSend.connect(this, &UDPPort::OnReadyToSend); 217 socket_->SignalAddressReady.connect(this, &UDPPort::OnLocalAddressReady); 224 delete socket_; 229 if (socket_ [all...] |
H A D | stunserver.cc | 35 StunServer::StunServer(rtc::AsyncUDPSocket* socket) : socket_(socket) { 36 socket_->SignalReadPacket.connect(this, &StunServer::OnPacket); 40 socket_->SignalReadPacket.disconnect(this); 107 if (socket_->SendTo(buf.Data(), buf.Length(), addr, options) < 0)
|