diff --git a/core/src/find_packet_sender_stake_stage.rs b/core/src/find_packet_sender_stake_stage.rs index 4ec3f2d8d2..94ea617894 100644 --- a/core/src/find_packet_sender_stake_stage.rs +++ b/core/src/find_packet_sender_stake_stage.rs @@ -43,25 +43,25 @@ struct FindPacketSenderStakeStats { } impl FindPacketSenderStakeStats { - fn report(&mut self) { + fn report(&mut self, name: &'static str) { let now = timestamp(); let elapsed_ms = now - self.last_print; if elapsed_ms > 2000 { datapoint_info!( - "find_packet_sender_stake-services_stats", + name, ( - "refresh_ip_to_stake_time", + "refresh_ip_to_stake_time_us", self.refresh_ip_to_stake_time as i64, i64 ), ( - "apply_sender_stakes_time", + "apply_sender_stakes_time_us", self.apply_sender_stakes_time as i64, i64 ), - ("send_batches_time", self.send_batches_time as i64, i64), + ("send_batches_time_us", self.send_batches_time as i64, i64), ( - "receive_batches_time", + "receive_batches_time_ns", self.receive_batches_time as i64, i64 ), @@ -84,6 +84,7 @@ impl FindPacketSenderStakeStage { sender: FindPacketSenderStakeSender, bank_forks: Arc>, cluster_info: Arc, + name: &'static str, ) -> Self { let mut stats = FindPacketSenderStakeStats::default(); let thread_hdl = Builder::new() @@ -139,7 +140,7 @@ impl FindPacketSenderStakeStage { }, } - stats.report(); + stats.report(name); } }) .unwrap(); diff --git a/core/src/tpu.rs b/core/src/tpu.rs index f40ba7ee18..d94fa3dbf7 100644 --- a/core/src/tpu.rs +++ b/core/src/tpu.rs @@ -122,6 +122,7 @@ impl Tpu { find_packet_sender_stake_sender, bank_forks.clone(), cluster_info.clone(), + "tpu-find-packet-sender-stake", ); let (vote_find_packet_sender_stake_sender, vote_find_packet_sender_stake_receiver) = @@ -132,6 +133,7 @@ impl Tpu { vote_find_packet_sender_stake_sender, bank_forks.clone(), cluster_info.clone(), + "tpu-vote-find-packet-sender-stake", ); let (verified_sender, verified_receiver) = unbounded();