Home
last modified time | relevance | path

Searched refs:done_tx (Results 1 – 25 of 39) sorted by relevance

12

/webrtc/webrtc/src/data_channel/
H A Ddata_channel_test.rs46 let (done_tx, done_rx) = mpsc::channel(1); in set_up_data_channel_parameters_test()
143 let done_tx = Arc::new(done_tx); in test_data_channel_open() localVariable
232 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_send_before_signaling() localVariable
281 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_send_after_connected() localVariable
385 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_parameters_max_packet_life_time_exchange() localVariable
434 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_parameters_max_retransmits_exchange() localVariable
479 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_parameters_protocol_exchange() localVariable
558 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_parameters_negotiated_exchange() localVariable
752 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_parameters_go() localVariable
836 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_data_channel_buffered_amount_set_before_open() localVariable
[all …]
/webrtc/dtls/examples/listen/verify/
H A Dlisten_verify.rs85 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
86 let mut done_tx = Some(done_tx); in main() localVariable
113 done_tx.take(); in main()
/webrtc/sctp/src/timer/
H A Dtimer_test.rs177 done_tx: Option<mpsc::Sender<SystemTime>>, field
186 done_tx: None, in default()
202 if let Some(done) = &self.done_tx { in on_retransmission_timeout()
211 if let Some(done) = &self.done_tx { in on_retransmission_failure()
358 let (done_tx, mut done_rx) = mpsc::channel(1); in test_rtx_timer_should_stop_after_rtx_failure()
365 done_tx: Some(done_tx), in test_rtx_timer_should_stop_after_rtx_failure()
407 let (done_tx, mut done_rx) = mpsc::channel(1); in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
415 done_tx: Some(done_tx), in test_rtx_timer_should_not_stop_if_max_retrans_is_zero()
460 let (done_tx, mut done_rx) = mpsc::channel(1); in test_rtx_timer_stop_timer_that_is_not_running_is_noop()
465 done_tx: Some(done_tx), in test_rtx_timer_stop_timer_that_is_not_running_is_noop()
/webrtc/examples/examples/data-channels-close/
H A Ddata-channels-close.rs114 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
126 let _ = done_tx.try_send(()); in main()
148 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
149 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in main() localVariable
153 let done_tx2 = Arc::clone(&done_tx); in main()
/webrtc/ice/src/agent/
H A Dagent_gather_test.rs154 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_vnet_gather_with_nat_1to1_as_host_candidates()
155 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_vnet_gather_with_nat_1to1_as_host_candidates() localVariable
158 let done_tx_clone = Arc::clone(&done_tx); in test_vnet_gather_with_nat_1to1_as_host_candidates()
271 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
272 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_vnet_gather_with_nat_1to1_as_srflx_candidates() localVariable
275 let done_tx_clone = Arc::clone(&done_tx); in test_vnet_gather_with_nat_1to1_as_srflx_candidates()
455 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_vnet_gather_muxed_udp()
456 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_vnet_gather_muxed_udp() localVariable
459 let done_tx_clone = Arc::clone(&done_tx); in test_vnet_gather_muxed_udp()
H A Dagent_internal.rs27 pub(crate) done_tx: Mutex<Option<mpsc::Sender<()>>>, field
90 let (done_tx, done_rx) = mpsc::channel(1); in new()
98 done_tx: Mutex::new(Some(done_tx)), in new()
615 let mut done_tx = self.done_tx.lock().await; in close() localVariable
616 if done_tx.is_none() { in close()
619 done_tx.take(); in close()
/webrtc/ice/src/mdns/
H A Dmdns_test.rs108 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_multicast_dns_static_host_name()
109 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_multicast_dns_static_host_name() localVariable
112 let done_tx_clone = Arc::clone(&done_tx); in test_multicast_dns_static_host_name()
/webrtc/examples/examples/rtp-to-webrtc/
H A Drtp-to-webrtc.rs123 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
125 let done_tx1 = done_tx.clone(); in main()
138 let done_tx2 = done_tx.clone(); in main()
189 let done_tx3 = done_tx.clone(); in main()
/webrtc/util/src/conn/
H A Dconn_udp_listener_test.rs194 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_listener_concurrent()
195 let mut done_tx = Some(done_tx); in test_listener_concurrent() localVariable
207 done_tx.take(); in test_listener_concurrent()
/webrtc/sctp/examples/
H A Dpong.rs79 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in main()
94 drop(done_tx); in main()
H A Dping.rs95 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in main()
105 drop(done_tx); in main()
/webrtc/examples/examples/play-from-disk-h264/
H A Dplay-from-disk-h264.rs141 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
142 let video_done_tx = done_tx.clone(); in main()
143 let audio_done_tx = done_tx.clone(); in main()
311 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/play-from-disk-vpx/
H A Dplay-from-disk-vpx.rs147 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
148 let video_done_tx = done_tx.clone(); in main()
149 let audio_done_tx = done_tx.clone(); in main()
322 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/insertable-streams/
H A Dinsertable-streams.rs120 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
121 let video_done_tx = done_tx.clone(); in main()
219 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/data-channels/
H A Ddata-channels.rs98 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
110 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/data-channels-create/
H A Ddata-channels-create.rs100 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
112 let _ = done_tx.try_send(()); in main()
/webrtc/webrtc/src/ice_transport/
H A Dice_gatherer.rs386 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_ice_gather_mdns_candidate_gathering()
387 let done_tx = Arc::new(Mutex::new(Some(done_tx))); in test_ice_gather_mdns_candidate_gathering() localVariable
389 let done_tx_clone = Arc::clone(&done_tx); in test_ice_gather_mdns_candidate_gathering()
/webrtc/examples/examples/data-channels-detach-create/
H A Ddata-channels-detach-create.rs112 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
124 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/data-channels-detach/
H A Ddata-channels-detach.rs110 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
122 let _ = done_tx.try_send(()); in main()
/webrtc/srtp/src/session/
H A Dsession_rtcp_test.rs193 let (done_tx, mut done_rx) = mpsc::channel::<()>(1); in test_session_srtcp_replay_protection()
213 drop(done_tx); in test_session_srtcp_replay_protection()
/webrtc/ice/examples/
H A Dping_pong.rs147 let (done_tx, done_rx) = watch::channel(()); in main()
394 let _ = done_tx.send(()); in main()
398 let _ = done_tx.send(()); in main()
/webrtc/examples/examples/simulcast/
H A Dsimulcast.rs211 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
223 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/reflect/
H A Dreflect.rs265 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
277 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/rtp-forwarder/
H A Drtp-forwarder.rs260 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel::<()>(1); in main()
272 let _ = done_tx.try_send(()); in main()
/webrtc/examples/examples/swap-tracks/
H A Dswap-tracks.rs207 let (done_tx, mut done_rx) = tokio::sync::mpsc::channel(1); in main()
219 let _ = done_tx.try_send(()); in main()

12