From 42d38d5d46f6d8850f97d5e90a82eb0ac7d3a2d1 Mon Sep 17 00:00:00 2001
From: tv <tv@krebsco.de>
Date: Sat, 24 Oct 2026 06:43:16 +0200
Subject: add throughput stats

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

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

diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs
index 7a3eed8..3b85539 100644
--- a/src/swarm/peer.rs
+++ b/src/swarm/peer.rs
@@ -496,6 +496,11 @@ pub(crate) async fn run_peer_worker(state: AppState) {
             {
                 let known = state.peer_states.read().await;
                 state.traffic.retain(|peer| known.contains_key(peer));
+                state
+                    .throughput
+                    .lock()
+                    .unwrap_or_else(|poisoned| poisoned.into_inner())
+                    .retain(|peer| known.contains_key(peer));
             }
             if let Some(change) = topology::refresh(&state).await {
                 apply_neighbour_change(&state, change).await;
-- 
cgit v1.3.1