aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer/worker.rs
diff options
context:
space:
mode:
authortv <tv@krebsco.de>2026-11-06 04:33:45 +0100
committertv <tv@krebsco.de>2026-11-06 04:33:45 +0100
commitde30fc105bbb9c610c847f64e00cd2555ca0c63c (patch)
tree2b13361744eda5ba7606c18da5574744e4265668 /src/swarm/peer/worker.rs
parent26ff4ff86b58fed130ce6802ac4aceba8ee93443 (diff)
rtt table pruned
Diffstat (limited to 'src/swarm/peer/worker.rs')
-rw-r--r--src/swarm/peer/worker.rs1
1 files changed, 1 insertions, 0 deletions
diff --git a/src/swarm/peer/worker.rs b/src/swarm/peer/worker.rs
index b5c533a..7a0b502 100644
--- a/src/swarm/peer/worker.rs
+++ b/src/swarm/peer/worker.rs
@@ -201,6 +201,7 @@ pub(crate) async fn run_peer_worker(state: AppState) {
.throughput
.lock_or_recover()
.retain(|peer| known.contains_key(peer));
+ state.lock_rtt().retain(|peer| known.contains_key(peer));
}
// Fallback for what doesn't notify (`topology::run_worker`).
state.topology_changed.notify_one();