Searched defs:tx (Results 1 – 10 of 10) sorted by relevance
195 let mut tx = callback_called_tx_clone.lock().await; in test_on_selected_candidate_pair_change() localVariable469 let mut tx = accepted_tx_clone.lock().await; in test_connectivity_on_startup() localVariable995 let mut tx = is_failed_tx_clone.lock().await; in test_connection_state_callback() localVariable1662 let mut tx = is_failed_tx_clone.lock().await; in test_connection_state_failed_delete_all_candidates() localVariable1829 let mut tx = cancel_tx_clone.lock().await; in test_agent_restart_one_side() localVariable1990 let mut tx = is_closed_tx_clone.lock().await; in test_close_in_connection_state_callback() localVariable2041 let mut tx = is_complete_tx_clone.lock().await; in test_run_task_in_connection_state_callback() localVariable2093 let mut tx = is_tested_tx_clone.lock().await; in test_run_task_in_selected_candidate_pair_change_callback() localVariable2105 let mut tx = is_complete_tx_clone.lock().await; in test_run_task_in_selected_candidate_pair_change_callback() localVariable2173 let mut tx = b_connected_tx_clone.lock().await; in test_lite_lifecycle() localVariable[all …]
161 let mut tx = done_tx_clone.lock().await; in test_vnet_gather_with_nat_1to1_as_host_candidates() localVariable278 let mut tx = done_tx_clone.lock().await; in test_vnet_gather_with_nat_1to1_as_srflx_candidates() localVariable462 let mut tx = done_tx_clone.lock().await; in test_vnet_gather_muxed_udp() localVariable
348 let mut tx = done_tx_clone.lock().await; in on_connected() localVariable
84 let tx = { in delete_allocations_by_username() localVariable122 let tx = { in get_allocations_info() localVariable223 let tx = { in close() localVariable
50 let tx = REMOTE_AUTH_CHANNEL.0.lock().await; in remote_handler() localVariable65 let tx = REMOTE_CAND_CHANNEL.0.lock().await; in remote_handler() localVariable
56 let mut tx = SDP_CHAN_TX_MUTEX.lock().await; in http_sdp_server() localVariable
115 let mut tx = done_tx_clone.lock().await; in test_multicast_dns_static_host_name() localVariable
350 let mut tx = gather_finished_tx_clone.lock().await; in test_new_ice_gatherer_success() localVariable393 let mut tx = done_tx_clone.lock().await; in test_ice_gather_mdns_candidate_gathering() localVariable
16 tx: mpsc::Sender<u32>, field
91 tx: mpsc::Sender<Message>, field385 tx: mpsc::Sender<Message>, field611 tx: mpsc::Sender<Message>, field707 tx: mpsc::Sender<Message>, field750 tx: mpsc::Sender<Message>, field