Searched refs:ufrag (Results 1 – 8 of 8) sorted by relevance
| /webrtc/ice/src/udp_mux/ |
| H A D | mod.rs | 45 async fn get_conn(self: Arc<Self>, ufrag: &str) -> Result<Arc<dyn Conn + Send + Sync>, Error>; in get_conn()
48 async fn remove_conn_by_ufrag(&self, ufrag: &str); in remove_conn_by_ufrag()
107 fn create_muxed_conn(self: &Arc<Self>, ufrag: &str) -> Result<UDPMuxConn, Error> { in create_muxed_conn()
112 key: ufrag.into(), in create_muxed_conn()
155 .and_then(|ufrag| conns.get(ufrag)) in conn_from_stun_message()
264 if let Some(conn) = conns.get(ufrag) { in get_conn()
270 let muxed_conn = self.create_muxed_conn(ufrag)?; in get_conn()
273 let cloned_ufrag = ufrag.to_string(); in get_conn()
281 conns.insert(ufrag.into(), muxed_conn.clone()); in get_conn()
287 async fn remove_conn_by_ufrag(&self, ufrag: &str) { in remove_conn_by_ufrag()
[all …]
|
| H A D | udp_mux_test.rs | 155 ufrag: &str, in test_mux_connection()
159 let conn = mux.get_conn(ufrag).await?; in test_mux_connection()
168 log::info!("Bound for ufrag: {}", ufrag); in test_mux_connection()
170 log::info!("Connected to {} for ufrag: {}", connect_addr, ufrag); in test_mux_connection()
|
| /webrtc/ice/src/agent/ |
| H A D | mod.rs | 339 let (ufrag, _) = self.get_local_user_credentials().await; in close()
340 udp_mux.remove_conn_by_ufrag(&ufrag).await; in close()
368 pub async fn restart(&self, mut ufrag: String, mut pwd: String) -> Result<()> { in restart()
369 if ufrag.is_empty() { in restart()
370 ufrag = generate_ufrag(); in restart()
376 if ufrag.len() * 8 < 24 { in restart()
401 ufrag_pwd.local_ufrag = ufrag; in restart()
|
| H A D | agent_gather.rs | 423 let ufrag = { in gather_candidates_local_udp_mux() localVariable
429 let conn = udp_mux.get_conn(&ufrag).await?; in gather_candidates_local_udp_mux()
|
| H A D | agent_test.rs | 1897 let (ufrag, pwd) = agent_b.get_local_user_credentials().await; in test_agent_restart_both_side()
1898 agent_a.set_remote_credentials(ufrag, pwd).await?; in test_agent_restart_both_side()
1900 let (ufrag, pwd) = agent_a.get_local_user_credentials().await; in test_agent_restart_both_side()
1901 agent_b.set_remote_credentials(ufrag, pwd).await?; in test_agent_restart_both_side()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | mod.rs | 338 let (ufrag, upwd) = agent.get_remote_user_credentials().await; in have_remote_credentials_change()
339 ufrag != new_ufrag || upwd != new_pwd in have_remote_credentials_change()
|
| /webrtc/webrtc/src/peer_connection/sdp/ |
| H A D | sdp_test.rs | 166 let (ufrag, pwd, _) = extract_ice_details(&s).await?; in test_extract_ice_details()
167 assert_eq!(ufrag, DEFAULT_UFRAG); in test_extract_ice_details()
190 let (ufrag, pwd, _) = extract_ice_details(&s).await?; in test_extract_ice_details()
191 assert_eq!(ufrag, DEFAULT_UFRAG); in test_extract_ice_details()
|
| H A D | mod.rs | 788 if let Some(ufrag) = desc.attribute("ice-ufrag") { in extract_ice_details()
789 remote_ufrags.push(ufrag.clone()); in extract_ice_details()
796 if let Some(ufrag) = m.attribute("ice-ufrag").and_then(|o| o) { in extract_ice_details()
797 remote_ufrags.push(ufrag.to_owned()); in extract_ice_details()
|