From 490234bbd44356da1cca0ad62b044e0cba70a226 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sat, 24 Oct 2026 06:09:22 +0200
Subject: add swarm stats

---
 src/swarm/peer.rs | 2 ++
 1 file changed, 2 insertions(+)

(limited to 'src/swarm/peer.rs')

diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs
index 3ceea3c..7a3eed8 100644
--- a/src/swarm/peer.rs
+++ b/src/swarm/peer.rs
@@ -492,6 +492,7 @@ pub(crate) async fn run_peer_worker(state: AppState) {
             apply_forget_records(&state).await;
             crate::swarm::members::ensure_registered(&state).await;
             crate::swarm::stability::tick(&state).await;
+            crate::swarm::stats::measure_saved_size(&state);
             {
                 let known = state.peer_states.read().await;
                 state.traffic.retain(|peer| known.contains_key(peer));
@@ -725,6 +726,7 @@ pub(crate) async fn handle_message(
     // we were down) says nothing about now; the peer answers our current HELLO.
     if let transport::ParsedMessage::HelloReply(reply) = &message {
         if reply.run_id != state.run_id {
+            state.stats.stale_hello_reply();
             debug!(peer = %peer, "Ignoring a HELLO_REPLY to a HELLO from an earlier run");
             return Ok(());
         }
-- 
cgit v1.3.1