Home
last modified time | relevance | path

Searched refs:UdpSocket (Results 1 – 25 of 75) sorted by relevance

123

/external/openscreen/osp/impl/testing/
Dfake_mdns_responder_adapter.h23 UdpSocket* socket);
30 UdpSocket* socket);
36 UdpSocket* socket);
40 UdpSocket* socket);
44 UdpSocket* socket);
54 UdpSocket* socket);
61 UdpSocket* socket;
104 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
105 void OnSendError(UdpSocket* socket, Error error) override;
106 void OnError(UdpSocket* socket, Error error) override;
[all …]
Dfake_mdns_responder_adapter.cc23 UdpSocket* socket) { in MakePtrEvent()
39 UdpSocket* socket) { in MakeSrvEvent()
60 UdpSocket* socket) { in MakeTxtEvent()
73 UdpSocket* socket) { in MakeAEvent()
85 UdpSocket* socket) { in MakeAaaaEvent()
103 UdpSocket* socket) { in AddEventsForNewService()
210 UdpSocket* socket) { in RegisterInterface()
224 Error FakeMdnsResponderAdapter::DeregisterInterface(UdpSocket* socket) { in DeregisterInterface()
237 void FakeMdnsResponderAdapter::OnRead(UdpSocket* socket, in OnRead()
242 void FakeMdnsResponderAdapter::OnSendError(UdpSocket* socket, Error error) { in OnSendError()
[all …]
/external/openscreen/osp/impl/discovery/mdns/
Dmdns_responder_adapter_impl.h35 UdpSocket* socket) override;
36 Error DeregisterInterface(UdpSocket* socket) override;
38 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
39 void OnSendError(UdpSocket* socket, Error error) override;
40 void OnError(UdpSocket* socket, Error error) override;
41 void OnBound(UdpSocket* socket) override;
51 MdnsResponderErrorCode StartPtrQuery(UdpSocket* socket,
54 UdpSocket* socket,
57 UdpSocket* socket,
59 MdnsResponderErrorCode StartAQuery(UdpSocket* socket,
[all …]
Dmdns_responder_adapter.h32 QueryEventHeader(Type response_type, UdpSocket* socket);
38 UdpSocket* socket;
163 class MdnsResponderAdapter : public UdpSocket::Client {
189 UdpSocket* socket) = 0;
190 virtual Error DeregisterInterface(UdpSocket* socket) = 0;
203 UdpSocket* socket,
206 UdpSocket* socket,
209 UdpSocket* socket,
211 virtual MdnsResponderErrorCode StartAQuery(UdpSocket* socket,
214 UdpSocket* socket,
[all …]
Dmdns_demo.cc59 class DemoSocketClient : public UdpSocket::Client {
63 void OnError(UdpSocket* socket, Error error) override { in OnError()
69 void OnSendError(UdpSocket* socket, Error error) override { in OnSendError()
73 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override { in OnRead()
127 std::vector<std::unique_ptr<UdpSocket>> SetUpMulticastSockets( in SetUpMulticastSockets()
130 UdpSocket::Client* client) { in SetUpMulticastSockets()
131 std::vector<std::unique_ptr<UdpSocket>> sockets; in SetUpMulticastSockets()
134 UdpSocket::Create(task_runner, client, IPEndpoint{{}, 5353}); in SetUpMulticastSockets()
140 std::unique_ptr<UdpSocket> socket = std::move(create_result.value()); in SetUpMulticastSockets()
306 for (const std::unique_ptr<UdpSocket>& socket : sockets) { in BrowseDemo()
[all …]
/external/rust/crates/mio/src/net/
Dudp.rs91 pub struct UdpSocket { struct
92 inner: IoSource<net::UdpSocket>, argument
95 impl UdpSocket { implementation
121 pub fn bind(addr: SocketAddr) -> io::Result<UdpSocket> { in bind() argument
122 sys::udp::bind(addr).map(UdpSocket::from_std) in bind()
131 pub fn from_std(socket: net::UdpSocket) -> UdpSocket { in from_std() argument
132 UdpSocket { in from_std()
530 impl event::Source for UdpSocket { implementation
554 impl fmt::Debug for UdpSocket { implementation
561 impl IntoRawFd for UdpSocket { implementation
[all …]
/external/openscreen/platform/api/
Dudp_socket.h28 class UdpSocket {
37 virtual void OnBound(UdpSocket* socket) {} in OnBound()
45 virtual void OnError(UdpSocket* socket, Error error) = 0;
48 virtual void OnSendError(UdpSocket* socket, Error error) = 0;
51 virtual void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) = 0;
77 static ErrorOr<std::unique_ptr<UdpSocket>> Create(
82 virtual ~UdpSocket();
119 UdpSocket();
Dudp_socket.cc9 UdpSocket::UdpSocket() = default;
10 UdpSocket::~UdpSocket() = default;
Dsocket_integration_unittest.cc23 ErrorOr<std::unique_ptr<UdpSocket>> create_result = UdpSocket::Create( in TEST()
41 ErrorOr<std::unique_ptr<UdpSocket>> create_result = UdpSocket::Create( in TEST()
/external/rust/crates/tokio/src/net/
Dudp.rs122 pub struct UdpSocket {
123 io: PollEvented<mio::net::UdpSocket>,
127 impl UdpSocket { impl
145 pub async fn bind<A: ToSocketAddrs>(addr: A) -> io::Result<UdpSocket> { in bind() argument
150 match UdpSocket::bind_addr(addr) { in bind()
164 fn bind_addr(addr: SocketAddr) -> io::Result<UdpSocket> { in bind_addr() argument
165 let sys = mio::net::UdpSocket::bind(addr)?; in bind_addr()
166 UdpSocket::new(sys) in bind_addr()
169 fn new(socket: mio::net::UdpSocket) -> io::Result<UdpSocket> { in new() argument
171 Ok(UdpSocket { io }) in new()
[all …]
/external/rust/crates/tokio/tests/
Dudp.rs7 use tokio::{io::ReadBuf, net::UdpSocket};
14 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_recv()
15 let receiver = UdpSocket::bind("127.0.0.1:0").await?; in send_recv()
31 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_recv_poll()
32 let receiver = UdpSocket::bind("127.0.0.1:0").await?; in send_recv_poll()
49 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_recv_from()
50 let receiver = UdpSocket::bind("127.0.0.1:0").await?; in send_to_recv_from()
65 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_recv_from_poll()
66 let receiver = UdpSocket::bind("127.0.0.1:0").await?; in send_to_recv_from_poll()
82 let sender = UdpSocket::bind("127.0.0.1:0").await?; in send_to_peek_from()
[all …]
/external/openscreen/osp/impl/
Dinternal_services.h37 class InternalServices : UdpSocket::Client {
49 void OnError(UdpSocket* socket, Error error) override;
50 void OnSendError(UdpSocket* socket, Error error) override;
51 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
66 std::vector<std::unique_ptr<UdpSocket>> open_sockets_;
74 void RegisterMdnsSocket(UdpSocket* socket);
75 void DeregisterMdnsSocket(UdpSocket* socket);
Dmdns_responder_service.h37 public UdpSocket::Client {
55 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
56 void OnSendError(UdpSocket* socket, Error error) override;
57 void OnError(UdpSocket* socket, Error error) override;
99 UdpSocket* ptr_socket = nullptr;
117 UdpSocket* socket;
145 bool HandleAddressEvent(UdpSocket* socket,
156 HostInfo* AddOrGetHostInfo(UdpSocket* socket, const DomainName& domain_name);
157 HostInfo* GetHostInfo(UdpSocket* socket, const DomainName& domain_name);
160 const UdpSocket* socket) const;
Dinternal_services.cc40 Error SetUpMulticastSocket(UdpSocket* socket, NetworkInterfaceIndex ifindex) { in SetUpMulticastSocket()
134 UdpSocket::Create(parent_->task_runner_, parent_, in RegisterInterfaces()
141 std::unique_ptr<UdpSocket> socket = std::move(create_result.value()); in RegisterInterfaces()
157 UdpSocket* const socket = interface.socket; in DeregisterInterfaces()
161 [socket](const std::unique_ptr<UdpSocket>& s) { in DeregisterInterfaces()
181 void InternalServices::RegisterMdnsSocket(UdpSocket* socket) { in RegisterMdnsSocket()
187 void InternalServices::DeregisterMdnsSocket(UdpSocket* socket) { in DeregisterMdnsSocket()
214 void InternalServices::OnError(UdpSocket* socket, Error error) { in OnError()
219 void InternalServices::OnSendError(UdpSocket* socket, Error error) { in OnSendError()
224 void InternalServices::OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) { in OnRead()
/external/openscreen/discovery/mdns/
Dmdns_service_impl.h35 class MdnsServiceImpl : public MdnsService, public UdpSocket::Client {
66 void OnError(UdpSocket* socket, Error error) override;
67 void OnSendError(UdpSocket* socket, Error error) override;
68 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
69 void OnBound(UdpSocket* socket) override;
81 std::unique_ptr<UdpSocket> socket_v4_;
82 std::unique_ptr<UdpSocket> socket_v6_;
Dmdns_service_impl.cc48 ErrorOr<std::unique_ptr<UdpSocket>> socket = UdpSocket::Create( in MdnsServiceImpl()
59 ErrorOr<std::unique_ptr<UdpSocket>> socket = UdpSocket::Create( in MdnsServiceImpl()
70 UdpSocket* socket_ptr = in MdnsServiceImpl()
144 void MdnsServiceImpl::OnError(UdpSocket* socket, Error error) { in OnError()
148 void MdnsServiceImpl::OnSendError(UdpSocket* socket, Error error) { in OnSendError()
152 void MdnsServiceImpl::OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) { in OnRead()
156 void MdnsServiceImpl::OnBound(UdpSocket* socket) { in OnBound()
/external/openscreen/osp/impl/quic/testing/
Dfake_quic_connection_factory.h60 void OnError(UdpSocket* socket, Error error) override;
61 void OnSendError(UdpSocket* socket, Error error) override;
62 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
73 std::unique_ptr<UdpSocket> socket_;
87 void OnError(UdpSocket* socket, Error error) override;
88 void OnSendError(UdpSocket* socket, Error error) override;
89 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
/external/openscreen/platform/test/
Dfake_udp_socket.h20 class FakeUdpSocket : public UdpSocket {
22 class MockClient : public UdpSocket::Client {
24 MOCK_METHOD1(OnBound, void(UdpSocket*));
25 MOCK_METHOD2(OnError, void(UdpSocket*, Error));
26 MOCK_METHOD2(OnSendError, void(UdpSocket*, Error));
27 MOCK_METHOD2(OnReadInternal, void(UdpSocket*, const ErrorOr<UdpPacket>&));
29 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override { in OnRead()
/external/openscreen/cast/streaming/
Denvironment.cc23 ErrorOr<std::unique_ptr<UdpSocket>> result = in Environment()
24 UdpSocket::Create(task_runner_, this, local_endpoint); in Environment()
30 const_cast<std::unique_ptr<UdpSocket>&>(socket_) = std::move(result.value()); in Environment()
83 void Environment::OnBound(UdpSocket* socket) { in OnBound()
92 void Environment::OnError(UdpSocket* socket, Error error) { in OnError()
111 void Environment::OnSendError(UdpSocket* socket, Error error) { in OnSendError()
115 void Environment::OnRead(UdpSocket* socket, in OnRead()
Denvironment.h24 class Environment : public UdpSocket::Client {
133 void OnBound(UdpSocket* socket) final;
134 void OnError(UdpSocket* socket, Error error) final;
135 void OnSendError(UdpSocket* socket, Error error) final;
136 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet_or_error) final;
140 const std::unique_ptr<UdpSocket> socket_;
/external/openscreen/osp/impl/quic/
Dquic_connection_factory_impl.h30 void OnError(UdpSocket* socket, Error error) override;
31 void OnSendError(UdpSocket* socket, Error error) override;
32 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> packet) override;
51 std::vector<std::unique_ptr<UdpSocket>> sockets_;
55 UdpSocket* socket; // References one of the owned |sockets_|.
Dquic_connection_impl.h29 UdpTransport(UdpSocket* socket, const IPEndpoint& destination);
40 UdpSocket* socket() const { return socket_; } in socket()
43 UdpSocket* socket_;
79 void OnRead(UdpSocket* socket, ErrorOr<UdpPacket> data) override;
80 void OnError(UdpSocket* socket, Error error) override;
81 void OnSendError(UdpSocket* socket, Error error) override;
Dquic_connection_factory_impl.cc91 auto create_result = UdpSocket::Create(task_runner_, this, endpoint); in SetServerDelegate()
97 std::unique_ptr<UdpSocket> server_socket = std::move(create_result.value()); in SetServerDelegate()
103 void QuicConnectionFactoryImpl::OnRead(UdpSocket* socket, in OnRead()
115 [packet_ptr](const std::unique_ptr<UdpSocket>& s) { in OnRead()
151 auto create_result = UdpSocket::Create(task_runner_, this, endpoint); in Connect()
158 std::unique_ptr<UdpSocket> socket = std::move(create_result.value()); in Connect()
189 UdpSocket* const socket = entry->second.socket; in OnConnectionClosed()
200 [socket](const std::unique_ptr<UdpSocket>& s) { in OnConnectionClosed()
208 void QuicConnectionFactoryImpl::OnError(UdpSocket* socket, Error error) { in OnError()
212 void QuicConnectionFactoryImpl::OnSendError(UdpSocket* socket, Error error) { in OnSendError()
/external/openscreen/platform/base/
Dudp_packet.h18 class UdpSocket; variable
45 UdpSocket* socket() const { return socket_; } in socket()
46 void set_socket(UdpSocket* socket) { socket_ = socket; } in set_socket()
55 UdpSocket* socket_ = nullptr;
/external/openscreen/platform/impl/
Dudp_socket_posix.cc93 ErrorOr<std::unique_ptr<UdpSocket>> UdpSocket::Create( in Create()
122 std::unique_ptr<UdpSocket> socket = std::make_unique<UdpSocketPosix>( in Create()
141 case UdpSocket::Version::kV4: { in GetLocalEndpoint()
156 case UdpSocket::Version::kV6: { in GetLocalEndpoint()
193 case UdpSocket::Version::kV4: { in Bind()
205 case UdpSocket::Version::kV6: { in Bind()
233 case UdpSocket::Version::kV4: { in SetMulticastOutboundInterface()
248 case UdpSocket::Version::kV6: { in SetMulticastOutboundInterface()
269 case UdpSocket::Version::kV4: { in JoinMulticastGroup()
295 case UdpSocket::Version::kV6: { in JoinMulticastGroup()
[all …]

123