Lines Matching refs:conn_map

27     let conn_map = UdpConnMap::new();  in test_udp_conn_map_insert_remove()  localVariable
38 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_insert_remove()
40 let conn_out = conn_map.find(&conn_in.local_addr()?).await; in test_udp_conn_map_insert_remove()
48 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_remove()
52 conn_map.delete(&conn_in.local_addr()?).await?; in test_udp_conn_map_insert_remove()
54 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_remove()
58 let result = conn_map.delete(&conn_in.local_addr()?).await; in test_udp_conn_map_insert_remove()
66 let conn_map = UdpConnMap::new(); in test_udp_conn_map_insert_0_remove() localVariable
77 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_insert_0_remove()
79 let conn_out = conn_map.find(&conn_in.local_addr()?).await; in test_udp_conn_map_insert_0_remove()
87 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_0_remove()
91 conn_map.delete(&conn_in.local_addr()?).await?; 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()
97 let result = conn_map.delete(&conn_in.local_addr()?).await; in test_udp_conn_map_insert_0_remove()
105 let conn_map = UdpConnMap::new(); in test_udp_conn_map_find_0() localVariable
116 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_find_0()
119 let conn_out = conn_map.find(&addr).await; in test_udp_conn_map_find_0()
125 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_find_0()
134 let conn_map = UdpConnMap::new(); in test_udp_conn_map_insert_many_ips_with_same_port() localVariable
151 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_insert_many_ips_with_same_port()
152 conn_map.insert(Arc::clone(&conn_in2)).await?; in test_udp_conn_map_insert_many_ips_with_same_port()
155 let conn_out1 = conn_map.find(&addr1).await; in test_udp_conn_map_insert_many_ips_with_same_port()
161 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_many_ips_with_same_port()
166 let conn_out2 = conn_map.find(&addr2).await; in test_udp_conn_map_insert_many_ips_with_same_port()
172 let port_map = conn_map.port_map.lock().await; in test_udp_conn_map_insert_many_ips_with_same_port()
181 let conn_map = UdpConnMap::new(); in test_udp_conn_map_already_inuse_when_insert_0() localVariable
197 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_already_inuse_when_insert_0()
198 let result = conn_map.insert(Arc::clone(&conn_in2)).await; in test_udp_conn_map_already_inuse_when_insert_0()
206 let conn_map = UdpConnMap::new(); in test_udp_conn_map_already_inuse_when_insert_a_specified_ip() localVariable
222 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
223 let result = conn_map.insert(Arc::clone(&conn_in2)).await; in test_udp_conn_map_already_inuse_when_insert_a_specified_ip()
231 let conn_map = UdpConnMap::new(); in test_udp_conn_map_already_inuse_when_insert_same_specified_ip() localVariable
247 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_already_inuse_when_insert_same_specified_ip()
248 let result = conn_map.insert(Arc::clone(&conn_in2)).await; in test_udp_conn_map_already_inuse_when_insert_same_specified_ip()
256 let conn_map = UdpConnMap::new(); in test_udp_conn_map_find_failure_1() localVariable
267 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_find_failure_1()
270 let result = conn_map.find(&addr).await; in test_udp_conn_map_find_failure_1()
278 let conn_map = UdpConnMap::new(); in test_udp_conn_map_find_failure_2() localVariable
289 conn_map.insert(Arc::clone(&conn_in)).await?; in test_udp_conn_map_find_failure_2()
292 let result = conn_map.find(&addr).await; in test_udp_conn_map_find_failure_2()
300 let conn_map = UdpConnMap::new(); in test_udp_conn_map_insert_two_on_same_port_then_remove() localVariable
316 conn_map.insert(Arc::clone(&conn_in1)).await?; in test_udp_conn_map_insert_two_on_same_port_then_remove()
317 conn_map.insert(Arc::clone(&conn_in2)).await?; in test_udp_conn_map_insert_two_on_same_port_then_remove()
319 conn_map.delete(&conn_in1.local_addr()?).await?; in test_udp_conn_map_insert_two_on_same_port_then_remove()
320 conn_map.delete(&conn_in2.local_addr()?).await?; in test_udp_conn_map_insert_two_on_same_port_then_remove()