From b97aec99a8639bf110418389602837581087ad6e Mon Sep 17 00:00:00 2001
From: James Wilson <james@jsdw.me>
Date: Mon, 9 Aug 2021 16:38:23 +0100
Subject: [PATCH] monitoring queue len

---
 backend/telemetry_core/src/aggregator/inner_loop.rs | 6 ++++--
 1 file changed, 4 insertions(+), 2 deletions(-)

diff --git a/backend/telemetry_core/src/aggregator/inner_loop.rs b/backend/telemetry_core/src/aggregator/inner_loop.rs
index 1b6e0fe..4715c9e 100644
--- a/backend/telemetry_core/src/aggregator/inner_loop.rs
+++ b/backend/telemetry_core/src/aggregator/inner_loop.rs
@@ -197,9 +197,11 @@ impl InnerLoop {
         // TEMP: let's monitor message queue len out of interest
         let tx_len = metered_tx.clone();
         tokio::spawn(async move {
+            let mut n = 0;
             loop {
-                println!("Queue len: {}", tx_len.len());
-                tokio::time::sleep(tokio::time::Duration::from_secs(1)).await
+                println!("#{} Queue len: {}", n, tx_len.len());
+                n += 1;
+                tokio::time::sleep(tokio::time::Duration::from_millis(500)).await;
             }
         });