Home
last modified time | relevance | path

Searched refs:bind (Results 1 – 25 of 65) sorted by relevance

123

/webrtc/turn/src/allocation/
H A Dallocation_test.rs10 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/turn/src/allocation/allocation_manager/
H A Dallocation_manager_test.rs49 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()
342 let turn_socket: Arc<dyn Conn + Send + Sync> = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_delete_allocation_by_username()
403 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in create_server()
[all …]
/webrtc/turn/src/client/
H A Dclient_test.rs13 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/ice/src/udp_mux/
H A Dudp_mux_test.rs23 async fn bind(self) -> io::Result<UdpSocket> { in bind() method
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()
167 let remote_connection = Arc::new(network.bind().await?); in test_mux_connection()
/webrtc/turn/src/relay/
H A Drelay_range.rs62 let conn = self.net.bind(addr).await?; in allocate_conn()
74 let conn = match self.net.bind(addr).await { in allocate_conn()
H A Drelay_none.rs35 let conn = self.net.bind(addr).await?; in allocate_conn()
H A Drelay_static.rs41 let conn = self.net.bind(addr).await?; in allocate_conn()
/webrtc/turn/src/server/
H A Dserver_test.rs46 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()
183 let conn = net0.bind(SocketAddr::from_str("0.0.0.0:3478")?).await?; in build_vnet()
224 let lconn = v.netl0.bind(SocketAddr::from_str("0.0.0.0:0")?).await?; in test_server_vnet_send_binding_request()
261 let lconn = v.netl0.bind(SocketAddr::from_str("0.0.0.0:0")?).await?; in test_server_vnet_echo_via_relay()
284 let echo_conn = v.net1.bind(SocketAddr::from_str("1.2.3.5:5678")?).await?; in test_server_vnet_echo_via_relay()
/webrtc/util/src/conn/
H A Dconn_udp_listener_test.rs20 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()
/webrtc/turn/src/auth/
H A Dauth_test.rs56 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/sctp/examples/
H A Dthroughput.rs60 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 Dpong.rs61 let conn = DisconnectedPacketConn::new(Arc::new(UdpSocket::bind(host).await.unwrap())); in main()
/webrtc/util/src/vnet/
H A Dnet.rs323 pub(crate) async fn bind( in bind() method
377 let conn = self.bind(loc_addr).await?; in dail()
522 pub async fn bind(&self, addr: SocketAddr) -> Result<Arc<dyn Conn + Send + Sync>> { in bind() method
526 net.bind(addr).await in bind()
528 Net::Ifs(_) => Ok(Arc::new(UdpSocket::bind(addr).await?)), in bind()
550 let conn = UdpSocket::bind(local_addr).await?; in dail()
/webrtc/turn/examples/
H A Dturn_client_udp.rs77 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()
/webrtc/util/src/vnet/net/
H A Dnet_test.rs61 let conn = nw.bind(SocketAddr::from_str("127.0.0.1:0")?).await?; in test_net_native_bind()
96 let conn = nw.bind(SocketAddr::from_str("127.0.0.1:0")?).await?; in test_net_native_loopback()
411 let conn = nw.bind(SocketAddr::from_str("127.0.0.1:0")?).await?; in test_net_virtual_loopback1()
432 let conn = nw.bind(SocketAddr::from_str("127.0.0.1:50916")?).await?; in test_net_virtual_bind_specific_port()
557 let conn = nw.bind(SocketAddr::from_str("127.0.0.1:50916")?).await?; in test_net_virtual_loopback2()
684 let conn1 = net1.bind(SocketAddr::new(ip1, 1234)).await?; in test_net_virtual_end2end()
685 let conn2 = net2.bind(SocketAddr::new(ip2, 5678)).await?; in test_net_virtual_end2end()
818 net.bind(SocketAddr::new(Ipv4Addr::from_str(DEMO_IP)?.into(), 1234)) in test_net_virtual_two_ips_on_a_nic()
820 net.bind(SocketAddr::new(Ipv4Addr::from_str("1.2.3.5")?.into(), 1234)) in test_net_virtual_two_ips_on_a_nic()
/webrtc/webrtc/src/track/track_local/
H A Dtrack_local_static_sample.rs184 async fn bind(&self, t: &TrackLocalContext) -> Result<RTCRtpCodecParameters> { in bind() method
185 let codec = self.rtp_track.bind(t).await?; in bind()
/webrtc/ice/src/util/
H A Dmod.rs141 return Ok(vnet.bind(laddr).await?); in listen_udp_in_port_range()
153 match vnet.bind(laddr).await { in listen_udp_in_port_range()
/webrtc/stun/examples/
H A Dstun_client.rs42 let conn = UdpSocket::bind("0:0").await?; in main()
/webrtc/dtls/examples/dial/selfsign/
H A Ddial_selfsign.rs57 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main()
/webrtc/turn/src/allocation/channel_bind/
H A Dchannel_bind_test.rs11 let turn_socket = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in create_channel_bind()
/webrtc/dtls/examples/dial/verify/
H A Ddial_verify.rs58 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main()
/webrtc/dtls/examples/dial/psk/
H A Ddial_psk.rs58 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main()
/webrtc/turn/src/client/relay_conn/
H A Drelay_conn_test.rs76 RelayConnInternal::bind(rc_obs, bind_addr, bind_number, nonce, integrity).await in test_relay_conn()
/webrtc/ice/src/candidate/
H A Dcandidate_server_reflexive_test.rs29 let server_listener = Arc::new(UdpSocket::bind("127.0.0.1:0").await?); in test_server_reflexive_only_connection()
/webrtc/examples/examples/rtp-forwarder/
H A Drtp-forwarder.rs154 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()

123