From 331c45decf20e2d8b8baa9286dcb2e6b171ff107 Mon Sep 17 00:00:00 2001 From: carllin Date: Mon, 8 Mar 2021 17:54:53 -0800 Subject: [PATCH] Report datapoint on number of retransmit shreds (#15694) --- core/src/retransmit_stage.rs | 11 +++++++++-- 1 file changed, 9 insertions(+), 2 deletions(-) diff --git a/core/src/retransmit_stage.rs b/core/src/retransmit_stage.rs index a01641aa5b..e59fcfe3c3 100644 --- a/core/src/retransmit_stage.rs +++ b/core/src/retransmit_stage.rs @@ -174,9 +174,16 @@ fn update_retransmit_stats( ), ); let mut packets_by_slot = stats.packets_by_slot.lock().unwrap(); - info!("retransmit: packets_by_slot: {:?}", packets_by_slot); - packets_by_slot.clear(); + let old_packets_by_slot = std::mem::replace(&mut *packets_by_slot, BTreeMap::new()); 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 top = BTreeMap::new(); let mut max = 0;