From c301f7f3805b21fe811ee5201f8fe817274c33bb Mon Sep 17 00:00:00 2001 From: tv Date: Sat, 24 Oct 2026 22:00:37 +0200 Subject: remake coordinators resume after restart --- src/remake/switch.rs | 4 ++++ 1 file changed, 4 insertions(+) (limited to 'src/remake/switch.rs') diff --git a/src/remake/switch.rs b/src/remake/switch.rs index c18905c..e4644fb 100644 --- a/src/remake/switch.rs +++ b/src/remake/switch.rs @@ -27,6 +27,7 @@ use tracing::{error, info, warn}; use super::Host; use super::catchup; use super::content; +use super::coordinator; use super::delta::{self, ReplayStats}; use super::kind::Translator; use super::local::LocalStatus; @@ -90,6 +91,9 @@ async fn check(host: &H) { host.dormant_after().as_millis() as u64, ); let local_record = EpochRecord::from(local); + if host.is_node_ready().await { + coordinator::resume(host, &local_record, &all); + } let committed: Vec<(String, Record)> = all .into_iter() -- cgit v1.3.1