Update summary stats

helius-labs · May 15, 2024 · 5126f22 · 5126f22
1 parent 5edada1
commit 5126f22
Show file tree

Hide file tree

Showing 2 changed files with 13 additions and 3 deletions.
diff --git a/validator-firewall/src/main.rs b/validator-firewall/src/main.rs
@@ -15,7 +15,7 @@ use log::{debug, info, warn};
 use serde::Deserialize;
 use solana_rpc_client::nonblocking::rpc_client::RpcClient;
 use std::collections::HashSet;
-use std::net::{Ipv4Addr};
+use std::net::Ipv4Addr;
 use std::path::PathBuf;
 use std::sync::atomic::AtomicBool;
 use std::sync::Arc;

diff --git a/validator-firewall/src/stats_service.rs b/validator-firewall/src/stats_service.rs
@@ -45,7 +45,12 @@ impl StatsService {
                 all_sum += total;
                 info!("total_packets: {:?} = {:?}", native_addr, total);
             }
-            info!("All traffic summary: {} pkts {} pkts/s", all_sum, (all_sum - all_last_sum) / all_las_eval_time.elapsed().as_secs());
+            info!(
+                "All traffic summary: {} pkts last_interval {} pkts {} pkts/s",
+                all_sum,
+                all_sum - all_last_sum,
+                (all_sum - all_last_sum) / all_las_eval_time.elapsed().as_secs().max(1)
+            );
             all_last_sum = all_sum;
             all_las_eval_time = std::time::Instant::now();
 
@@ -56,7 +61,12 @@ impl StatsService {
                 blocked_sum += total;
                 info!("dropped_packets: {:?} = {:?}", native_addr, total);
             }
-            info!("Blocked traffic summary: {} pkts {} pkts/s", blocked_sum, (blocked_sum - blocked_last_sum) / blocked_las_eval_time.elapsed().as_secs());
+            info!(
+                "Blocked traffic summary: {} pkts last_interval {} pkts {} pkts/s",
+                blocked_sum,
+                blocked_sum - blocked_last_sum,
+                (blocked_sum - blocked_last_sum) / blocked_las_eval_time.elapsed().as_secs().max(1)
+            );
             blocked_last_sum = blocked_sum;
             blocked_las_eval_time = std::time::Instant::now();