Home
last modified time | relevance | path

Searched refs:AsyncUDPSocket (Results 1 – 21 of 21) sorted by relevance

/external/webrtc/rtc_base/
Dasync_udp_socket.cc32 AsyncUDPSocket* AsyncUDPSocket::Create(Socket* socket, in Create()
39 return new AsyncUDPSocket(owned_socket.release()); in Create()
42 AsyncUDPSocket* AsyncUDPSocket::Create(SocketFactory* factory, in Create()
50 AsyncUDPSocket::AsyncUDPSocket(Socket* socket) : socket_(socket) { in AsyncUDPSocket() function in rtc::AsyncUDPSocket
53 socket_->SignalReadEvent.connect(this, &AsyncUDPSocket::OnReadEvent); in AsyncUDPSocket()
54 socket_->SignalWriteEvent.connect(this, &AsyncUDPSocket::OnWriteEvent); in AsyncUDPSocket()
57 SocketAddress AsyncUDPSocket::GetLocalAddress() const { in GetLocalAddress()
61 SocketAddress AsyncUDPSocket::GetRemoteAddress() const { in GetRemoteAddress()
65 int AsyncUDPSocket::Send(const void* pv, in Send()
76 int AsyncUDPSocket::SendTo(const void* pv, in SendTo()
[all …]
Dasync_udp_socket.h31 class AsyncUDPSocket : public AsyncPacketSocket {
36 static AsyncUDPSocket* Create(Socket* socket,
40 static AsyncUDPSocket* Create(SocketFactory* factory,
42 explicit AsyncUDPSocket(Socket* socket);
43 ~AsyncUDPSocket() = default;
Dnat_server.h99 TransEntry(const SocketAddressPair& r, AsyncUDPSocket* s, NAT* nat);
106 AsyncUDPSocket* socket;
123 AsyncUDPSocket* udp_server_socket_;
Dasync_udp_socket_unittest.cc28 udp_socket_(new AsyncUDPSocket(socket_)), in AsyncUdpSocketTest()
40 std::unique_ptr<AsyncUDPSocket> udp_socket_;
Dnat_server.cc136 udp_server_socket_ = AsyncUDPSocket::Create(internal, internal_udp_addr); in NATServer()
215 AsyncUDPSocket* socket = AsyncUDPSocket::Create(external_, external_ip_); in Translate()
234 AsyncUDPSocket* s, in TransEntry()
Dvirtual_socket_unittest.cc60 socket(std::make_unique<AsyncUDPSocket>(s)), in Sender()
85 std::unique_ptr<AsyncUDPSocket> socket;
97 socket(std::make_unique<AsyncUDPSocket>(s)), in Receiver()
139 std::unique_ptr<AsyncUDPSocket> socket;
189 std::make_unique<AsyncUDPSocket>(socket), &fake_clock_); in TestDefaultSourceAddress()
197 std::make_unique<AsyncUDPSocket>(socket2), &fake_clock_); in TestDefaultSourceAddress()
220 std::make_unique<AsyncUDPSocket>(socket), &fake_clock_); in BasicTest()
223 std::make_unique<AsyncUDPSocket>(socket2), &fake_clock_); in BasicTest()
237 absl::WrapUnique(AsyncUDPSocket::Create(&ss_, empty)), &fake_clock_); in BasicTest()
820 std::make_unique<AsyncUDPSocket>(socket), &fake_clock_); in CrossFamilyDatagramTest()
[all …]
Dtest_client_unittest.cc47 TestClient client(std::make_unique<AsyncUDPSocket>(socket)); in TestUdpInternal()
Dsocket_unittest.cc963 absl::WrapUnique(AsyncUDPSocket::Create(socket_factory_, addr1))); in UdpInternal()
965 absl::WrapUnique(AsyncUDPSocket::Create(socket_factory_, empty))); in UdpInternal()
978 absl::WrapUnique(AsyncUDPSocket::Create(socket_factory_, empty))); in UdpInternal()
1005 absl::WrapUnique(AsyncUDPSocket::Create(socket_factory_, empty))); in UdpReadyToSend()
1126 absl::WrapUnique(AsyncUDPSocket::Create(socket_factory_, address))); in UdpSocketRecvTimestampUseRtcEpoch()
1128 absl::WrapUnique(AsyncUDPSocket::Create(socket_factory_, empty))); in UdpSocketRecvTimestampUseRtcEpoch()
Dthread_unittest.cc84 : socket_(AsyncUDPSocket::Create(socket, addr)), in SocketClient()
109 AsyncUDPSocket* socket_;
Dnat_unittest.cc56 absl::WrapUnique(AsyncUDPSocket::Create(factory, local_addr))); in CreateTestClient()
/external/webrtc/examples/stunserver/
Dstunserver_main.cc34 rtc::AsyncUDPSocket* server_socket = in main()
35 rtc::AsyncUDPSocket::Create(pthMain->socketserver(), server_addr); in main()
/external/webrtc/p2p/base/
Dtest_stun_server.cc21 rtc::AsyncUDPSocket* udp_socket = rtc::AsyncUDPSocket::Create(socket, addr); in Create()
Dstun_server.h33 explicit StunServer(rtc::AsyncUDPSocket* socket);
67 std::unique_ptr<rtc::AsyncUDPSocket> socket_;
Dstun_server_unittest.cc38 new StunServer(rtc::AsyncUDPSocket::Create(ss_.get(), server_addr))); in StunServerTest()
40 absl::WrapUnique(rtc::AsyncUDPSocket::Create(ss_.get(), client_addr)))); in StunServerTest()
Dtest_stun_server.h34 explicit TestStunServer(rtc::AsyncUDPSocket* socket) : StunServer(socket) {} in TestStunServer()
Dstun_server.cc22 StunServer::StunServer(rtc::AsyncUDPSocket* socket) : socket_(socket) { in StunServer()
Dtest_turn_server.h101 rtc::AsyncUDPSocket::Create(socket_factory_, int_addr), proto);
Dbasic_packet_socket_factory.cc51 return new AsyncUDPSocket(socket); in CreateUdpSocket()
/external/webrtc/examples/turnserver/
Dturnserver_main.cc75 rtc::AsyncUDPSocket* int_socket = in main()
76 rtc::AsyncUDPSocket::Create(&socket_server, int_addr); in main()
/external/webrtc/examples/androidvoip/jni/
Dandroid_voip_client.h178 std::unique_ptr<rtc::AsyncUDPSocket> rtp_socket_ RTC_GUARDED_BY(voip_thread_);
179 std::unique_ptr<rtc::AsyncUDPSocket> rtcp_socket_
Dandroid_voip_client.cc307 rtp_socket_.reset(rtc::AsyncUDPSocket::Create(voip_thread_->socketserver(), in StartSession()
318 rtcp_socket_.reset(rtc::AsyncUDPSocket::Create(voip_thread_->socketserver(), in StartSession()