diff options
| author | murilo ijanc | 2026-03-25 16:52:03 -0300 |
|---|---|---|
| committer | murilo ijanc | 2026-03-25 16:52:03 -0300 |
| commit | 4cff87560ba238ba6eebd16b1465c0ebae2f6ac2 (patch) | |
| tree | ae9598973520d5cd6d4528f198dec7b9699c0f5e /src/handlers.rs | |
| parent | c4076f54c9e66afb73081fd33b4176ba4407a8a5 (diff) | |
| download | tesseras-dht-4cff87560ba238ba6eebd16b1465c0ebae2f6ac2.tar.gz | |
Remove stale peers without replacement from routing table
When a peer exceeds STALE_THRESHOLD failures and the replacement
cache is empty, remove it outright instead of leaving it in the
bucket indefinitely. Prevents phantom peer accumulation in small
clusters where the cache rarely fills.
Diffstat (limited to 'src/handlers.rs')
| -rw-r--r-- | src/handlers.rs | 7 |
1 files changed, 2 insertions, 5 deletions
diff --git a/src/handlers.rs b/src/handlers.rs index f4c5b2c..574aca3 100644 --- a/src/handlers.rs +++ b/src/handlers.rs @@ -849,8 +849,7 @@ impl Node { .closest .iter() .find(|p| { - q.queried.contains(&p.id) - && p.id != sender_id + q.queried.contains(&p.id) && p.id != sender_id }) .cloned(); @@ -866,9 +865,7 @@ impl Node { is_unique: false, }; if let Err(e) = self.send_store(&peer, &store_msg) { - log::debug!( - "Republish-on-access failed: {e}" - ); + log::debug!("Republish-on-access failed: {e}"); } else { log::debug!( "Republished value to {:?} (nearest without)", |