print cache avg el

RCasatta · Oct 7, 2024 · 52a38c6 · 52a38c6
1 parent 6f45f00
commit 52a38c6
Show file tree

Hide file tree

Showing 2 changed files with 6 additions and 3 deletions.
diff --git a/src/threads/update_mempool_info.rs b/src/threads/update_mempool_info.rs
@@ -1,4 +1,4 @@
-use std::collections::{BTreeSet, HashSet};
+use std::collections::BTreeSet;
 use std::sync::Arc;
 use std::time::{Duration, Instant};
 

diff --git a/src/threads/zmq.rs b/src/threads/zmq.rs
@@ -38,8 +38,11 @@ async fn update_tx_zmq(socket: &SocketAddr, state: Arc<SharedState>) -> Result<(
             }
         }
         if count % 10_000 == 0 {
-            let cache_len = state.txs.lock().await.len();
-            log::info!("zmq received {count} txs, cache len: {cache_len}");
+            let (cache_len, cache_avg) = {
+                let c = state.txs.lock().await;
+                (c.len(), c.avg())
+            };
+            log::info!("zmq received {count} txs, (cache len: {cache_len}, avg: {cache_avg:.1})");
         }
     }
     Ok(())