Home
last modified time | relevance | path

Searched refs:a_agent (Results 1 – 7 of 7) sorted by relevance

/webrtc/ice/src/mdns/
H A Dmdns_test.rs24 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_multicast_dns_only_connection() localVariable
26 a_agent.on_connection_state_change(a_notifier); in test_multicast_dns_only_connection()
39 connect_with_vnet(&a_agent, &b_agent).await?; in test_multicast_dns_only_connection()
43 a_agent.close().await?; in test_multicast_dns_only_connection()
58 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_multicast_dns_mixed_connection() localVariable
60 a_agent.on_connection_state_change(a_notifier); in test_multicast_dns_mixed_connection()
73 connect_with_vnet(&a_agent, &b_agent).await?; in test_multicast_dns_mixed_connection()
77 a_agent.close().await?; in test_multicast_dns_mixed_connection()
/webrtc/ice/src/candidate/
H A Dcandidate_server_reflexive_test.rs59 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_server_reflexive_only_connection() localVariable
61 a_agent.on_connection_state_change(a_notifier); in test_server_reflexive_only_connection()
79 connect_with_vnet(&a_agent, &b_agent).await?; in test_server_reflexive_only_connection()
84 a_agent.close().await?; in test_server_reflexive_only_connection()
H A Dcandidate_relay_test.rs82 let a_agent = Arc::new(Agent::new(cfg0).await?); in test_relay_only_connection() localVariable
84 a_agent.on_connection_state_change(a_notifier); in test_relay_only_connection()
104 connect_with_vnet(&a_agent, &b_agent).await?; in test_relay_only_connection()
109 a_agent.close().await?; in test_relay_only_connection()
/webrtc/ice/src/agent/
H A Dagent_transport_test.rs23 let a_agent = Arc::new(Agent::new(cfg0).await?); in pipe() localVariable
24 a_agent.on_connection_state_change(a_notifier); in pipe()
37 let (a_conn, b_conn) = connect_with_vnet(&a_agent, &b_agent).await?; in pipe()
44 Ok((a_conn, b_conn, a_agent, b_agent)) in pipe()
H A Dagent_test.rs438 a_agent.on_connection_state_change(a_notifier); in test_connectivity_on_startup()
1008 connect_with_vnet(&a_agent, &b_agent).await?; in test_connection_state_callback()
1019 a_agent.close().await?; in test_connection_state_callback()
1682 a_agent.close().await?; in test_connection_state_failed_delete_all_candidates()
1740 let agent_a = Arc::clone(&a_agent); in test_connection_state_connecting_to_failed()
1761 a_agent.close().await?; in test_connection_state_connecting_to_failed()
1999 a_agent.close().await?; in test_close_in_connection_state_callback()
2053 a_agent.close().await?; in test_run_task_in_connection_state_callback()
2118 a_agent.close().await?; in test_run_task_in_selected_candidate_pair_change_callback()
2129 let a_agent = Arc::new( in test_lite_lifecycle() localVariable
[all …]
H A Dagent_vnet_test.rs248 a_agent: &Arc<Agent>, in connect_with_vnet()
252 let (a_ufrag, a_pwd) = a_agent.get_local_user_credentials().await; in connect_with_vnet()
255 gather_and_exchange_candidates(a_agent, b_agent).await?; in connect_with_vnet()
260 let agent_a = Arc::clone(a_agent); in connect_with_vnet()
310 let a_agent = Arc::new(Agent::new(cfg0).await?); in pipe_with_vnet() localVariable
311 a_agent.on_connection_state_change(a_notifier); in pipe_with_vnet()
357 a_agent: &Arc<Agent>, in gather_and_exchange_candidates()
363 a_agent.on_candidate(Box::new( in gather_and_exchange_candidates()
374 a_agent.gather_candidates()?; in gather_and_exchange_candidates()
392 let candidates = a_agent.get_local_candidates().await?; in gather_and_exchange_candidates()
[all …]
H A Dagent_gather_test.rs406 let a_agent = Agent::new(cfg0).await?; in test_vnet_gather_turn_connection_leak() localVariable
409 let agent_internal = Arc::clone(&a_agent.internal); in test_vnet_gather_turn_connection_leak()
419 a_agent.close().await?; in test_vnet_gather_turn_connection_leak()