Searched refs:socket_ (Results 26 - 50 of 217) sorted by relevance

123456789

/external/chromium_org/device/bluetooth/
H A Dbluetooth_channel_mac.h53 BluetoothSocketMac* socket() { return socket_; }
57 BluetoothSocketMac* socket_; member in class:device::BluetoothChannelMac
/external/chromium_org/net/test/embedded_test_server/
H A Dhttp_connection.cc15 : socket_(socket.Pass()),
24 socket_->Send(response_string.c_str(), response_string.length());
/external/chromium_org/third_party/libjingle/source/talk/xmpp/
H A Dxmppclient.cc50 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 Dclient_socket_handle.cc42 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 Dtcp_socket_unittest.cc30 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 Dtcp_socket_win.cc147 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 Dstream_listen_socket.cc55 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 Dtcp_server_socket_unittest.cc30 : 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 Dautodetectproxy.cc32 : 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 Dtestclient.cc22 : 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 Dsslsocketfactory.cc39 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 Dsocketstream.h30 AsyncSocket* GetSocket() { return socket_; }
48 AsyncSocket* socket_; member in class:rtc::SocketStream
H A Dtestclient.h40 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 Dsocket.cc71 : 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 Dtcp_socket.cc52 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 Dudp_socket.cc31 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 Dwebsocket_job.cc86 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 Dsocket_reader.cc22 : 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 Ddata_socket.h54 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 Dudp_socket_libevent.cc67 : 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 Dforwarder.cc115 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 Dsocket_host_tcp_server_unittest.cc93 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 DIRCProxyWebSocket.java39 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 Dstunport.cc185 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 Dstunserver.cc35 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)

Completed in 2134 milliseconds

123456789