gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Report datapoint on number of retransmit shreds (#15694) (#15769)

Browse Source 
(cherry picked from commit 331c45decf)

Co-authored-by: carllin <carl@solana.com>
This commit is contained in:
mergify[bot]
2021-03-09 03:08:36 +00:00
committed by GitHub
parent 9fbc03d517
commit 74b13605c0
1 changed files with 9 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

11
core/src/retransmit_stage.rs
View File

@ -174,9 +174,16 @@ fn update_retransmit_stats(
), ),
); );
let mut packets_by_slot = stats.packets_by_slot.lock().unwrap(); let mut packets_by_slot = stats.packets_by_slot.lock().unwrap();
info!("retransmit: packets_by_slot: {:?}", packets_by_slot); let old_packets_by_slot = std::mem::replace(&mut *packets_by_slot, BTreeMap::new());
packets_by_slot.clear();
drop(packets_by_slot); drop(packets_by_slot);
for (slot, num_shreds) in old_packets_by_slot {
datapoint_info!(
"retransmit-slot-num-packets",
("slot", slot, i64),
("num_shreds", num_shreds, i64)
);
}
let mut packets_by_source = stats.packets_by_source.lock().unwrap(); let mut packets_by_source = stats.packets_by_source.lock().unwrap();
let mut top = BTreeMap::new(); let mut top = BTreeMap::new();
let mut max = 0; let mut max = 0;