Searched refs:worker (Results 1 – 13 of 13) sorted by relevance
40 let w = wg.worker(); in test_random_generator_collision()
104 let w = wg.worker(); in gather_candidates_internal()126 let w1 = wg.worker(); in gather_candidates_internal()142 let w2 = wg.worker(); in gather_candidates_internal()155 let w = wg.worker(); in gather_candidates_internal()474 let w = wg.worker(); in gather_candidates_srflx_mapped()602 let w = wg.worker(); in gather_candidates_srflx()748 let w = wg.worker(); in gather_candidates_relay()
116 let w = wg.worker(); in test_conn_stats()
362 let w1 = Arc::new(Mutex::new(Some(wg.worker()))); in gather_and_exchange_candidates()376 let w2 = Arc::new(Mutex::new(Some(wg.worker()))); in gather_and_exchange_candidates()
1734 let (wf1, wc1) = (is_failed.worker(), is_checking.worker()); in test_connection_state_connecting_to_failed()1737 let (wf2, wc2) = (is_failed.worker(), is_checking.worker()); in test_connection_state_connecting_to_failed()
21 let w = wg.worker(); in test_twcc_sender_interceptor()
250 let w = Arc::new(Mutex::new(Some(wg.worker()))); in until_connection_state()255 let mut worker = w2.lock().await; in until_connection_state() localVariable256 worker.take(); in until_connection_state()
95 let mut w = Some(wg.worker()); in done()
111 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()
153 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()
187 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()
177 wait_group.as_ref().map(|wg| wg.worker()) in bind_rtcp_writer()
1048 let w = wg.worker(); in test_eof_detach()1088 let w = wg.worker(); in test_eof_detach()