diff --git a/consensus/core/src/authority_node.rs b/consensus/core/src/authority_node.rs index 2ab0aeac813a4..4cfbbccfac4b7 100644 --- a/consensus/core/src/authority_node.rs +++ b/consensus/core/src/authority_node.rs @@ -148,7 +148,7 @@ where registry: Registry, ) -> Self { info!( - "Starting authority {}\n{:#?}\n{:#?}\n{:?}", + "Starting consensus authority {}\n{:#?}\n{:#?}\n{:?}", own_index, committee, parameters, protocol_config.version ); assert!(committee.is_valid_index(own_index)); @@ -292,7 +292,10 @@ where network_manager.install_service(network_service).await; - info!("Authority start complete, took {:?}", start_time.elapsed()); + info!( + "Consensus authority started, took {:?}", + start_time.elapsed() + ); Self { context, diff --git a/consensus/core/src/commit_observer.rs b/consensus/core/src/commit_observer.rs index 0dcd9071edadc..652eb5af24604 100644 --- a/consensus/core/src/commit_observer.rs +++ b/consensus/core/src/commit_observer.rs @@ -121,7 +121,7 @@ impl CommitObserver { .scan_commits(((last_processed_commit_index + 1)..=CommitIndex::MAX).into()) .expect("Scanning commits should not fail"); - debug!("Recovering commit observer from {last_processed_commit_index} with last commit {:?} and {} unsent commits", last_commit, unsent_commits.len()); + debug!("Recovering commit observer after index {last_processed_commit_index} with last commit {:?} and {} unsent commits", last_commit, unsent_commits.len()); // Resend all the committed subdags to the consensus output channel // for all the commits above the last processed index. @@ -157,7 +157,7 @@ impl CommitObserver { } debug!( - "Commit observer recovery complete, took {:?}", + "Commit observer recovery completed, took {:?}", now.elapsed() ); } diff --git a/consensus/core/src/core.rs b/consensus/core/src/core.rs index 17d3d34ab3522..f58098551d214 100644 --- a/consensus/core/src/core.rs +++ b/consensus/core/src/core.rs @@ -205,7 +205,7 @@ impl Core { } debug!( - "Core recovery complete with last block {:?}", + "Core recovery completed with last proposed block {:?}", self.last_proposed_block );