| /webrtc/dtls/examples/hub/src/ |
| H A D | lib.rs | 34 if let Some(remote_addr) = conn.remote_addr() { in register()
41 let _ = Hub::read_loop(conns, conn).await; in register()
47 conn: Arc<dyn Conn + Send + Sync>, in read_loop()
51 while let Ok(n) = conn.recv(&mut b).await { in read_loop()
56 Hub::unregister(conns, conn).await in read_loop()
61 conn: Arc<dyn Conn + Send + Sync>, in unregister()
63 if let Some(remote_addr) = conn.remote_addr() { in unregister()
69 if let Err(err) = conn.close().await { in unregister()
81 for conn in conns.values() { in broadcast()
82 if let Err(err) = conn.send(msg).await { in broadcast()
[all …]
|
| /webrtc/ice/src/udp_mux/ |
| H A D | mod.rs | 52 conn: Box<dyn Conn + Send + Sync>, field
56 pub fn new<C>(conn: C) -> Self in new()
61 conn: Box::new(conn), in new()
152 let conn = s in conn_from_stun_message() localVariable
158 conn in conn_from_stun_message()
169 let conn = &loop_self.params.conn; in start_conn_worker() localVariable
184 let conn = match conn { in start_conn_worker() localVariable
241 for (_, conn) in old_conns { in close()
242 conn.close(); in close()
313 let key = conn.key(); in register_conn_for_address()
[all …]
|
| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener_test.rs | 77 conn.connect(listener.addr().await?).await?; in test_listener_close_unaccepted()
78 conn.send(&[i]).await?; in test_listener_close_unaccepted()
79 conn.close().await?; in test_listener_close_unaccepted()
114 conn.send(packet).await?; in test_listener_accept_filter()
150 conn.close().await?; in test_listener_accept_filter()
172 conn.send(&[i]).await?; in test_listener_concurrent()
173 conn.close().await?; in test_listener_concurrent()
182 let n = conn.recv(&mut b).await?; in test_listener_concurrent()
191 conn.close().await?; in test_listener_concurrent()
199 Ok((conn, _raddr)) => { in test_listener_concurrent()
[all …]
|
| /webrtc/turn/src/relay/ |
| H A D | relay_range.rs | 62 let conn = self.net.bind(addr).await?; in allocate_conn() localVariable
63 let mut relay_addr = conn.local_addr()?; in allocate_conn()
65 return Ok((conn, relay_addr)); in allocate_conn()
74 let conn = match self.net.bind(addr).await { in allocate_conn() localVariable
75 Ok(conn) => conn, in allocate_conn()
79 let mut relay_addr = conn.local_addr()?; in allocate_conn()
81 return Ok((conn, relay_addr)); in allocate_conn()
|
| H A D | relay_none.rs | 35 let conn = self.net.bind(addr).await?; in allocate_conn() localVariable
36 let relay_addr = conn.local_addr()?; in allocate_conn()
37 Ok((conn, relay_addr)) in allocate_conn()
|
| H A D | relay_static.rs | 41 let conn = self.net.bind(addr).await?; in allocate_conn() localVariable
42 let mut relay_addr = conn.local_addr()?; in allocate_conn()
44 return Ok((conn, relay_addr)); in allocate_conn()
|
| /webrtc/turn/src/client/ |
| H A D | client_test.rs | 13 let conn = UdpSocket::bind("0.0.0.0:0").await?; in create_listening_test_client() localVariable
23 conn: Arc::new(conn), in create_listening_test_client()
34 let conn = UdpSocket::bind("0.0.0.0:0").await?; in create_listening_test_client_with_stun_serv() localVariable
44 conn: Arc::new(conn), 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() localVariable
139 let server_port = conn.local_addr()?.port(); in test_client_nonce_expiration()
143 conn, in test_client_nonce_expiration()
157 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_client_nonce_expiration() localVariable
167 conn, in test_client_nonce_expiration()
|
| /webrtc/turn/src/server/ |
| H A D | request.rs | 51 pub conn: Arc<dyn Conn + Send + Sync>, field
67 conn: Arc<dyn Conn + Send + Sync>, in new()
73 conn, in new()
211 &self.conn, in authenticate_request()
323 &self.conn, in handle_allocate_request()
359 &self.conn, in handle_allocate_request()
385 &self.conn, in handle_allocate_request()
414 &self.conn, in handle_allocate_request()
446 &self.conn, in handle_allocate_request()
476 Arc::clone(&self.conn), in handle_allocate_request()
[all …]
|
| H A D | server_test.rs | 47 let server_port = conn.local_addr()?.port(); in test_server_simple()
51 conn, in test_server_simple()
80 conn, in test_server_simple()
187 conn, in build_vnet()
234 conn: lconn, in test_server_vnet_send_binding_request()
271 conn: lconn, in test_server_vnet_echo_via_relay()
279 let conn = client.allocate().await?; in test_server_vnet_echo_via_relay() localVariable
280 let local_addr = conn.local_addr()?; in test_server_vnet_echo_via_relay()
282 log::debug!("laddr: {}", conn.local_addr()?); in test_server_vnet_echo_via_relay()
320 conn.send_to(b"Hello", echo_addr).await?; in test_server_vnet_echo_via_relay()
[all …]
|
| H A D | mod.rs | 62 let conn = p.conn; in new() localVariable
69 conn, in new()
144 conn: Arc<dyn Conn + Send + Sync>, in read_loop()
189 v = conn.recv_from(&mut buf) => { in read_loop()
202 conn: Arc::clone(&conn), in read_loop()
218 let _ = conn.close().await; in read_loop()
|
| /webrtc/util/src/vnet/conn/ |
| H A D | conn_test.rs | 64 let conn = Arc::new(UdpConn::new(src_addr, None, obs)); in test_udp_conn_send_to_recv_from() localVariable
68 dummy.read_ch_tx = conn.get_inbound_ch(); in test_udp_conn_send_to_recv_from()
71 let conn_rx = Arc::clone(&conn); in test_udp_conn_send_to_recv_from()
100 let n = conn.send_to(&data, dst_addr).await.unwrap(); in test_udp_conn_send_to_recv_from()
108 conn.close().await?; in test_udp_conn_send_to_recv_from()
151 let conn = Arc::new(UdpConn::new(src_addr, Some(dst_addr), obs)); in test_udp_conn_send_recv() localVariable
155 dummy.read_ch_tx = conn.get_inbound_ch(); in test_udp_conn_send_recv()
158 let conn_rx = Arc::clone(&conn); in test_udp_conn_send_recv()
185 let n = conn.send(&data).await.unwrap(); in test_udp_conn_send_recv()
193 conn.close().await?; in test_udp_conn_send_recv()
|
| /webrtc/turn/src/auth/ |
| H A D | auth_test.rs | 56 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in test_new_long_term_auth_handler() localVariable
57 let server_port = conn.local_addr()?.port(); in test_new_long_term_auth_handler()
61 conn, 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() localVariable
88 conn, in test_new_long_term_auth_handler()
|
| /webrtc/sctp/examples/ |
| H A D | throughput.rs | 5 use util::{conn::conn_disconnected_packet::DisconnectedPacketConn, Conn};
59 let conn = DisconnectedPacketConn::new(Arc::new( in main() localVariable
62 println!("listening {}...", conn.local_addr().unwrap()); in main()
65 net_conn: Arc::new(conn), in main()
106 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await.unwrap()); in main() localVariable
107 conn.connect(format!("127.0.0.1:{port2}")).await.unwrap(); in main()
111 net_conn: conn, in main()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_gather.rs | 283 Ok(conn) => conn, in gather_candidates_local()
314 conn: Some(conn), in gather_candidates_local()
430 let port = conn.local_addr()?.port(); in gather_candidates_local_udp_mux()
437 conn: Some(conn), in gather_candidates_local_udp_mux()
490 Ok(conn) => conn, in gather_candidates_srflx_mapped()
502 let laddr = conn.local_addr()?; in gather_candidates_srflx_mapped()
532 conn: Some(conn), in gather_candidates_srflx_mapped()
632 Ok(conn) => conn, in gather_candidates_srflx()
668 conn: Some(conn), in gather_candidates_srflx()
793 conn: loc_conn, in gather_candidates_relay()
[all …]
|
| /webrtc/stun/examples/ |
| H A D | stun_client.rs | 42 let conn = UdpSocket::bind("0:0").await?; in main() localVariable
43 println!("Local address: {}", conn.local_addr()?); in main()
46 conn.connect(server).await?; in main()
48 let mut client = ClientBuilder::new().with_conn(Arc::new(conn)).build()?; in main()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | mod.rs | 10 use dtls::conn::DTLSConn;
109 let conn = self.conn.lock().await; in conn() localVariable
110 conn.clone() in conn()
195 if let Some(conn) = self.conn().await { in start_srtp()
235 if let Some(conn) = self.conn().await { in start_srtp()
380 dtls::conn::DTLSConn::new( in start()
388 dtls::conn::DTLSConn::new( in start()
462 let mut conn = self.conn.lock().await; in start() localVariable
463 *conn = Some(Arc::new(dtls_conn)); in start()
523 if let Some(conn) = self.conn().await { in stop()
[all …]
|
| /webrtc/dtls/src/ |
| H A D | listener.rs | 2 use crate::conn::DTLSConn;
15 use util::{conn::conn_udp_listener::*, conn::*};
75 let (conn, raddr) = self.parent.accept().await?; in accept()
76 let dtls_conn = DTLSConn::new(conn, self.config.clone(), false, None) in accept()
|
| /webrtc/dtls/examples/dial/selfsign/ |
| H A D | dial_selfsign.rs | 7 use webrtc_dtls::{config::*, conn::DTLSConn, crypto::Certificate};
57 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main() localVariable
58 conn.connect(server).await?; in main()
71 Arc::new(DTLSConn::new(conn, config, true, None).await?); in main()
|
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 5 use crate::vnet::conn::UdpConn;
27 pub(crate) async fn insert(&self, conn: Arc<UdpConn>) -> Result<()> { in insert()
28 let addr = conn.local_addr()?; in insert()
45 conns.push(conn); in insert()
47 port_map.insert(addr.port(), vec![conn]); in insert()
|
| H A D | net.rs | 8 use crate::vnet::conn::{ConnObserver, UdpConn};
10 use crate::{conn, ifaces, Conn};
56 let read_ch_tx = conn.get_inbound_ch(); in write()
164 let read_ch_tx = conn.get_inbound_ch(); in on_inbound_chunk()
347 vi.udp_conns.insert(Arc::clone(&conn)).await?; in bind()
350 Ok(conn) in bind()
377 let conn = self.bind(loc_addr).await?; in dail() localVariable
378 conn.connect(rem_addr).await?; in dail()
380 Ok(conn) in dail()
551 conn.connect(remote_addr).await?; in dail()
[all …]
|
| /webrtc/ice/src/mdns/ |
| H A D | mod.rs | 7 use mdns::conn::*;
63 let conn = DnsConn::server( in create_multicast_dns() localVariable
70 Ok(Some(Arc::new(conn))) in create_multicast_dns()
|
| /webrtc/dtls/examples/dial/verify/ |
| H A D | dial_verify.rs | 8 use webrtc_dtls::{config::*, conn::DTLSConn};
58 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main() localVariable
59 conn.connect(server).await?; in main()
82 Arc::new(DTLSConn::new(conn, config, true, None).await?); in main()
|
| /webrtc/dtls/examples/dial/psk/ |
| H A D | dial_psk.rs | 8 use webrtc_dtls::{config::*, conn::DTLSConn};
58 let conn = Arc::new(UdpSocket::bind("0.0.0.0:0").await?); in main() localVariable
59 conn.connect(server).await?; in main()
73 Arc::new(DTLSConn::new(conn, config, true, None).await?); in main()
|
| /webrtc/ice/src/util/ |
| H A D | mod.rs | 49 conn: &Arc<dyn Conn + Send + Sync>, in get_xormapped_addr()
53 let resp = stun_request(conn, server_addr, deadline).await?; in get_xormapped_addr()
62 conn: &Arc<dyn Conn + Send + Sync>, in stun_request()
69 conn.send_to(&request.raw, server_addr).await?; in stun_request()
72 match tokio::time::timeout(deadline, conn.recv_from(&mut bs)).await { in stun_request()
80 conn.recv_from(&mut bs).await? in stun_request()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 62 let laddr = conn.local_addr()?; in test_net_native_bind()
79 let laddr = conn.local_addr()?; in test_net_native_dail()
97 let laddr = conn.local_addr()?; in test_net_native_loopback()
412 let laddr = conn.local_addr()?; in test_net_virtual_loopback1()
433 let laddr = conn.local_addr()?; in test_net_virtual_bind_specific_port()
451 let laddr = conn.local_addr()?; in test_net_virtual_dail_lo0()
483 let laddr = conn.local_addr()?; in test_net_virtual_dail_eth0()
524 let (conn, raddr) = { in test_net_virtual_resolver()
529 let laddr = conn.local_addr()?; in test_net_virtual_resolver()
558 let laddr = conn.local_addr()?; in test_net_virtual_loopback2()
[all …]
|