From a8163f083ee945c426014e0bd0025578cf418146 Mon Sep 17 00:00:00 2001
From: Sunil Nimmagadda <sunil@nimmagadda.net>
Date: Mon, 28 Nov 2022 15:42:07 +0530
Subject: Backed out changeset 50156c8f38b0

---
 src/main.rs | 43 +++++++++++++++++++++++++++++++++++++++++++
 1 file changed, 43 insertions(+)
 create mode 100644 src/main.rs

(limited to 'src/main.rs')

diff --git a/src/main.rs b/src/main.rs
new file mode 100644
index 0000000..7d31e24
--- /dev/null
+++ b/src/main.rs
@@ -0,0 +1,43 @@
+use tokio::signal::unix::{signal, SignalKind};
+use tokio::time;
+
+const ADV_INTERVAL: u64 = 3;
+const SKEW_INTERVAL: u64 = 1;
+
+async fn advert_handler() {
+    println!("3 second timer fired");
+}
+
+async fn skew_handler() {
+    println!("1 second timer fired");
+}
+
+async fn sighup_handler() {
+    println!("got SIGHUP");
+}
+
+#[tokio::main(flavor = "current_thread")]
+async fn main() {
+    let advert_handle = tokio::spawn(async move {
+        let mut advert_interval = time::interval(time::Duration::from_secs(ADV_INTERVAL));
+        loop {
+            advert_interval.tick().await;
+            advert_handler().await;
+        }
+    });
+    let skew_handle = tokio::spawn(async move {
+        let mut skew_interval = time::interval(time::Duration::from_secs(SKEW_INTERVAL));
+        loop {
+            skew_interval.tick().await;
+            skew_handler().await;
+        }
+    });
+    let sighup_handle = tokio::spawn(async move {
+        let mut stream = signal(SignalKind::hangup()).expect("Should be a signal stream");
+        loop {
+            stream.recv().await;
+            sighup_handler().await;
+        }
+    });
+    let (_, _, _) = tokio::join!(advert_handle, skew_handle, sighup_handle);
+}
-- 
cgit v1.2.3