Home
last modified time | relevance | path

Searched refs:socket_ (Results 1 – 25 of 76) sorted by relevance

1234

/external/webrtc/rtc_base/
Dsocket_stream.cc18 SocketStream::SocketStream(AsyncSocket* socket) : socket_(nullptr) { in SocketStream()
23 delete socket_; in ~SocketStream()
27 if (socket_) in Attach()
28 delete socket_; in Attach()
29 socket_ = socket; in Attach()
30 if (socket_) { in Attach()
31 socket_->SignalConnectEvent.connect(this, &SocketStream::OnConnectEvent); in Attach()
32 socket_->SignalReadEvent.connect(this, &SocketStream::OnReadEvent); in Attach()
33 socket_->SignalWriteEvent.connect(this, &SocketStream::OnWriteEvent); in Attach()
34 socket_->SignalCloseEvent.connect(this, &SocketStream::OnCloseEvent); in Attach()
[all …]
Dasync_socket.cc21 AsyncSocketAdapter::AsyncSocketAdapter(AsyncSocket* socket) : socket_(nullptr) { in AsyncSocketAdapter()
26 delete socket_; in ~AsyncSocketAdapter()
30 RTC_DCHECK(!socket_); in Attach()
31 socket_ = socket; in Attach()
32 if (socket_) { in Attach()
33 socket_->SignalConnectEvent.connect(this, in Attach()
35 socket_->SignalReadEvent.connect(this, &AsyncSocketAdapter::OnReadEvent); in Attach()
36 socket_->SignalWriteEvent.connect(this, &AsyncSocketAdapter::OnWriteEvent); in Attach()
37 socket_->SignalCloseEvent.connect(this, &AsyncSocketAdapter::OnCloseEvent); in Attach()
42 return socket_->GetLocalAddress(); in GetLocalAddress()
[all …]
Dnat_socket_factory.cc79 socket_(nullptr), in NATSocket()
84 delete socket_; in ~NATSocket()
89 return (socket_) ? socket_->GetLocalAddress() : SocketAddress(); in GetLocalAddress()
97 if (socket_) { // already bound, bubble up error in Bind()
108 if (!socket_) { in Connect()
116 result = socket_->Connect(server_addr_.IsNil() ? addr : server_addr_); in Connect()
138 return socket_->SendTo(data, size, addr); in SendTo()
146 int result = socket_->SendTo(buf.get(), encoded_size, server_addr_); in SendTo()
164 return socket_->RecvFrom(data, size, out_addr, timestamp); in RecvFrom()
172 int result = socket_->RecvFrom(buf_, size_, &remote_addr, timestamp); in RecvFrom()
[all …]
Dasync_udp_socket.cc46 AsyncUDPSocket::AsyncUDPSocket(AsyncSocket* socket) : socket_(socket) { in AsyncUDPSocket()
51 socket_->SignalReadEvent.connect(this, &AsyncUDPSocket::OnReadEvent); in AsyncUDPSocket()
52 socket_->SignalWriteEvent.connect(this, &AsyncUDPSocket::OnWriteEvent); in AsyncUDPSocket()
60 return socket_->GetLocalAddress(); in GetLocalAddress()
64 return socket_->GetRemoteAddress(); in GetRemoteAddress()
73 int ret = socket_->Send(pv, cb); in Send()
85 int ret = socket_->SendTo(pv, cb, addr); in SendTo()
91 return socket_->Close(); in Close()
99 return socket_->GetOption(opt, value); in GetOption()
103 return socket_->SetOption(opt, value); in SetOption()
[all …]
Dasync_tcp_socket.cc67 : socket_(socket), in AsyncTCPSocketBase()
76 RTC_DCHECK(socket_.get() != nullptr); in AsyncTCPSocketBase()
77 socket_->SignalConnectEvent.connect(this, in AsyncTCPSocketBase()
79 socket_->SignalReadEvent.connect(this, &AsyncTCPSocketBase::OnReadEvent); in AsyncTCPSocketBase()
80 socket_->SignalWriteEvent.connect(this, &AsyncTCPSocketBase::OnWriteEvent); in AsyncTCPSocketBase()
81 socket_->SignalCloseEvent.connect(this, &AsyncTCPSocketBase::OnCloseEvent); in AsyncTCPSocketBase()
84 if (socket_->Listen(kListenBacklog) < 0) { in AsyncTCPSocketBase()
85 RTC_LOG(LS_ERROR) << "Listen() failed with error " << socket_->GetError(); in AsyncTCPSocketBase()
93 return socket_->GetLocalAddress(); in GetLocalAddress()
97 return socket_->GetRemoteAddress(); in GetRemoteAddress()
[all …]
Dwin32_socket_server.cc208 : socket_(INVALID_SOCKET), in Win32Socket()
224 socket_ = ::WSASocket(family, type, proto, nullptr, 0, 0); in CreateT()
225 if (socket_ == INVALID_SOCKET) { in CreateT()
236 RTC_DCHECK(socket_ == INVALID_SOCKET); in Attach()
237 if (socket_ != INVALID_SOCKET) in Attach()
244 socket_ = s; in Attach()
262 ::getsockname(socket_, reinterpret_cast<sockaddr*>(&addr), &addrlen); in GetLocalAddress()
268 << socket_; in GetLocalAddress()
277 ::getpeername(socket_, reinterpret_cast<sockaddr*>(&addr), &addrlen); in GetRemoteAddress()
283 << "GetRemoteAddress: unable to get remote addr, socket=" << socket_; in GetRemoteAddress()
[all …]
Dtest_client.cc34 socket_(std::move(socket)), in TestClient()
36 socket_->SignalReadPacket.connect(this, &TestClient::OnPacket); in TestClient()
37 socket_->SignalReadyToSend.connect(this, &TestClient::OnReadyToSend); in TestClient()
45 while (socket_->GetState() != state && TimeUntil(end) > 0) { in CheckConnState()
48 return (socket_->GetState() == state); in CheckConnState()
53 return socket_->Send(buf, size, options); in Send()
60 return socket_->SendTo(buf, size, dest, options); in SendTo()
140 return socket_->GetError(); in GetError()
144 return socket_->SetOption(opt, value); in SetOption()
Dasync_tcp_socket_unittest.cc25 socket_(vss_->CreateAsyncSocket(SOCK_STREAM)), in AsyncTCPSocketTest()
26 tcp_socket_(new AsyncTCPSocket(socket_, true)), in AsyncTCPSocketTest()
36 AsyncSocket* socket_; member in rtc::AsyncTCPSocketTest
43 socket_->SignalWriteEvent(socket_); in TEST_F()
Dasync_udp_socket_unittest.cc27 socket_(vss_->CreateAsyncSocket(SOCK_DGRAM)), in AsyncUdpSocketTest()
28 udp_socket_(new AsyncUDPSocket(socket_)), in AsyncUdpSocketTest()
39 AsyncSocket* socket_; member in rtc::AsyncUdpSocketTest
46 socket_->SignalWriteEvent(socket_); in TEST_F()
/external/parameter-framework/asio-1.10.6/include/asio/detail/
Dsocket_holder.hpp31 : socket_(invalid_socket) in socket_holder()
37 : socket_(s) in socket_holder()
44 if (socket_ != invalid_socket) in ~socket_holder()
48 socket_ops::close(socket_, state, true, ec); in ~socket_holder()
55 return socket_; in get()
61 if (socket_ != invalid_socket) in reset()
65 socket_ops::close(socket_, state, true, ec); in reset()
66 socket_ = invalid_socket; in reset()
74 socket_ = s; in reset()
80 socket_type tmp = socket_; in release()
[all …]
Dreactive_socket_service_base.hpp49 socket_type socket_; member
83 return impl.socket_ != invalid_socket; in is_open()
93 return impl.socket_; in native_handle()
104 return socket_ops::sockatmark(impl.socket_, ec); in at_mark()
111 return socket_ops::available(impl.socket_, ec); in available()
118 socket_ops::listen(impl.socket_, backlog, ec); in listen()
127 socket_ops::ioctl(impl.socket_, impl.state_, command.name(), in io_control()
142 socket_ops::set_user_non_blocking(impl.socket_, impl.state_, mode, ec); in non_blocking()
156 socket_ops::set_internal_non_blocking(impl.socket_, impl.state_, mode, ec); in native_non_blocking()
164 socket_ops::shutdown(impl.socket_, what, ec); in shutdown()
[all …]
Dreactive_socket_service.hpp132 return impl.socket_; in native_handle()
139 socket_ops::bind(impl.socket_, endpoint.data(), endpoint.size(), ec); in bind()
148 socket_ops::setsockopt(impl.socket_, impl.state_, in set_option()
160 socket_ops::getsockopt(impl.socket_, impl.state_, in get_option()
174 if (socket_ops::getsockname(impl.socket_, endpoint.data(), &addr_len, ec)) in local_endpoint()
186 if (socket_ops::getpeername(impl.socket_, in remote_endpoint()
203 return socket_ops::sync_sendto(impl.socket_, impl.state_, in send_to()
214 socket_ops::poll_write(impl.socket_, impl.state_, ec); in send_to()
236 p.p = new (p.v) op(impl.socket_, buffers, destination, flags, handler); in async_send_to()
279 impl.socket_, impl.state_, bufs.buffers(), bufs.count(), in receive_from()
[all …]
/external/webrtc/p2p/base/
Dtcp_port.cc102 socket_(NULL), in TCPPort()
112 delete socket_; in ~TCPPort()
168 if (socket_) { in PrepareAddress()
173 << socket_->GetState(); in PrepareAddress()
174 if (socket_->GetState() == rtc::AsyncPacketSocket::STATE_BOUND || in PrepareAddress()
175 socket_->GetState() == rtc::AsyncPacketSocket::STATE_CLOSED) in PrepareAddress()
176 AddAddress(socket_->GetLocalAddress(), socket_->GetLocalAddress(), in PrepareAddress()
249 if (socket_) { in GetOption()
250 return socket_->GetOption(opt, value); in GetOption()
257 if (socket_) { in SetOption()
[all …]
Dstun_port.cc178 socket_(socket), in UDPPort()
205 socket_(nullptr), in UDPPort()
217 RTC_DCHECK(socket_ == nullptr); in Init()
218 socket_ = socket_factory()->CreateUdpSocket( in Init()
220 if (!socket_) { in Init()
224 socket_->SignalReadPacket.connect(this, &UDPPort::OnReadPacket); in Init()
226 socket_->SignalSentPacket.connect(this, &UDPPort::OnSentPacket); in Init()
227 socket_->SignalReadyToSend.connect(this, &UDPPort::OnReadyToSend); in Init()
228 socket_->SignalAddressReady.connect(this, &UDPPort::OnLocalAddressReady); in Init()
235 delete socket_; in ~UDPPort()
[all …]
Dstun_server.cc20 StunServer::StunServer(rtc::AsyncUDPSocket* socket) : socket_(socket) { in StunServer()
21 socket_->SignalReadPacket.connect(this, &StunServer::OnPacket); in StunServer()
25 socket_->SignalReadPacket.disconnect(this); in ~StunServer()
82 if (socket_->SendTo(buf.Data(), buf.Length(), addr, options) < 0) in SendResponse()
/external/parameter-framework/asio-1.10.6/include/asio/detail/impl/
Dreactive_socket_service_base.ipp39 impl.socket_ = invalid_socket;
47 impl.socket_ = other_impl.socket_;
48 other_impl.socket_ = invalid_socket;
53 reactor_.move_descriptor(impl.socket_,
64 impl.socket_ = other_impl.socket_;
65 other_impl.socket_ = invalid_socket;
70 other_service.reactor_.move_descriptor(impl.socket_,
77 if (impl.socket_ != invalid_socket)
81 reactor_.deregister_descriptor(impl.socket_, impl.reactor_data_,
85 socket_ops::close(impl.socket_, impl.state_, true, ignored_ec);
[all …]
/external/openscreen/cast/common/channel/
Dconnection_namespace_handler_unittest.cc90 socket_ = fake_cast_socket_pair_.socket.get(); in SetUp()
142 CastSocket* socket_; member in openscreen::cast::ConnectionNamespaceHandlerTest
155 &router_, socket_, MakeConnectMessage(sender_id_, receiver_id_)); in TEST_F()
157 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
170 &router_, socket_, MakeConnectMessage(sender_id_, receiver_id_)); in TEST_F()
172 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
180 &router_, socket_, in TEST_F()
185 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
193 &router_, socket_, in TEST_F()
200 VirtualConnection{receiver_id_, sender_id_, socket_->socket_id()})); in TEST_F()
[all …]
Dcast_socket_message_port.cc30 socket_ = socket; in SetSocket()
34 return ToCastSocketId(socket_.get()); in GetSocketId()
66 if (!socket_) { in PostMessage()
72 socket_->socket_id()}; in PostMessage()
88 OSP_DCHECK(!socket || socket_.get() == socket); in OnMessage()
/external/openscreen/cast/streaming/
Denvironment.cc30 const_cast<std::unique_ptr<UdpSocket>&>(socket_) = std::move(result.value()); in Environment()
31 OSP_DCHECK(socket_); in Environment()
32 socket_->Bind(); in Environment()
38 if (socket_) { in GetBoundLocalEndpoint()
39 return socket_->GetLocalEndpoint(); in GetBoundLocalEndpoint()
76 if (socket_) { in SendPacket()
77 socket_->SendMessage(packet.data(), packet.size(), remote_endpoint_); in SendPacket()
84 OSP_DCHECK(socket == socket_.get()); in OnBound()
93 OSP_DCHECK(socket == socket_.get()); in OnError()
106 OSP_LOG_ERROR << "For UDP socket bound to " << socket_->GetLocalEndpoint() in OnError()
/external/grpc-grpc-java/services/src/generated/main/java/io/grpc/channelz/v1/
DGetSocketResponse.java54 if (socket_ != null) { in GetSocketResponse()
55 subBuilder = socket_.toBuilder(); in GetSocketResponse()
57 socket_ = input.readMessage(io.grpc.channelz.v1.Socket.parser(), extensionRegistry); in GetSocketResponse()
59 subBuilder.mergeFrom(socket_); in GetSocketResponse()
60 socket_ = subBuilder.buildPartial(); in GetSocketResponse()
90 private io.grpc.channelz.v1.Socket socket_; field in GetSocketResponse
100 return socket_ != null; in hasSocket()
111 return socket_ == null ? io.grpc.channelz.v1.Socket.getDefaultInstance() : socket_; in getSocket()
137 if (socket_ != null) { in writeTo()
148 if (socket_ != null) { in getSerializedSize()
[all …]
/external/openscreen/discovery/mdns/
Dmdns_querier_unittest.cc58 sender_(&socket_), in MdnsQuerierTest()
168 testing::NiceMock<MockUdpSocket> socket_; member in openscreen::discovery::MdnsQuerierTest
197 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_created_)); in TEST_F()
199 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_created_)); in TEST_F()
200 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_updated_)); in TEST_F()
201 receiver_.OnRead(&socket_, CreatePacketWithRecord(record0_deleted_)); in TEST_F()
220 receiver_.OnRead(&socket_, CreatePacketWithRecord(record1_created_)); in TEST_F()
221 receiver_.OnRead(&socket_, CreatePacketWithRecord(record1_deleted_)); in TEST_F()
240 receiver_.OnRead(&socket_, CreatePacketWithRecord(record1_created_)); in TEST_F()
242 receiver_.OnRead(&socket_, CreatePacketWithRecord(record1_created_)); in TEST_F()
[all …]
Dmdns_sender.cc17 MdnsSender::MdnsSender(UdpSocket* socket) : socket_(socket) { in MdnsSender()
18 OSP_DCHECK(socket_ != nullptr); in MdnsSender()
24 const IPEndpoint& endpoint = socket_->IsIPv6() ? kMulticastSendIPv6Endpoint in SendMulticast()
41 socket_->SendMessage(buffer.data(), writer.offset(), endpoint); in SendMessage()
/external/openscreen/cast/test/
Dcast_socket_e2e_test.cc53 CastSocket* socket() const { return socket_; } in socket()
59 OSP_CHECK(!socket_); in OnConnected()
62 socket_ = socket.get(); in OnConnected()
74 socket_ = nullptr; in OnClose()
78 socket_ = nullptr; in OnError()
87 std::atomic<CastSocket*> socket_{nullptr}; member in openscreen::cast::SenderSocketsClient
99 CastSocket* socket() const { return socket_; } in socket()
105 OSP_CHECK(!socket_); in OnConnected()
109 socket_ = socket.get(); in OnConnected()
119 socket_ = nullptr; in OnClose()
[all …]
/external/webrtc/examples/peerconnection/server/
Ddata_socket.cc57 socket_ = ::socket(AF_INET, SOCK_STREAM, 0); in Create()
62 if (socket_ != INVALID_SOCKET) { in Close()
63 closesocket(socket_); in Close()
64 socket_ = INVALID_SOCKET; in Close()
90 int bytes = recv(socket_, buffer, sizeof(buffer), 0); in OnDataAvailable()
119 return send(socket_, data.data(), static_cast<int>(data.length()), 0) != in Send()
272 setsockopt(socket_, SOL_SOCKET, SO_REUSEADDR, in Listen()
278 if (bind(socket_, reinterpret_cast<const sockaddr*>(&addr), sizeof(addr)) == in Listen()
283 return listen(socket_, 5) != SOCKET_ERROR; in Listen()
291 accept(socket_, reinterpret_cast<sockaddr*>(&addr), &size); in Accept()
Ddata_socket.h38 SocketBase() : socket_(INVALID_SOCKET) {} in SocketBase()
39 explicit SocketBase(NativeSocket socket) : socket_(socket) {} in SocketBase()
42 NativeSocket socket() const { return socket_; } in socket()
43 bool valid() const { return socket_ != INVALID_SOCKET; } in valid()
49 NativeSocket socket_;

1234