diff --git a/core/src/broadcast_stage/standard_broadcast_run.rs b/core/src/broadcast_stage/standard_broadcast_run.rs index 3acb1dcc5..17a3725cd 100644 --- a/core/src/broadcast_stage/standard_broadcast_run.rs +++ b/core/src/broadcast_stage/standard_broadcast_run.rs @@ -418,7 +418,8 @@ impl StandardBroadcastRun { self.process_shreds_stats.submit( "broadcast-process-shreds-interrupted-stats", unfinished_slot.slot, - unfinished_slot.next_shred_index, // num_data_shreds, + unfinished_slot.next_shred_index, // num_data_shreds + unfinished_slot.next_code_index, // num_coding_shreds None, // slot_broadcast_time ); } else { @@ -426,7 +427,8 @@ impl StandardBroadcastRun { self.process_shreds_stats.submit( "broadcast-process-shreds-stats", unfinished_slot.slot, - unfinished_slot.next_shred_index, // num_data_shreds, + unfinished_slot.next_shred_index, // num_data_shreds + unfinished_slot.next_code_index, // num_coding_shreds Some(slot_broadcast_time), ); } diff --git a/ledger/src/shred/stats.rs b/ledger/src/shred/stats.rs index 1f261f5c8..c09590658 100644 --- a/ledger/src/shred/stats.rs +++ b/ledger/src/shred/stats.rs @@ -48,6 +48,7 @@ impl ProcessShredsStats { name: &'static str, slot: Slot, num_data_shreds: u32, + num_coding_shreds: u32, slot_broadcast_time: Option, ) { let slot_broadcast_time = slot_broadcast_time @@ -63,6 +64,7 @@ impl ProcessShredsStats { ("shredding_time", self.shredding_elapsed, i64), ("receive_time", self.receive_elapsed, i64), ("num_data_shreds", num_data_shreds, i64), + ("num_coding_shreds", num_coding_shreds, i64), ("slot_broadcast_time", slot_broadcast_time, i64), ( "get_leader_schedule_time",