Lines Matching refs:b_agent

450     let b_agent = Arc::new(Agent::new(cfg1).await?);  in test_connectivity_on_startup()  localVariable
451 b_agent.on_connection_state_change(b_notifier); in test_connectivity_on_startup()
455 let (b_ufrag, b_pwd) = b_agent.get_local_user_credentials().await; in test_connectivity_on_startup()
457 gather_and_exchange_candidates(&a_agent, &b_agent).await?; in test_connectivity_on_startup()
483 let _ = b_agent.dial(b_cancel_rx, a_ufrag, a_pwd).await?; in test_connectivity_on_startup()
558 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_connectivity_lite() localVariable
559 b_agent.on_connection_state_change(b_notifier); in test_connectivity_lite()
561 let _ = connect_with_vnet(&a_agent, &b_agent).await?; in test_connectivity_lite()
956 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_connection_state_callback() localVariable
1008 connect_with_vnet(&a_agent, &b_agent).await?; in test_connection_state_callback()
1020 b_agent.close().await?; in test_connection_state_callback()
1654 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_connection_state_failed_delete_all_candidates() localVariable
1668 connect_with_vnet(&a_agent, &b_agent).await?; in test_connection_state_failed_delete_all_candidates()
1683 b_agent.close().await?; in test_connection_state_failed_delete_all_candidates()
1708 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_connection_state_connecting_to_failed() localVariable
1738 b_agent.on_connection_state_change(connection_state_check(wf2, wc2)); in test_connection_state_connecting_to_failed()
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()
1976 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_close_in_connection_state_callback() localVariable
1996 connect_with_vnet(&a_agent, &b_agent).await?; in test_close_in_connection_state_callback()
2002 b_agent.close().await?; in test_close_in_connection_state_callback()
2033 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_run_task_in_connection_state_callback() localVariable
2047 connect_with_vnet(&a_agent, &b_agent).await?; in test_run_task_in_connection_state_callback()
2054 b_agent.close().await?; in test_run_task_in_connection_state_callback()
2085 let b_agent = Arc::new(Agent::new(cfg1).await?); in test_run_task_in_selected_candidate_pair_change_callback() localVariable
2111 connect_with_vnet(&a_agent, &b_agent).await?; in test_run_task_in_selected_candidate_pair_change_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
2166 b_agent.on_connection_state_change(Box::new(move |c: ConnectionState| { in test_lite_lifecycle()
2185 connect_with_vnet(&b_agent, &a_agent).await?; in test_lite_lifecycle()
2194 b_agent.close().await?; in test_lite_lifecycle()