From 0c74ee56c3b9f01afb3032aaed7b5d5f9952dc8b Mon Sep 17 00:00:00 2001 From: Herbert Wolverson Date: Thu, 18 Jul 2024 13:12:10 -0500 Subject: [PATCH] Ticker system isn't working - this is a push to add some diagnostics --- src/rust/lqosd/src/node_manager/ws/ticker.rs | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/src/rust/lqosd/src/node_manager/ws/ticker.rs b/src/rust/lqosd/src/node_manager/ws/ticker.rs index 62658372..329838c8 100644 --- a/src/rust/lqosd/src/node_manager/ws/ticker.rs +++ b/src/rust/lqosd/src/node_manager/ws/ticker.rs @@ -1,6 +1,6 @@ use std::sync::Arc; -use tokio::spawn; +use tokio::{join, spawn}; use crate::node_manager::ws::publish_subscribe::PubSub; mod cadence; mod throughput; @@ -21,9 +21,8 @@ pub use network_tree::{Circuit, all_circuits}; /// Runs a periodic tick to feed data to the node manager. pub(super) async fn channel_ticker(channels: Arc) { - let mc = channels.clone(); spawn(async move { one_second_cadence(mc) }); - let mc = channels.clone(); spawn(async move { two_second_cadence(mc) }); - let mc = channels.clone(); spawn(async move { five_second_cadence(mc) }); + log::info!("Starting channel tickers"); + join!(one_second_cadence(channels.clone()), two_second_cadence(channels.clone()), five_second_cadence(channels.clone())); } async fn one_second_cadence(channels: Arc) {