remake coordinators resume after restart

1 files changed, 4 insertions, 0 deletions

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<H: Host>(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()