From ab2303ce5cdc68157c2dc80bd87ca9ed8434d63e Mon Sep 17 00:00:00 2001
From: James Wilson <james@jsdw.me>
Date: Tue, 10 Aug 2021 16:49:04 +0100
Subject: [PATCH] more diagnostic logging

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

diff --git a/backend/telemetry_core/src/aggregator/inner_loop.rs b/backend/telemetry_core/src/aggregator/inner_loop.rs
index 4a1e314..bdb3c94 100644
--- a/backend/telemetry_core/src/aggregator/inner_loop.rs
+++ b/backend/telemetry_core/src/aggregator/inner_loop.rs
@@ -277,6 +277,11 @@ impl InnerLoop {
             .map(|c| c.len())
             .sum();
 
+        let num_messages_to_feeds = self.feed_channels
+            .values()
+            .map(|c| c.len())
+            .sum();
+
         println!("Periodic update at {:?}:", std::time::SystemTime::now());
         dbg!(node_ids);
         dbg!(node_count);
@@ -286,6 +291,7 @@ impl InnerLoop {
         dbg!(feed_to_chain);
         dbg!(num_subscribed_chains);
         dbg!(num_subscribed_chain_feeds);
+        dbg!(num_messages_to_feeds);
 
         drop(rx);
     }