aboutsummaryrefslogtreecommitdiffstats
path: root/src/swarm/peer
diff options
context:
space:
mode:
Diffstat (limited to 'src/swarm/peer')
-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();