diff options
| author | tv <tv@krebsco.de> | 2026-10-26 05:50:14 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-26 05:50:14 +0100 |
| commit | f00378e8609e0117132d7aab3f4468a1721f52fa (patch) | |
| tree | 5a252c09685cf833f5e1a7fc2e2e4e4b3f3c02dd /src/swarm/peer/worker.rs | |
| parent | 51e8c8e38c05d98487784e21f9df54cc18875b8b (diff) | |
keep silent strangers for a day
Diffstat (limited to 'src/swarm/peer/worker.rs')
| -rw-r--r-- | src/swarm/peer/worker.rs | 3 |
1 files changed, 2 insertions, 1 deletions
diff --git a/src/swarm/peer/worker.rs b/src/swarm/peer/worker.rs index a27f144..5161ae6 100644 --- a/src/swarm/peer/worker.rs +++ b/src/swarm/peer/worker.rs @@ -8,7 +8,7 @@ use std::time::Duration; use tokio::time::{Instant, MissedTickBehavior}; use tracing::{debug, info, warn}; -use super::forget::apply_forget_records; +use super::forget::{apply_forget_records, forget_strangers}; use super::handshake::retry_hello_if_due; use super::keepalive::send_ping; use crate::locks::MutexExt; @@ -94,6 +94,7 @@ pub(crate) async fn run_peer_worker(state: AppState) { if last_forget_check.is_none_or(|t| t.elapsed() >= FORGET_CHECK_INTERVAL) { apply_forget_records(&state).await; + forget_strangers(&state).await; crate::swarm::members::ensure_registered(&state).await; crate::swarm::stability::tick(&state).await; crate::swarm::stats::measure_saved_size(&state); |
