Searched refs:reset_tx (Results 1 – 3 of 3) sorted by relevance
15 reset_tx: Option<mpsc::Sender<Duration>>, field25 reset_tx: None, in new()31 let (reset_tx, mut reset_rx) = mpsc::channel(1); in start()32 self.reset_tx = Some(reset_tx); in start()67 let expired = self.reset_tx.is_none() || self.timer_expired.load(Ordering::SeqCst); in stop()68 self.reset_tx.take(); in stop()73 if let Some(tx) = &self.reset_tx { in refresh()
18 reset_tx: Option<mpsc::Sender<Duration>>, field29 reset_tx: None, in new()35 let (reset_tx, mut reset_rx) = mpsc::channel(1); in start()36 self.reset_tx = Some(reset_tx); in start()73 let expired = self.reset_tx.is_none() || self.timer_expired.load(Ordering::SeqCst); in stop()74 self.reset_tx.take(); in stop()79 if let Some(tx) = &self.reset_tx { in refresh()
81 reset_tx: SyncMutex<Option<mpsc::Sender<Duration>>>, field113 reset_tx: SyncMutex::new(None), in new()267 let (reset_tx, mut reset_rx) = mpsc::channel(1); in start()268 self.reset_tx.lock().replace(reset_tx); in start()305 let reset_tx = self.reset_tx.lock().take(); in stop() localVariable306 reset_tx.is_none() || self.timer_expired.load(Ordering::SeqCst) in stop()311 let reset_tx = self.reset_tx.lock().clone(); in refresh() localVariable312 if let Some(tx) = reset_tx { in refresh()