blockworks-foundation
/
solana-with-rpc-optimizations
mirror of https://github.com/blockworks-foundation/solana-with-rpc-optimizations.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

adds number of coding shreds to broadcast metrics (#27006)

This commit is contained in:
behzad nouri 2022-08-09 13:59:40 +00:00 committed by GitHub
parent b6d38aad69
commit e2a2d271f2
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
core/src/broadcast_stage/standard_broadcast_run.rs
View File

@ -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),
);
}

2
ledger/src/shred/stats.rs
View File

@ -48,6 +48,7 @@ impl ProcessShredsStats {
name: &'static str,
slot: Slot,
num_data_shreds: u32,
num_coding_shreds: u32,
slot_broadcast_time: Option<Duration>,
) {
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",