[review] address review comments

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,

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()
         );
     }

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
         );