Error logging

Author: carllin

core/src/repair/cluster_slot_state_verifier.rs

@@ -853,7 +853,7 @@ pub(crate) fn check_slot_agrees_with_cluster(
     purge_repair_slot_counter: &mut PurgeRepairSlotCounter,
     slot_state_update: SlotStateUpdate,
 ) {
-    info!(
+    error!(
         "check_slot_agrees_with_cluster() slot: {}, root: {}, slot_state_update: {:?}",
         slot, root, slot_state_update
     );
@@ -870,7 +870,7 @@ pub(crate) fn check_slot_agrees_with_cluster(
             return;
         }
 
-        datapoint_info!(
+        datapoint_error!(
             "duplicate_slot",
             ("slot", slot, i64),
             (
@@ -902,7 +902,7 @@ pub(crate) fn check_slot_agrees_with_cluster(
             }
         }
 
-        datapoint_info!(
+        datapoint_error!(
             "duplicate_confirmed_slot",
             ("slot", slot, i64),
             (

core/src/replay_stage.rs

@@ -613,6 +613,7 @@ impl ReplayStage {
                 let mut ancestors = bank_forks.read().unwrap().ancestors();
                 let mut descendants = bank_forks.read().unwrap().descendants();
                 let did_complete_bank = Self::replay_active_banks(
+                    &my_pubkey,
                     &blockstore,
                     &bank_forks,
                     &my_pubkey,
@@ -920,8 +921,9 @@ impl ReplayStage {
                 // Reset onto a fork
                 if let Some(reset_bank) = reset_bank {
                     if last_reset != reset_bank.last_blockhash() {
-                        info!(
-                            "vote bank: {:?} reset bank: {:?}",
+                        error!(
+                            "{} vote bank: {:?} reset bank: {:?}",
+                            my_pubkey,
                             vote_bank
                                 .as_ref()
                                 .map(|(b, switch_fork_decision)| (b.slot(), switch_fork_decision)),
@@ -2699,6 +2701,7 @@ impl ReplayStage {
 
     #[allow(clippy::too_many_arguments)]
     fn process_replay_results(
+        id: &Pubkey,
         blockstore: &Blockstore,
         bank_forks: &RwLock<BankForks>,
         progress: &mut ProgressMap,
@@ -2783,6 +2786,7 @@ impl ReplayStage {
                     transaction_status_sender.send_transaction_status_freeze_message(bank);
                 }
                 bank.freeze();
+                error!("{} froze bank {} {:?}", id, bank_slot, bank.hash());
                 datapoint_info!(
                     "bank_frozen",
                     ("slot", bank_slot, i64),
@@ -2887,6 +2891,7 @@ impl ReplayStage {
 
     #[allow(clippy::too_many_arguments)]
     fn replay_active_banks(
+        id: &Pubkey,
         blockstore: &Blockstore,
         bank_forks: &RwLock<BankForks>,
         my_pubkey: &Pubkey,
@@ -2965,6 +2970,7 @@ impl ReplayStage {
             };
 
             Self::process_replay_results(
+                id,
                 blockstore,
                 bank_forks,
                 progress,

local-cluster/tests/local_cluster.rs

@@ -5288,7 +5288,10 @@ fn test_duplicate_shreds_switch_failure() {
         if original_frozen_hash != dup_frozen_hash {
             break;
         } else {
-            panic!("Duplicate leader and partition target got same hash: {}", original_frozen_hash);
+            panic!(
+                "Duplicate leader and partition target got same hash: {}",
+                original_frozen_hash
+            );
         }
     }