Searched refs:port_map (Results 1 – 2 of 2) sorted by relevance
| /webrtc/util/src/vnet/ |
| H A D | conn_map.rs | 17 port_map: PortMap, field
23 port_map: Mutex::new(HashMap::new()), in new()
30 let mut port_map = self.port_map.lock().await; in insert() localVariable
31 if let Some(conns) = port_map.get(&addr.port()) { in insert()
47 port_map.insert(addr.port(), vec![conn]); in insert()
53 let port_map = self.port_map.lock().await; in find() localVariable
81 let mut port_map = self.port_map.lock().await; in delete() localVariable
103 port_map.remove(&addr.port()); in delete()
105 port_map.insert(addr.port(), new_conns); in delete()
112 let port_map = self.port_map.lock().await; in len() localVariable
[all …]
|
| /webrtc/util/src/vnet/conn_map/ |
| H A D | conn_map_test.rs | 48 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_remove() localVariable
49 assert_eq!(port_map.len(), 1, "should match"); in test_udp_conn_map_insert_remove()
54 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_remove() localVariable
55 assert_eq!(port_map.len(), 0, "should match"); in test_udp_conn_map_insert_remove()
87 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_0_remove() localVariable
88 assert_eq!(port_map.len(), 1, "should match"); in test_udp_conn_map_insert_0_remove()
93 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_0_remove() localVariable
94 assert_eq!(port_map.len(), 0, "should match"); in test_udp_conn_map_insert_0_remove()
125 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_find_0() localVariable
161 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_many_ips_with_same_port() localVariable
[all …]
|