diff options
Diffstat (limited to 'src/state/mod.rs')
| -rw-r--r-- | src/state/mod.rs | 4 |
1 files changed, 4 insertions, 0 deletions
diff --git a/src/state/mod.rs b/src/state/mod.rs index 7c1299f..2902234 100644 --- a/src/state/mod.rs +++ b/src/state/mod.rs @@ -151,6 +151,9 @@ pub(crate) struct AppState { /// Something the neighbours are computed from may have changed: the member list or a /// peer's state (`swarm::topology::run_worker`, `swarm::topology::change_peer`). pub(crate) topology_changed: Arc<tokio::sync::Notify>, + /// 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>, /// While rejoining a newer epoch, the previous document, served read-only (and /// marked stale) instead of answering 503. @@ -276,6 +279,7 @@ impl AppState { discovered_swarm_id: Some(swarm_id), }; debug!("Node transitioned from {old_lifecycle:?} {lifecycle:?}"); + self.join_progress.notify_one(); Ok(()) } NodeLifecycle::Joining { |