diff options
| author | tv <tv@krebsco.de> | 2026-11-01 20:38:27 +0100 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-11-01 20:38:27 +0100 |
| commit | 7d9f3a0db5d0421a2e3fac54e920718f0fdd1f7c (patch) | |
| tree | 1ae9f3987e28d05f9ac9014170efc904b7490687 /src/state | |
| parent | d09ec56ca2cdaf8060819a70ca2d89bd0458896f (diff) | |
peer worker forget records on change
Diffstat (limited to 'src/state')
| -rw-r--r-- | src/state/mod.rs | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/src/state/mod.rs b/src/state/mod.rs index ba90269..a4ea553 100644 --- a/src/state/mod.rs +++ b/src/state/mod.rs @@ -154,6 +154,9 @@ pub(crate) struct AppState { /// Something a joining node waits for may have happened: the swarm ID learned, the /// initial sync done, a rejoin ended, a seed found (`swarm::bootstrap`). pub(crate) join_progress: Arc<tokio::sync::Notify>, + /// The forget records may have changed (`swarm::changes`): the peer worker acts on + /// them at once instead of at its next periodic check. + pub(crate) forget_records_changed: Arc<AtomicBool>, /// When the peer worker is next due (`swarm::peer::Due`). pub(crate) peers_due: Arc<crate::swarm::peer::Due>, |
