Home
last modified time | relevance | path

Searched refs:b_agent (Results 1 – 6 of 6) sorted by relevance

/webrtc/ice/src/mdns/
H A Dmdns_test.rs35 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_multicast_dns_only_connection() localVariable
37 b_agent.on_connection_state_change(b_notifier); in test_multicast_dns_only_connection()
39 connect_with_vnet(&a_agent, &b_agent).await?; in test_multicast_dns_only_connection()
44 b_agent.close().await?; in test_multicast_dns_only_connection()
69 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_multicast_dns_mixed_connection() localVariable
71 b_agent.on_connection_state_change(b_notifier); in test_multicast_dns_mixed_connection()
73 connect_with_vnet(&a_agent, &b_agent).await?; in test_multicast_dns_mixed_connection()
78 b_agent.close().await?; in test_multicast_dns_mixed_connection()
/webrtc/ice/src/candidate/
H A Dcandidate_server_reflexive_test.rs75 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_server_reflexive_only_connection() localVariable
77 b_agent.on_connection_state_change(b_notifier); in test_server_reflexive_only_connection()
79 connect_with_vnet(&a_agent, &b_agent).await?; in test_server_reflexive_only_connection()
85 b_agent.close().await?; in test_server_reflexive_only_connection()
H A Dcandidate_relay_test.rs100 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_relay_only_connection() localVariable
102 b_agent.on_connection_state_change(b_notifier); in test_relay_only_connection()
104 connect_with_vnet(&a_agent, &b_agent).await?; in test_relay_only_connection()
110 b_agent.close().await?; in test_relay_only_connection()
/webrtc/ice/src/agent/
H A Dagent_transport_test.rs34 let b_agent = Arc::new(Agent::new(cfg1).await?); in pipe() localVariable
35 b_agent.on_connection_state_change(b_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.rs451 b_agent.on_connection_state_change(b_notifier); in test_connectivity_on_startup()
1008 connect_with_vnet(&a_agent, &b_agent).await?; in test_connection_state_callback()
1020 b_agent.close().await?; in test_connection_state_callback()
1683 b_agent.close().await?; in test_connection_state_failed_delete_all_candidates()
1749 let agent_b = Arc::clone(&b_agent); in test_connection_state_connecting_to_failed()
1762 b_agent.close().await?; in test_connection_state_connecting_to_failed()
2002 b_agent.close().await?; in test_close_in_connection_state_callback()
2054 b_agent.close().await?; in test_run_task_in_connection_state_callback()
2119 b_agent.close().await?; in test_run_task_in_selected_candidate_pair_change_callback()
2144 let b_agent = Arc::new( in test_lite_lifecycle() localVariable
[all …]
H A Dagent_vnet_test.rs249 b_agent: &Arc<Agent>, in connect_with_vnet()
253 let (b_ufrag, b_pwd) = b_agent.get_local_user_credentials().await; in connect_with_vnet()
255 gather_and_exchange_candidates(a_agent, b_agent).await?; in connect_with_vnet()
270 let b_conn = b_agent.dial(b_cancel_rx, a_ufrag, a_pwd).await?; in connect_with_vnet()
328 let b_agent = Arc::new(Agent::new(cfg1).await?); in pipe_with_vnet() localVariable
329 b_agent.on_connection_state_change(b_notifier); in pipe_with_vnet()
358 b_agent: &Arc<Agent>, in gather_and_exchange_candidates()
377 b_agent.on_candidate(Box::new( in gather_and_exchange_candidates()
388 b_agent.gather_candidates()?; in gather_and_exchange_candidates()
396 b_agent.add_remote_candidate(&c2)?; in gather_and_exchange_candidates()
[all …]