gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Fix leader rotation counter

Browse Source
This commit is contained in:
Sagar Dhawan
2019-03-15 16:36:12 -07:00
committed by Grimes
parent 656fb173f9
commit 00f005af25
1 changed files with 8 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

9
core/src/replay_stage.rs
View File

@ -12,6 +12,7 @@ use crate::result;
use crate::rpc_subscriptions::RpcSubscriptions; use crate::rpc_subscriptions::RpcSubscriptions;
use crate::service::Service; use crate::service::Service;
use solana_metrics::counter::Counter; use solana_metrics::counter::Counter;
use solana_metrics::influxdb;
use solana_runtime::bank::Bank; use solana_runtime::bank::Bank;
use solana_sdk::hash::Hash; use solana_sdk::hash::Hash;
use solana_sdk::pubkey::Pubkey; use solana_sdk::pubkey::Pubkey;
@ -241,7 +242,13 @@ impl ReplayStage {
cluster_info.write().unwrap().set_leader(&next_leader); cluster_info.write().unwrap().set_leader(&next_leader);
if next_leader == *my_id && reached_leader_tick { if next_leader == *my_id && reached_leader_tick {
debug!("{} starting tpu for slot {}", my_id, poh_slot); 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); let tpu_bank = Bank::new_from_parent(parent, my_id, poh_slot);
bank_forks.write().unwrap().insert(poh_slot, tpu_bank); bank_forks.write().unwrap().insert(poh_slot, tpu_bank);
if let Some(tpu_bank) = bank_forks.read().unwrap().get(poh_slot).cloned() { if let Some(tpu_bank) = bank_forks.read().unwrap().get(poh_slot).cloned() {