Temporary replay logging changes for local cluster test transparency

solana-labs · Mar 12, 2021 · cf626d8 · cf626d8
1 parent 743ecd2
commit cf626d8
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/core/src/replay_stage.rs b/core/src/replay_stage.rs
@@ -528,7 +528,8 @@ impl ReplayStage {
                                 if !partition_exists && partition_detected
                                 {
                                     warn!(
-                                        "PARTITION DETECTED waiting to join heaviest fork: {} last vote: {:?}, reset slot: {}",
+                                        "{}, PARTITION DETECTED waiting to join heaviest fork: {} last vote: {:?}, reset slot: {}",
+                                        &my_pubkey,
                                         heaviest_bank.slot(),
                                         last_voted_slot,
                                         reset_bank.slot(),
@@ -991,6 +992,7 @@ impl ReplayStage {
     }
 
     fn replay_blockstore_into_bank(
+        my_pubkey: &Pubkey,
         bank: &Arc<Bank>,
         blockstore: &Blockstore,
         bank_progress: &mut ForkProgress,
@@ -1354,6 +1356,7 @@ impl ReplayStage {
             });
             if bank.collector_id() != my_pubkey {
                 let replay_result = Self::replay_blockstore_into_bank(
+                    &my_pubkey,
                     &bank,
                     &blockstore,
                     bank_progress,
@@ -2550,6 +2553,7 @@ pub(crate) mod tests {
             let shreds = shred_to_insert(&mint_keypair, bank0.clone());
             blockstore.insert_shreds(shreds, None, false).unwrap();
             let res = ReplayStage::replay_blockstore_into_bank(
+                &Pubkey::default(),
                 &bank0,
                 &blockstore,
                 &mut bank0_progress,