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

Report datapoint on number of retransmit shreds (#15694)

Browse Source
This commit is contained in:
carllin
2021-03-08 17:54:53 -08:00
committed by GitHub
parent e3e8179f2d
commit 331c45decf
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;