imp(timer): empty implementation for epoll/kqueue

grafana · Jan 10, 2022 · 09e3de9 · 09e3de9
1 parent f759478
commit 09e3de9
Show file tree

Hide file tree

Showing 2 changed files with 24 additions and 0 deletions.
diff --git a/src/timer/epoll.rs b/src/timer/epoll.rs
@@ -23,11 +23,23 @@ impl Timer {
         self
     }
 
+    /// Attach an mpsc::Sender to Timer
+    ///
+    /// Timer will dispatch an event with the timestamp of the current instant,
+    /// every 10th second to all attached senders
     pub fn attach_listener(&mut self, tx: Sender<u64>) -> Result<()> {
+        // Push Sender to a Vector of Sender(s)
+        let txs = Arc::clone(&self.txs);
+        txs.lock()?.push(tx);
+
         Ok(())
     }
 
+    /// Clear the listeners (txs) from Timer. This will shutdown the Timer thread
     pub fn drop_listeners(&mut self) -> Result<()> {
+        let txs = Arc::clone(&self.txs);
+        txs.lock()?.clear();
+
         Ok(())
     }
 }
diff --git a/src/timer/kqueue.rs b/src/timer/kqueue.rs
@@ -23,11 +23,23 @@ impl Timer {
         self
     }
 
+    /// Attach an mpsc::Sender to Timer
+    ///
+    /// Timer will dispatch an event with the timestamp of the current instant,
+    /// every 10th second to all attached senders
     pub fn attach_listener(&mut self, tx: Sender<u64>) -> Result<()> {
+        // Push Sender to a Vector of Sender(s)
+        let txs = Arc::clone(&self.txs);
+        txs.lock()?.push(tx);
+
         Ok(())
     }
 
+    /// Clear the listeners (txs) from Timer. This will shutdown the Timer thread
     pub fn drop_listeners(&mut self) -> Result<()> {
+        let txs = Arc::clone(&self.txs);
+        txs.lock()?.clear();
+
         Ok(())
     }
 }