Searched refs:find (Results 1 – 14 of 14) sorted by relevance
40 let conn_out = conn_map.find(&conn_in.local_addr()?).await; in test_udp_conn_map_insert_remove()79 let conn_out = conn_map.find(&conn_in.local_addr()?).await; in test_udp_conn_map_insert_0_remove()119 let conn_out = conn_map.find(&addr).await; in test_udp_conn_map_find_0()155 let conn_out1 = conn_map.find(&addr1).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()270 let result = conn_map.find(&addr).await; in test_udp_conn_map_find_failure_1()292 let result = conn_map.find(&addr).await; in test_udp_conn_map_find_failure_2()
46 let pos = raw.find(':'); in parse_uri()
54 pub(crate) fn find(&self, addr: &SocketAddr) -> Option<&Arc<Permission>> { in find() method
24 let (tr_raw, tr_to) = match tm.find(tr_key) { in on_rtx_timeout()254 pub fn find(&self, key: &str) -> Option<&Transaction> { in find() method
347 if tm.find(&tr_key).is_none() { in handle_stun_message()
214 let perm = if let Some(perm) = self.perm_map.find(&addr) { in send_to()
47 self.interfaces.iter().find(|ifc| ifc.name == ifc_name) in get_interface()55 if let Some(conn) = self.udp_conns.find(&c.destination_addr()).await { in write()163 if let Some(conn) = vi.udp_conns.find(&c.destination_addr()).await { in on_inbound_chunk()245 if vi.udp_conns.find(&addr).await.is_some() { in allocate_local_addr()337 if vi.udp_conns.find(&local_addr).await.is_some() { in bind()
52 pub(crate) async fn find(&self, addr: &SocketAddr) -> Option<Arc<UdpConn>> { in find() method
356 .find(|ext| ext.uri == extension.uri) in register_header_extension()547 .find(|(_, ext)| ext.uri == extension); in update_header_extension()706 .find(|(_, e)| e.uri == local_extension.uri) in get_rtp_parameters_by_kind()723 .find(|(_, e)| e.uri == local_extension.uri) in get_rtp_parameters_by_kind()735 let id = VALID_EXT_IDS.clone().find(|id| { in get_rtp_parameters_by_kind()
771 .find(|ext| ext.uri == "urn:3gpp:video-orientation") in test_extension_id_collision()
369 .find(|extension| extension.id == id) in set_extension()404 .find(|extension| extension.id == id) in get_extension()
146 let pos = raw.find(':'); in parse_url()
107 .find(|ext| &ext.uri == uri) in write_rtp_with_extensions()
53 track_details.iter().find(|x| x.ssrcs.contains(&ssrc)) in track_details_for_ssrc()60 track_details.iter().find(|x| x.rids.contains(&rid)) in track_details_for_rid()