Searched refs:WaitGroup (Results 1 – 18 of 18) sorted by relevance
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 5 use waitgroup::WaitGroup;
52 wg: Mutex::new(Some(WaitGroup::new())), in build_rr()
71 wg: Mutex::new(Some(WaitGroup::new())), in build_sr()
|
| /webrtc/ice/src/rand/ |
| H A D | rand_test.rs | 6 use waitgroup::WaitGroup;
37 let wg = WaitGroup::new(); in test_random_generator_collision()
|
| /webrtc/webrtc/src/dtls_transport/ |
| H A D | dtls_transport_test.rs | 15 use waitgroup::WaitGroup;
60 let offer_connection_has_failed = WaitGroup::new(); in test_invalid_fingerprint_causes_failed()
67 let answer_connection_has_failed = WaitGroup::new(); in test_invalid_fingerprint_causes_failed()
156 let wg = WaitGroup::new(); in run_test()
|
| /webrtc/interceptor/src/twcc/sender/ |
| H A D | sender_test.rs | 8 use waitgroup::WaitGroup;
19 let wg = WaitGroup::new(); in test_twcc_sender_interceptor()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_transport_test.rs | 12 use waitgroup::WaitGroup;
68 let peer_connection_connected = WaitGroup::new(); in test_ice_transport_get_selected_candidate_pair()
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport_test.rs | 6 use waitgroup::WaitGroup;
114 let wg = WaitGroup::new(); in test_conn_stats()
|
| H A D | agent_gather.rs | 18 use waitgroup::WaitGroup;
87 let wg = WaitGroup::new(); in gather_candidates_internal()
462 let wg = WaitGroup::new(); in gather_candidates_srflx_mapped()
589 let wg = WaitGroup::new(); in gather_candidates_srflx()
721 let wg = WaitGroup::new(); in gather_candidates_relay()
|
| H A D | agent_vnet_test.rs | 11 use waitgroup::WaitGroup;
360 let wg = WaitGroup::new(); in gather_and_exchange_candidates()
|
| H A D | agent_test.rs | 20 use waitgroup::{WaitGroup, Worker};
1710 let is_failed = WaitGroup::new(); in test_connection_state_connecting_to_failed()
1711 let is_checking = WaitGroup::new(); in test_connection_state_connecting_to_failed()
|
| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | mod.rs | 10 use waitgroup::WaitGroup;
94 let wg = WaitGroup::new(); in done()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 22 use waitgroup::WaitGroup;
79 wg: Mutex::new(Some(WaitGroup::new())), in build()
98 pub(crate) wg: Mutex<Option<WaitGroup>>,
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | rtp_receiver_test.rs | 16 use waitgroup::WaitGroup;
128 let wg = WaitGroup::new(); in test_set_rtp_parameters()
203 let wg = WaitGroup::new(); in test_rtp_receiver_set_read_deadline()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 15 use waitgroup::WaitGroup;
49 wg: Mutex::new(Some(WaitGroup::new())), in build()
79 wg: Mutex<Option<WaitGroup>>,
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 13 use waitgroup::WaitGroup;
26 pub(crate) wg: Mutex<Option<WaitGroup>>,
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 13 use waitgroup::WaitGroup;
64 pub(crate) wg: Mutex<Option<WaitGroup>>,
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | rtp_sender_test.rs | 16 use waitgroup::WaitGroup;
163 let peer_connections_connected = WaitGroup::new(); in test_rtp_sender_set_read_deadline()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_test.rs | 15 use waitgroup::WaitGroup;
247 wg: &WaitGroup, in until_connection_state() argument
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_test.rs | 28 use waitgroup::WaitGroup;
1017 let wg = WaitGroup::new(); in test_eof_detach()
|