Searched refs:awake_write_loop_ch (Results 1 – 3 of 3) sorted by relevance
| /webrtc/sctp/src/association/ |
| H A D | mod.rs | 205 awake_write_loop_ch: Arc<mpsc::Sender<()>>, field
263 let _ = self.awake_write_loop_ch.try_send(()); in shutdown()
294 let awake_write_loop_ch = Arc::new(awake_write_loop_ch_tx); in new() localVariable
301 Arc::clone(&awake_write_loop_ch), in new()
411 awake_write_loop_ch, in new()
484 mut awake_write_loop_ch: mpsc::Receiver<()>, in write_loop()
546 _ = awake_write_loop_ch.recv() =>{} in write_loop()
|
| H A D | association_internal.rs | 18 awake_write_loop_ch: Option<Arc<mpsc::Sender<()>>>, field
100 awake_write_loop_ch: Arc<mpsc::Sender<()>>, in new()
150 awake_write_loop_ch: Some(awake_write_loop_ch), in new()
293 if let Some(awake_write_loop_ch) = &self.awake_write_loop_ch { in awake_write_loop()
294 let _ = awake_write_loop_ch.try_send(()); in awake_write_loop()
1042 self.awake_write_loop_ch.clone(), in create_stream()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 71 pub(crate) awake_write_loop_ch: Option<Arc<mpsc::Sender<()>>>, field
96 .field("awake_write_loop_ch", &self.awake_write_loop_ch) in fmt()
120 awake_write_loop_ch: Option<Arc<mpsc::Sender<()>>>, in new()
127 awake_write_loop_ch, in new()
485 if let Some(awake_write_loop_ch) = &self.awake_write_loop_ch { in awake_write_loop()
486 let _ = awake_write_loop_ch.try_send(()); in awake_write_loop()
|