diff options
| author | tv <tv@krebsco.de> | 2026-10-21 03:56:31 +0200 |
|---|---|---|
| committer | tv <tv@krebsco.de> | 2026-10-21 03:56:31 +0200 |
| commit | 0cdd5075c88d938117c5dbddc22a2331a8816c34 (patch) | |
| tree | 98f3f8ad2f010f9e3aa9ea88350f21af4f11bb90 /src/swarm/bootstrap.rs | |
| parent | cc96f69204140caf02c44f95df2b1027d5073e4e (diff) | |
rename compaction to remake
Diffstat (limited to 'src/swarm/bootstrap.rs')
| -rw-r--r-- | src/swarm/bootstrap.rs | 2 |
1 files changed, 1 insertions, 1 deletions
diff --git a/src/swarm/bootstrap.rs b/src/swarm/bootstrap.rs index 697c97f..8546fdc 100644 --- a/src/swarm/bootstrap.rs +++ b/src/swarm/bootstrap.rs @@ -54,7 +54,7 @@ pub(crate) async fn bootstrap(state: &AppState, seeds: &[String]) -> Result<()> if let Some(cluster_id) = state.cluster_id().await { // A node joining a compacted cluster rejoins the newer epoch first; it is // ready only once that rejoin verified the epoch. - if state.initial_sync_done.load(Ordering::Acquire) && !state.compaction.is_rejoining() { + if state.initial_sync_done.load(Ordering::Acquire) && !state.remake.is_rejoining() { state.mark_ready(cluster_id.clone()).await?; info!(cluster_id = %cluster_id, "Node is ready"); return Ok(()); |
