From 0cdd5075c88d938117c5dbddc22a2331a8816c34 Mon Sep 17 00:00:00 2001 From: tv Date: Wed, 21 Oct 2026 03:56:31 +0200 Subject: rename compaction to remake --- src/swarm/bootstrap.rs | 2 +- src/swarm/peer.rs | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) (limited to 'src/swarm') 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(()); diff --git a/src/swarm/peer.rs b/src/swarm/peer.rs index f401680..a3a6ad9 100644 --- a/src/swarm/peer.rs +++ b/src/swarm/peer.rs @@ -534,7 +534,7 @@ async fn observe_peer_epoch(state: &AppState, peer: &str, remote: Epoch) -> bool .send(SyncEvent::PeerNeedsSync(peer.to_owned())); } } - // Expected after a compaction: either side switches or catches up. + // Expected after a remake: either side switches or catches up. EpochRelation::PeerAhead | EpochRelation::PeerBehind => { info!( peer = %peer, -- cgit v1.3.1