| /webrtc/turn/src/allocation/ |
| H A D | permission.rs | 41 let mut done = false; in start() localVariable
43 while !done { in start()
50 done = true; in start()
56 done = true; in start()
|
| H A D | channel_bind.rs | 45 let mut done = false; in start() localVariable
47 while !done { in start()
56 done = true; in start()
62 done = true; in start()
|
| H A D | mod.rs | 277 let mut done = false; in start() localVariable
279 while !done { in start()
288 done = true; in start()
294 done = true; in start()
|
| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | operation_test.rs | 27 ops.done().await; in test_operations_enqueue()
44 ops.done().await; in test_operations_done()
|
| H A D | mod.rs | 93 pub(crate) async fn done(&self) { in done() method
|
| /webrtc/dtls/src/ |
| H A D | handshaker.rs | 312 done = self.handshake_rx.recv() =>{ in wait()
313 if done.is_none() { in wait()
320 drop(done); in wait()
372 done = self.handshake_rx.recv() =>{ in finish()
373 if done.is_none() { in finish()
378 drop(done); in finish()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | rtp_receiver_test.rs | 121 let mut done = seen_packet_tx2.lock().await; in test_set_rtp_parameters() localVariable
122 done.take(); in test_set_rtp_parameters()
197 let mut done = seen_packet_tx2.lock().await; in test_rtp_receiver_set_read_deadline() localVariable
198 done.take(); in test_rtp_receiver_set_read_deadline()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | data_channel_test.rs | 237 done.take(); in test_data_channel_send_before_signaling()
300 done.take(); in test_data_channel_send_after_connected()
404 done.take(); in test_data_channel_parameters_max_packet_life_time_exchange()
448 done.take(); in test_data_channel_parameters_max_retransmits_exchange()
496 done.take(); in test_data_channel_parameters_protocol_exchange()
582 done.take(); in test_data_channel_parameters_negotiated_exchange()
612 done.take(); in test_data_channel_event_handlers()
621 done.take(); in test_data_channel_event_handlers()
771 done.take(); in test_data_channel_parameters_go()
855 done.take(); in test_data_channel_buffered_amount_set_before_open()
[all …]
|
| /webrtc/ice/src/agent/ |
| H A D | agent_transport.rs | 90 pub(crate) done: AtomicBool, field
104 done: AtomicBool::new(false), in new()
171 if self.done.load(Ordering::SeqCst) { in recv()
197 if self.done.load(Ordering::SeqCst) { in send()
|
| H A D | agent_internal.rs | 644 self.agent_conn.done.store(true, Ordering::SeqCst); in close()
|
| /webrtc/turn/src/client/ |
| H A D | transaction.rs | 174 let mut done = false; in start_rtx_timer() localVariable
175 while !done { in start_rtx_timer()
192 done = on_rtx_timeout(&conn, &tr_map, &key, rtx + 1).await; in start_rtx_timer()
194 _ = timer_ch_rx.recv() => done = true, in start_rtx_timer()
|
| /webrtc/examples/examples/ortc/ |
| H A D | ortc.rs | 98 let done = Arc::new(Notify::new()); in main() localVariable
99 let done_answer = done.clone(); in main()
100 let done_offer = done.clone(); in main()
232 done.notify_waiters(); in main()
|
| /webrtc/webrtc/src/ice_transport/ |
| H A D | ice_transport_test.rs | 29 let mut done = ice_complete_tx2.lock().await; in test_ice_transport_on_selected_candidate_pair_change() localVariable
30 done.take(); in test_ice_transport_on_selected_candidate_pair_change()
|
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 433 let mut done = false; in read_loop() localVariable
435 while !done { in read_loop()
463 done = true; in read_loop()
487 let done = Arc::new(AtomicBool::new(false)); in write_loop() localVariable
502 while !done.load(Ordering::Relaxed) { in write_loop()
517 let done2 = Arc::clone(&done); in write_loop()
548 done.store(true, Ordering::Relaxed); in write_loop()
|
| H A D | association_internal.rs | 2001 let mut done = false; in get_data_packets_to_retransmit() localVariable
2003 while !done { in get_data_packets_to_retransmit()
2013 done = true; in get_data_packets_to_retransmit()
|
| /webrtc/util/src/vnet/ |
| H A D | router.rs | 99 done: Option<mpsc::Sender<()>>, // requires mutex [x] field
301 if self.done.is_some() { in start()
307 self.done = Some(done_tx); in start()
351 if self.done.is_none() { in stop()
355 self.done.take(); in stop()
412 if self.done.is_some() { in push()
|
| /webrtc/sctp/src/timer/ |
| H A D | timer_test.rs | 202 if let Some(done) = &self.done_tx { in on_retransmission_timeout()
204 let _ = done.send(elapsed).await; in on_retransmission_timeout()
211 if let Some(done) = &self.done_tx { in on_retransmission_failure()
215 let _ = done.send(elapsed).await; in on_retransmission_failure()
|
| /webrtc/examples/examples/data-channels-close/ |
| H A D | data-channels-close.rs | 155 let mut done = done_tx2.lock().await; in main() localVariable
156 done.take(); in main()
|
| /webrtc/data/ |
| H A D | CHANGELOG.md | 23 * [#16 [PollDataChannel] reset shutdown_fut future after done](https://github.com/webrtc-rs/data/pu…
|
| /webrtc/webrtc/src/track/track_local/ |
| H A D | track_local_static_test.rs | 265 let mut done = on_track_fired_tx2.lock().await; in test_track_local_static_payload_type() localVariable
266 done.take(); in test_track_local_static_payload_type()
|
| /webrtc/webrtc/src/peer_connection/ |
| H A D | peer_connection_test.rs | 277 let mut done = ice_complete_tx2.lock().await; in test_get_stats() localVariable
278 done.take(); in test_get_stats()
|
| H A D | mod.rs | 2057 let done = Arc::new(Mutex::new(Some(gathering_complete_tx))); in gathering_complete_promise() localVariable
2058 let done2 = Arc::clone(&done); in gathering_complete_promise()
2070 let mut d = done.lock().await; in gathering_complete_promise()
|
| /webrtc/sctp/ |
| H A D | CHANGELOG.md | 11 * The lock for the internal association was contended badly because marshaling was done while still…
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | rtp_transceiver_test.rs | 305 offer_pc.internal.ops.done().await; in test_rtp_transceiver_set_direction_causing_negotiation()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 814 done = handle_queue_rx.recv() => { in read_and_buffer()
820 drop(done); in read_and_buffer()
|