Searched refs:UdpConn (Results 1 – 8 of 8) sorted by relevance
| /webrtc/util/src/conn/ |
| H A D | conn_udp_listener.rs | 27 accept_ch_tx: Arc<Mutex<Option<mpsc::Sender<Arc<UdpConn>>>>>,
30 conns: Arc<Mutex<HashMap<String, Arc<UdpConn>>>>,
146 conns: Arc<Mutex<HashMap<String, Arc<UdpConn>>>>, in read_loop()
192 conns: &Arc<Mutex<HashMap<String, Arc<UdpConn>>>>, in get_udp_conn()
195 ) -> Result<Option<Arc<UdpConn>>> { in get_udp_conn() argument
235 pub struct UdpConn { struct
237 conns: Arc<Mutex<HashMap<String, Arc<UdpConn>>>>, argument
242 impl UdpConn { argument
245 conns: Arc<Mutex<HashMap<String, Arc<UdpConn>>>>, in new() argument
248 UdpConn { in new()
[all …]
|
| /webrtc/util/src/vnet/conn_map/ |
| H A D | conn_map_test.rs | 32 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_insert_remove()
71 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_insert_0_remove()
110 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_find_0()
139 let conn_in1 = Arc::new(UdpConn::new( in test_udp_conn_map_insert_many_ips_with_same_port()
145 let conn_in2 = Arc::new(UdpConn::new( in test_udp_conn_map_insert_many_ips_with_same_port()
186 let conn_in1 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_0()
191 let conn_in2 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_0()
211 let conn_in1 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
216 let conn_in2 = Arc::new(UdpConn::new( in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
261 let conn_in = Arc::new(UdpConn::new( in test_udp_conn_map_find_failure_1()
[all …]
|
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 5 use crate::vnet::conn::UdpConn;
13 type PortMap = Mutex<HashMap<u16, Vec<Arc<UdpConn>>>>;
27 pub(crate) async fn insert(&self, conn: Arc<UdpConn>) -> Result<()> { in insert()
52 pub(crate) async fn find(&self, addr: &SocketAddr) -> Option<Arc<UdpConn>> { in find() argument
|
| H A D | conn.rs | 30 pub(crate) struct UdpConn { struct
39 impl UdpConn { argument
47 UdpConn { in new()
63 impl Conn for UdpConn { implementation
|
| H A D | net.rs | 8 use crate::vnet::conn::{ConnObserver, UdpConn};
343 let conn = Arc::new(UdpConn::new(local_addr, None, v)); in bind()
|
| /webrtc/examples/examples/rtp-forwarder/ |
| H A D | rtp-forwarder.rs | 24 struct UdpConn { struct
152 UdpConn { in main()
163 UdpConn { in main()
|
| /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()
151 let conn = Arc::new(UdpConn::new(src_addr, Some(dst_addr), obs)); in test_udp_conn_send_recv()
|
| /webrtc/util/src/vnet/net/ |
| H A D | net_test.rs | 301 let conn = Arc::new(UdpConn::new(SocketAddr::new(ip, port), None, obs)); in test_net_virtual_assign_port()
|