add epochs

1 files changed, 6 insertions, 2 deletions

diff --git a/src/bootstrap.rs b/src/bootstrap.rs
index 53f473f..df47ff6 100644
--- a/src/bootstrap.rs
+++ b/src/bootstrap.rs
@@ -72,24 +72,28 @@ pub(crate) async fn bootstrap(state: &AppState, seeds: &[String]) -> Result<()>
                     PeerMembership::Member { cluster_id } => Some(cluster_id.as_str()),
                 };
                 peer_diagnostics.push(format!(
-                    "{peer}: validated_cluster={:?}, pending_inbound_sync={}",
+                    "{peer}: validated_cluster={:?}, epoch={:?}, pending_inbound_sync={}",
                     validated_cluster,
+                    peer_state.epoch,
                     peer_state.pending_inbound_sync.len()
                 ))
             }
             let local_cluster = state.cluster_id().await;
+            let local_epoch = state.local_epoch();
             let initial_sync_done = state.initial_sync_done.load(Ordering::Acquire);
             error!(
                 local_cluster = ?local_cluster,
+                local_epoch = %local_epoch,
                 initial_sync_done,
                 peers = %peer_diagnostics.join("; "),
                 timeout_seconds = BOOTSTRAP_TIMEOUT.as_secs(),
                 "Bootstrap timed out"
             );
             bail!(
-                "Bootstrap timed out after {:?}; local_cluster={:?}; initial_sync_done={}; peers=[{}]. Refusing to create a genesis document.",
+                "Bootstrap timed out after {:?}; local_cluster={:?}; local_epoch={}; initial_sync_done={}; peers=[{}]. Refusing to create a genesis document.",
                 BOOTSTRAP_TIMEOUT,
                 local_cluster,
+                local_epoch,
                 initial_sync_done,
                 peer_diagnostics.join("; ")
             );