diff options
| author | tv <tv@krebsco.de> | 2026-11-06 04:33:45 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-06 04:33:45 +0100 |
| commit | de30fc105bbb9c610c847f64e00cd2555ca0c63c (patch) | |
| tree | 2b13361744eda5ba7606c18da5574744e4265668 /src/swarm/peer | |
| parent | 26ff4ff86b58fed130ce6802ac4aceba8ee93443 (diff) | |
rtt table pruned
Diffstat (limited to 'src/swarm/peer')
| -rw-r--r-- | src/swarm/peer/worker.rs | 1 |
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(); |
