From 00f005af25a1dac8f5c4f1a693aa3dfe71b39574 Mon Sep 17 00:00:00 2001
From: Sagar Dhawan <sagar@solana.com>
Date: Fri, 15 Mar 2019 16:36:12 -0700
Subject: [PATCH] Fix leader rotation counter

---
 core/src/replay_stage.rs | 9 ++++++++-
 1 file changed, 8 insertions(+), 1 deletion(-)

diff --git a/core/src/replay_stage.rs b/core/src/replay_stage.rs
index 76a75b4500..cbb22903d0 100644
--- a/core/src/replay_stage.rs
+++ b/core/src/replay_stage.rs
@@ -12,6 +12,7 @@ use crate::result;
 use crate::rpc_subscriptions::RpcSubscriptions;
 use crate::service::Service;
 use solana_metrics::counter::Counter;
+use solana_metrics::influxdb;
 use solana_runtime::bank::Bank;
 use solana_sdk::hash::Hash;
 use solana_sdk::pubkey::Pubkey;
@@ -241,7 +242,13 @@ impl ReplayStage {
                     cluster_info.write().unwrap().set_leader(&next_leader);
                     if next_leader == *my_id && reached_leader_tick {
                         debug!("{} starting tpu for slot {}", my_id, poh_slot);
-                        inc_new_counter_info!("replay_stage-new_leader", poh_slot as usize);
+                        solana_metrics::submit(
+                            influxdb::Point::new("counter-replay_stage-new_leader")
+                                .add_field(
+                                    "count",
+                                    influxdb::Value::Integer(poh_slot as i64),
+                                )
+                                .to_owned(),);
                         let tpu_bank = Bank::new_from_parent(parent, my_id, poh_slot);
                         bank_forks.write().unwrap().insert(poh_slot, tpu_bank);
                         if let Some(tpu_bank) = bank_forks.read().unwrap().get(poh_slot).cloned() {