| /system/netd/tests/dns_responder/ |
| dns_responder.h | 126 int socket_; member in class:test::DNSResponder
|
| /external/webrtc/webrtc/base/ |
| win32socketserver.h | 71 SOCKET socket_; member in class:rtc::Win32Socket
|
| natsocketfactory.cc | 74 socket_(NULL), buf_(NULL), size_(0) {
78 delete socket_;
83 return (socket_) ? socket_->GetLocalAddress() : SocketAddress();
91 if (socket_) { // already bound, bubble up error
96 socket_ = sf_->CreateInternalSocket(family_, type_, addr, &server_addr_);
97 result = (socket_) ? socket_->Bind(addr) : -1;
99 socket_->SignalConnectEvent.connect(this, &NATSocket::OnConnectEvent);
100 socket_->SignalReadEvent.connect(this, &NATSocket::OnReadEvent)
297 AsyncSocket* socket_; member in class:rtc::NATSocket
[all...] |
| thread_unittest.cc | 53 : socket_(AsyncUDPSocket::Create(socket, addr)),
56 socket_->SignalReadPacket.connect(this, &SocketClient::OnPacket);
60 delete socket_;
63 SocketAddress address() const { return socket_->GetLocalAddress(); }
76 AsyncUDPSocket* socket_; member in class:SocketClient
85 : socket_(socket) {
89 delete socket_;
95 EXPECT_GE(socket_->Send(&result, sizeof(result)), 0);
100 Socket* socket_; member in class:MessageClient
|
| testutils.h | 286 socket_->Connect(address);
289 AsyncSocket* socket() { return socket_.get(); }
305 if (Socket::CS_CONNECTED == socket_->GetState()) {
316 return (Socket::CS_CONNECTED == socket_->GetState());
319 return (Socket::CS_CLOSED == socket_->GetState());
330 socket_.reset(socket);
331 socket_->SignalConnectEvent.connect(this,
333 socket_->SignalReadEvent.connect(this, &SocketTestClient::OnReadEvent);
334 socket_->SignalWriteEvent.connect(this, &SocketTestClient::OnWriteEvent);
335 socket_->SignalCloseEvent.connect(this, &SocketTestClient::OnCloseEvent)
374 scoped_ptr<AsyncSocket> socket_; member in class:testing::SocketTestClient
417 scoped_ptr<AsyncSocket> socket_; member in class:testing::SocketTestServer
[all...] |
| /external/webrtc/webrtc/examples/peerconnection/server/ |
| data_socket.h | 39 SocketBase() : socket_(INVALID_SOCKET) { }
40 explicit SocketBase(NativeSocket socket) : socket_(socket) { }
43 NativeSocket socket() const { return socket_; }
44 bool valid() const { return socket_ != INVALID_SOCKET; }
50 NativeSocket socket_; member in class:SocketBase
|
| /external/webrtc/webrtc/p2p/base/ |
| stunport.h | 71 return socket_->GetLocalAddress();
215 rtc::AsyncPacketSocket* socket_; member in class:cricket::UDPPort
|
| stunport_unittest.cc | 77 socket_.reset(socket_factory_.CreateUdpSocket(
79 ASSERT_TRUE(socket_ != NULL);
80 socket_->SignalReadPacket.connect(this, &StunPortTest::OnReadPacket);
83 &network_, socket_.get(),
109 socket_.get(), data, len, rtc::SocketAddress("22.22.22.22", 0),
149 rtc::scoped_ptr<rtc::AsyncPacketSocket> socket_; member in class:StunPortTest
|
| relayserver.h | 141 rtc::AsyncPacketSocket* socket() { return socket_; }
175 rtc::AsyncPacketSocket* socket_; member in class:cricket::RelayServerConnection
|
| turnport.h | 129 return socket_;
257 rtc::AsyncPacketSocket* socket_; member in class:cricket::TurnPort
|
| turnserver.h | 43 TurnServerConnection() : proto_(PROTO_UDP), socket_(NULL) {}
48 rtc::AsyncPacketSocket* socket() { return socket_; }
57 rtc::AsyncPacketSocket* socket_; member in class:cricket::TurnServerConnection
|
| relayport.cc | 34 rtc::AsyncPacketSocket* socket() const { return socket_; }
60 int GetError() { return socket_->GetError(); }
67 rtc::AsyncPacketSocket* socket_; member in class:cricket::RelayConnection
406 : socket_(socket),
415 delete socket_;
420 if (socket_) {
421 return socket_->SetOption(opt, value);
434 int sent = socket_->SendTo(data, size, GetAddress(), options);
437 strerror(socket_->GetError());
444 return socket_->SendTo(pv, cb, GetAddress(), options)
[all...] |
| turnport_unittest.cc | 255 if (!socket_) {
256 socket_.reset(socket_factory_.CreateUdpSocket(
258 ASSERT_TRUE(socket_ != NULL);
259 socket_->SignalReadPacket.connect(
265 main_, &socket_factory_, &network_, socket_.get(),
515 rtc::scoped_ptr<rtc::AsyncPacketSocket> socket_; member in class:TurnPortTest
[all...] |
| /external/libbrillo/brillo/streams/ |
| tls_stream.cc | 118 StreamPtr socket_; member in class:brillo::TlsStream::TlsStreamImpl
208 return socket_->FlushBlocking(error);
225 if (!socket_->WaitForDataBlocking(AccessMode::READ, kTimeout, nullptr,
230 if (!socket_->WaitForDataBlocking(AccessMode::WRITE, kTimeout, nullptr,
240 return socket_->CloseBlocking(error);
258 return socket_->WaitForData(mode, callback, error);
276 return socket_->WaitForDataBlocking(in_mode, timeout, out_mode, error);
280 socket_->CancelPendingAsyncOperations();
375 socket_ = std::move(socket);
382 stream_bio_ = BIO_new_stream(socket_.get())
[all...] |
| /external/webrtc/webrtc/libjingle/xmpp/ |
| xmppclient.cc | 33 socket_(),
42 // We need to disconnect from socket_ before engine_ is destructed (by
51 rtc::scoped_ptr<AsyncSocket> socket_; member in class:buzz::XmppClient::Private
67 if (socket_) {
68 socket_->SignalConnected.disconnect(this);
69 socket_->SignalRead.disconnect(this);
70 socket_->SignalClosed.disconnect(this);
71 socket_.reset(NULL);
99 if (d_->socket_)
102 d_->socket_.reset(socket)
[all...] |
| /system/core/fastboot/ |
| udp.cpp | 114 explicit UdpTransport(std::unique_ptr<Socket> socket) : socket_(std::move(socket)) {}
133 std::unique_ptr<Socket> socket_; member in class:udp::UdpTransport
208 if (socket_ == nullptr) {
260 if (!socket_->Send({{header->bytes(), kHeaderSize}, {tx_data, tx_length}})) {
268 bytes = socket_->Receive(rx_packet_.data(), rx_packet_.size(), kResponseTimeoutMs);
270 if (socket_->ReceiveTimedOut()) {
281 if (socket_->ReceiveTimedOut()) {
364 if (socket_ == nullptr) {
368 int result = socket_->Close();
369 socket_.reset()
[all...] |
| /external/webrtc/webrtc/p2p/stunprober/ |
| stunprober.cc | 92 rtc::scoped_ptr<rtc::AsyncPacketSocket> socket_; member in class:stunprober::StunProber::Requester
113 socket_(socket),
117 socket_->SignalReadPacket.connect(
122 if (socket_) {
123 socket_->Close();
157 int rv = socket_->SendTo(const_cast<char*>(request_packet->Data()),
206 RTC_DCHECK(socket_);
|
| /bionic/libc/bionic/ |
| system_properties.cpp | 481 socket_ = ::socket(AF_LOCAL, SOCK_STREAM | SOCK_CLOEXEC, 0);
482 if (socket_ == -1) {
494 if (TEMP_FAILURE_RETRY(connect(socket_, reinterpret_cast<sockaddr*>(&addr), alen)) == -1) {
495 close(socket_);
496 socket_ = -1;
502 return socket_ != -1;
510 int result = TEMP_FAILURE_RETRY(recv(socket_, value, sizeof(*value), MSG_WAITALL));
515 return socket_;
519 if (socket_ != -1) {
520 close(socket_);
537 int socket_; member in class:PropertyServiceConnection
[all...] |
| /system/core/init/ |
| property_service.cpp | 217 : socket_(socket), cred_(cred) {}
220 close(socket_);
259 int result = TEMP_FAILURE_RETRY(send(socket_, &value, sizeof(value), 0));
264 return socket_;
274 ufds[0].fd = socket_;
316 int result = TEMP_FAILURE_RETRY(recv(socket_, data, bytes_left, MSG_DONTWAIT));
328 int socket_; member in class:SocketConnection
|
