| /webrtc/turn/src/client/ |
| H A D | periodic_timer.rs | 29 close_tx: Mutex<Option<mpsc::Sender<()>>>, field
38 close_tx: Mutex::new(None), in new()
49 let close_tx = self.close_tx.lock().await; in start() localVariable
50 if close_tx.is_some() { in start()
55 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
75 let mut close = self.close_tx.lock().await; in start()
76 *close = Some(close_tx); in start()
84 let mut close_tx = self.close_tx.lock().await; in stop() localVariable
85 close_tx.take(); in stop()
91 let close_tx = self.close_tx.lock().await; in is_running() localVariable
[all …]
|
| /webrtc/sctp/src/timer/ |
| H A D | ack_timer.rs | 19 pub(crate) close_tx: Option<mpsc::Sender<()>>, field
28 close_tx: None, in new()
35 if self.close_tx.is_some() { in start()
39 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
58 self.close_tx = Some(close_tx); in start()
65 self.close_tx.take(); in stop()
71 self.close_tx.is_some() in is_running()
|
| H A D | rtx_timer.rs | 110 pub(crate) close_tx: Arc<Mutex<Option<mpsc::Sender<()>>>>, field
126 close_tx: Arc::new(Mutex::new(None)), in new()
139 let mut close = self.close_tx.lock().await; in start()
144 let (close_tx, close_rx) = mpsc::channel(1); in start()
145 *close = Some(close_tx); in start()
151 let close_tx = Arc::clone(&self.close_tx); in start() localVariable
181 let mut close = close_tx.lock().await; in start()
196 let mut close_tx = self.close_tx.lock().await; in stop() localVariable
197 close_tx.take(); in stop()
203 let close_tx = self.close_tx.lock().await; in is_running() localVariable
[all …]
|
| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 39 let (close_tx, close_rx) = mpsc::channel(1); in build_rr()
53 close_tx: Mutex::new(Some(close_tx)), in build_rr()
58 let (close_tx, close_rx) = mpsc::channel(1); in build_sr()
72 close_tx: Mutex::new(Some(close_tx)), in build_sr()
|
| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | mod.rs | 43 close_tx: Option<mpsc::Sender<()>>, field
50 let (close_tx, close_rx) = mpsc::channel(1); in new()
61 close_tx: Some(close_tx), in new()
133 if let Some(close_tx) = &self.close_tx { in close()
134 close_tx.send(()).await?; in close()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 56 let (close_tx, close_rx) = mpsc::channel(1); in build()
80 close_tx: Mutex::new(Some(close_tx)), in build()
99 pub(crate) close_tx: Mutex<Option<mpsc::Sender<()>>>, field
109 let close_tx = self.close_tx.lock().await; in is_closed() localVariable
110 close_tx.is_none() in is_closed()
246 let mut close_tx = self.close_tx.lock().await; in close() localVariable
247 close_tx.take(); in close()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 33 let (close_tx, close_rx) = mpsc::channel(1); in build()
50 close_tx: Mutex::new(Some(close_tx)), in build()
80 close_tx: Mutex<Option<mpsc::Sender<()>>>, field
90 let close_tx = self.close_tx.lock().await; in is_closed() localVariable
91 close_tx.is_none() in is_closed()
248 let mut close_tx = self.close_tx.lock().await; in close() localVariable
249 close_tx.take(); in close()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 27 pub(crate) close_tx: Mutex<Option<mpsc::Sender<()>>>, field
40 let close_tx = self.close_tx.lock().await; in is_closed() localVariable
41 close_tx.is_none() in is_closed()
168 let mut close_tx = self.close_tx.lock().await; in close() localVariable
169 close_tx.take(); in close()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 65 pub(crate) close_tx: Mutex<Option<mpsc::Sender<()>>>, field
78 let close_tx = self.close_tx.lock().await; in is_closed() localVariable
79 close_tx.is_none() in is_closed()
210 let mut close_tx = self.close_tx.lock().await; in close() localVariable
211 close_tx.take(); in close()
|
| /webrtc/stun/src/ |
| H A D | client.rs | 37 close_tx: Option<mpsc::Sender<()>>, field
46 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
47 self.close_tx = Some(close_tx); in start()
68 if self.close_tx.is_none() { in close()
71 self.close_tx.take(); in close()
215 close_tx: Option<mpsc::Sender<()>>, field
372 self.close_tx.take(); //drop close channel in close()
386 let (close_tx, close_rx) = mpsc::channel(1); in run()
395 self.close_tx = Some(close_tx); in run()
|
| /webrtc/turn/src/server/ |
| H A D | mod.rs | 154 let (mut close_tx, mut close_rx) = oneshot::channel::<()>(); in read_loop()
198 _ = close_tx.closed() => break in read_loop()
|