Tweak debug to remove unreadable datapoints (#6060)

core/src/blocktree.rs

@@ -12,7 +12,7 @@ use std::collections::HashMap;
 
 use rocksdb;
 
-use solana_metrics::{datapoint_error, datapoint_info};
+use solana_metrics::{datapoint_debug, datapoint_error};
 
 use solana_sdk::genesis_block::GenesisBlock;
 use solana_sdk::hash::Hash;
@@ -324,7 +324,7 @@ impl Blocktree {
         // 3a. Enough number of shreds = (#data + #coding shreds) > erasure.num_data
         for (&(slot, set_index), erasure_meta) in erasure_metas.iter() {
             let submit_metrics = |attempted: bool, status: String, recovered: usize| {
-                datapoint_info!(
+                datapoint_debug!(
                     "blocktree-erasure",
                     ("slot", slot as i64, i64),
                     ("start_index", set_index as i64, i64),

core/src/broadcast_stage.rs

@@ -8,7 +8,7 @@ use crate::poh_recorder::WorkingBankEntry;
 use crate::result::{Error, Result};
 use crate::service::Service;
 use crate::staking_utils;
-use solana_metrics::{datapoint_info, inc_new_counter_error, inc_new_counter_info};
+use solana_metrics::{datapoint_debug, inc_new_counter_error, inc_new_counter_info};
 use std::net::UdpSocket;
 use std::sync::atomic::{AtomicBool, Ordering};
 use std::sync::mpsc::{Receiver, RecvTimeoutError};

core/src/broadcast_stage/standard_broadcast_run.rs

@@ -49,7 +49,7 @@ impl StandardBroadcastRun {
             self.stats.run_elapsed.clear();
         }
 
-        datapoint_info!(
+        datapoint_debug!(
             "broadcast-service",
             ("num_entries", num_entries as i64, i64),
             ("num_shreds", num_shreds as i64, i64),

core/src/cluster_info.rs

@@ -729,7 +729,7 @@ impl ClusterInfo {
         });
 
         last_err?;
-        datapoint_info!("cluster_info-num_nodes", ("count", broadcast_len + 1, i64));
+        datapoint_debug!("cluster_info-num_nodes", ("count", broadcast_len + 1, i64));
         Ok(())
     }
 

core/src/consensus.rs

@@ -1,5 +1,5 @@
 use crate::bank_forks::BankForks;
-use solana_metrics::datapoint_info;
+use solana_metrics::datapoint_debug;
 use solana_runtime::bank::Bank;
 use solana_sdk::account::Account;
 use solana_sdk::hash::Hash;
@@ -99,7 +99,7 @@ impl Tower {
                     vote_state.nth_recent_vote(0).map(|v| v.slot).unwrap_or(0) as i64
                 );
                 debug!("observed root {}", vote_state.root_slot.unwrap_or(0) as i64);
-                datapoint_info!(
+                datapoint_debug!(
                     "tower-observed",
                     (
                         "slot",
@@ -214,7 +214,7 @@ impl Tower {
         self.lockouts.process_vote_unchecked(&vote);
         self.last_vote = vote;
 
-        datapoint_info!(
+        datapoint_debug!(
             "tower-vote",
             ("latest", slot, i64),
             ("root", self.lockouts.root_slot.unwrap_or(0), i64)

core/src/repair_service.rs

@@ -6,7 +6,7 @@ use crate::cluster_info::ClusterInfo;
 use crate::cluster_info_repair_listener::ClusterInfoRepairListener;
 use crate::result::Result;
 use crate::service::Service;
-use solana_metrics::datapoint_info;
+use solana_metrics::datapoint_debug;
 use solana_runtime::epoch_schedule::EpochSchedule;
 use solana_sdk::pubkey::Pubkey;
 use std::collections::BTreeSet;
@@ -170,7 +170,7 @@ impl RepairService {
 
                 for ((to, req), repair_request) in reqs {
                     if let Ok(local_addr) = repair_socket.local_addr() {
-                        datapoint_info!(
+                        datapoint_debug!(
                             "repair_service",
                             ("repair_request", format!("{:?}", repair_request), String),
                             ("to", to.to_string(), String),

core/src/replay_stage.rs

@@ -330,7 +330,7 @@ impl ReplayStage {
                 return;
             }
 
-            datapoint_info!(
+            datapoint_debug!(
                 "replay_stage-new_leader",
                 ("slot", poh_slot, i64),
                 ("leader", next_leader.to_string(), String),

core/src/retransmit_stage.rs

@@ -73,7 +73,7 @@ fn retransmit(
             ClusterInfo::retransmit_to(&cluster_info, &children, packet, leader, sock, true)?;
         }
     }
-    datapoint_info!("cluster_info-num_nodes", ("count", peers_len, i64));
+    datapoint_debug!("cluster_info-num_nodes", ("count", peers_len, i64));
     Ok(())
 }
 

core/src/sigverify_stage.rs

@@ -16,7 +16,7 @@ use crate::sigverify::TxOffset;
 use crate::streamer::{self, PacketReceiver};
 use crossbeam_channel::Sender as CrossbeamSender;
 use solana_measure::measure::Measure;
-use solana_metrics::{datapoint_info, inc_new_counter_info};
+use solana_metrics::{datapoint_debug, inc_new_counter_info};
 use solana_sdk::timing;
 use std::sync::mpsc::{Receiver, RecvTimeoutError};
 use std::sync::{Arc, Mutex};
@@ -110,7 +110,7 @@ impl SigVerifyStage {
             (len as f32 / verify_batch_time.as_s())
         );
 
-        datapoint_info!(
+        datapoint_debug!(
             "sigverify_stage-total_verify_time",
             ("batch_len", batch_len, i64),
             ("len", len, i64),