| /webrtc/turn/src/allocation/ |
| H A D | allocation_test.rs | 6 use tokio::net::UdpSocket;
10 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_has_permission()
48 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_add_permission()
72 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_remove_permission()
105 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_add_channel_bind()
139 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_get_channel_by_number()
175 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_get_channel_by_addr()
207 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_remove_channel_bind()
244 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_allocation_refresh()
266 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_allocation_close()
|
| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener_test.rs | 7 use tokio::net::UdpSocket;
14 UdpSocket, in pipe()
20 let d_conn = UdpSocket::bind("0.0.0.0:0").await?; in pipe()
76 let conn = UdpSocket::bind("0.0.0.0:0").await?; in test_listener_close_unaccepted()
112 let conn = UdpSocket::bind("0.0.0.0:0").await?; in test_listener_accept_filter()
170 let conn = UdpSocket::bind("0.0.0.0:0").await?; in test_listener_concurrent()
|
| H A D | conn_udp.rs | 3 use tokio::net::UdpSocket;
6 impl Conn for UdpSocket { implementation
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 7 use tokio::net::UdpSocket;
13 let conn = UdpSocket::bind("0.0.0.0:0").await?; in create_listening_test_client()
34 let conn = UdpSocket::bind("0.0.0.0:0").await?; in create_listening_test_client_with_stun_serv()
138 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_client_nonce_expiration()
157 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_client_nonce_expiration()
|
| /webrtc/turn/src/auth/ |
| H A D | auth_test.rs | 46 use tokio::net::UdpSocket; in test_new_long_term_auth_handler()
56 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_new_long_term_auth_handler()
78 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_new_long_term_auth_handler()
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 20 use tokio::net::UdpSocket;
49 let turn_socket = UdpSocket::bind("127.0.0.1:0").await?; in test_packet_handler()
52 let client_listener = UdpSocket::bind("127.0.0.1:0").await?; in test_packet_handler()
83 let peer_listener1 = UdpSocket::bind("127.0.0.1:0").await?; in test_packet_handler()
84 let peer_listener2 = UdpSocket::bind("127.0.0.1:0").await?; in test_packet_handler()
172 let turn_socket: Arc<dyn Conn + Send + Sync> = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_create_allocation_duplicate_five_tuple()
207 let turn_socket: Arc<dyn Conn + Send + Sync> = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_delete_allocation()
243 let turn_socket: Arc<dyn Conn + Send + Sync> = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_allocation_timeout()
296 let turn_socket: Arc<dyn Conn + Send + Sync> = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_manager_close()
403 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in create_server()
[all …]
|
| /webrtc/ice/src/udp_mux/ |
| H A D | udp_mux_test.rs | 9 use tokio::net::UdpSocket;
23 async fn bind(self) -> io::Result<UdpSocket> { in bind() argument
25 Network::Ipv4 => UdpSocket::bind("0.0.0.0:0").await, in bind()
26 Network::Ipv6 => UdpSocket::bind("[::]:0").await, in bind()
60 let udp_socket = UdpSocket::bind((std::net::Ipv6Addr::UNSPECIFIED, 0)).await?; in test_udp_mux()
63 let udp_socket = UdpSocket::bind((std::net::Ipv4Addr::UNSPECIFIED, 0)).await?; in test_udp_mux()
|
| /webrtc/mdns/src/conn/ |
| H A D | mod.rs | 12 use tokio::net::{ToSocketAddrs, UdpSocket};
29 socket: Arc<UdpSocket>,
95 let socket = UdpSocket::from_std(socket.into())?; in server()
246 socket: Arc<UdpSocket>, in start() argument
294 socket: &Arc<UdpSocket>, in run() argument
383 socket: &Arc<UdpSocket>, in send_answer() argument
427 let socket = UdpSocket::bind("0.0.0.0:0").await?; in get_interface_addr_for_ip()
|
| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 9 use tokio::net::UdpSocket;
42 let conn = UdpSocket::bind("0:0").await?; in main()
|
| /webrtc/sctp/examples/ |
| H A D | throughput.rs | 4 use tokio::net::UdpSocket;
60 UdpSocket::bind(format!("127.0.0.1:{port1}")).await.unwrap(), in main()
106 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await.unwrap()); in main()
|
| H A D | pong.rs | 10 use tokio::net::UdpSocket;
61 let conn = DisconnectedPacketConn::new(Arc::new(UdpSocket::bind(host).await.unwrap())); in main()
|
| H A D | ping.rs | 10 use tokio::net::UdpSocket;
61 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await.unwrap()); in main()
|
| /webrtc/dtls/examples/dial/selfsign/ |
| H A D | dial_selfsign.rs | 4 use tokio::net::UdpSocket;
57 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main()
|
| /webrtc/turn/examples/ |
| H A D | turn_client_udp.rs | 6 use tokio::net::UdpSocket;
77 let conn = UdpSocket::bind("0.0.0.0:0").await?; in main()
127 let pinger_conn_tx = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in do_ping_test()
|
| H A D | turn_server_udp.rs | 11 use tokio::net::UdpSocket;
113 let conn = Arc::new(UdpSocket::bind(format!("0.0.0.0:{port}")).await?); in main()
|
| /webrtc/turn/src/allocation/channel_bind/ |
| H A D | channel_bind_test.rs | 5 use tokio::net::UdpSocket;
11 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in create_channel_bind()
|
| /webrtc/dtls/examples/dial/verify/ |
| H A D | dial_verify.rs | 5 use tokio::net::UdpSocket;
58 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main()
|
| /webrtc/dtls/examples/dial/psk/ |
| H A D | dial_psk.rs | 4 use tokio::net::UdpSocket;
58 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main()
|
| /webrtc/ice/src/candidate/ |
| H A D | candidate_server_reflexive_test.rs | 8 use tokio::net::UdpSocket;
29 let server_listener = Arc::new(UdpSocket::bind("127.0.0.1:0").await?); in test_server_reflexive_only_connection()
|
| H A D | candidate_relay_test.rs | 11 use tokio::net::UdpSocket;
50 let server_listener = Arc::new(UdpSocket::bind("127.0.0.1:0").await?); in test_relay_only_connection()
|
| /webrtc/turn/src/server/request/ |
| H A D | request_test.rs | 6 net::UdpSocket,
63 let l = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_allocation_lifetime_deletion_zero_lifetime()
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | rtp-forwarder.rs | 6 use tokio::net::UdpSocket;
154 let sock = UdpSocket::bind("127.0.0.1:0").await?; in main()
165 let sock = UdpSocket::bind("127.0.0.1:0").await?; in main()
|
| /webrtc/srtp/src/session/ |
| H A D | session_rtp_test.rs | 8 net::UdpSocket,
13 let ua = UdpSocket::bind("127.0.0.1:0").await?; in build_session_srtp_pair()
14 let ub = UdpSocket::bind("127.0.0.1:0").await?; in build_session_srtp_pair()
|
| /webrtc/examples/examples/rtp-to-webrtc/ |
| H A D | rtp-to-webrtc.rs | 5 use tokio::net::UdpSocket;
187 let listener = UdpSocket::bind("127.0.0.1:5004").await?; in main()
|
| /webrtc/turn/src/server/ |
| H A D | server_test.rs | 11 use tokio::net::UdpSocket;
46 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_server_simple()
70 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_server_simple()
|