diff --git a/core/src/blocktree.rs b/core/src/blocktree.rs index 4e292c9efc..5a98116515 100644 --- a/core/src/blocktree.rs +++ b/core/src/blocktree.rs @@ -1298,11 +1298,11 @@ fn try_erasure_recover( } } ErasureMetaStatus::StillNeed(needed) => { - inc_new_counter_info!("blocktree-erasure-blobs_needed", needed); + inc_new_counter_info!("blocktree-erasure-blobs_needed", needed, 0, 1000); None } ErasureMetaStatus::DataFull => { - inc_new_counter_info!("blocktree-erasure-complete", 1); + inc_new_counter_info!("blocktree-erasure-complete", 1, 0, 1000); None } }; diff --git a/core/src/cluster_info.rs b/core/src/cluster_info.rs index 0bfdb728a9..8dd2bbb5cd 100644 --- a/core/src/cluster_info.rs +++ b/core/src/cluster_info.rs @@ -1132,7 +1132,7 @@ impl ClusterInfo { data: &[CrdsValue], ) -> Vec { let self_id = me.read().unwrap().gossip.id; - inc_new_counter_info!("cluster_info-push_message", 1); + inc_new_counter_info!("cluster_info-push_message", 1, 0, 1000); let prunes: Vec<_> = me .write() .unwrap() diff --git a/core/src/window_service.rs b/core/src/window_service.rs index 643a97461f..1a78c617ea 100644 --- a/core/src/window_service.rs +++ b/core/src/window_service.rs @@ -36,7 +36,12 @@ fn retransmit_blobs(blobs: &[SharedBlob], retransmit: &BlobSender, id: &Pubkey) } if !retransmit_queue.is_empty() { - inc_new_counter_info!("streamer-recv_window-retransmit", retransmit_queue.len()); + inc_new_counter_info!( + "streamer-recv_window-retransmit", + retransmit_queue.len(), + 0, + 1000 + ); retransmit.send(retransmit_queue)?; } Ok(()) @@ -117,7 +122,7 @@ fn recv_window( blobs.append(&mut blob) } let now = Instant::now(); - inc_new_counter_info!("streamer-recv_window-recv", blobs.len()); + inc_new_counter_info!("streamer-recv_window-recv", blobs.len(), 0, 1000); blobs.retain(|blob| { should_retransmit_and_persist(