parent
96a61cc4e4
commit
53b8d0d528
|
@ -325,7 +325,8 @@ impl ClusterInfoVoteListener {
|
||||||
if exit.load(Ordering::Relaxed) {
|
if exit.load(Ordering::Relaxed) {
|
||||||
return Ok(());
|
return Ok(());
|
||||||
}
|
}
|
||||||
if let Some(bank) = poh_recorder.lock().unwrap().bank() {
|
let poh_bank = poh_recorder.lock().unwrap().bank();
|
||||||
|
if let Some(bank) = poh_bank {
|
||||||
let last_ts = bank.last_vote_sync.load(Ordering::Relaxed);
|
let last_ts = bank.last_vote_sync.load(Ordering::Relaxed);
|
||||||
let (votes, new_ts) = cluster_info.read().unwrap().get_votes(last_ts);
|
let (votes, new_ts) = cluster_info.read().unwrap().get_votes(last_ts);
|
||||||
bank.last_vote_sync
|
bank.last_vote_sync
|
||||||
|
|
|
@ -445,7 +445,8 @@ impl ReplayStage {
|
||||||
rewards_recorder_sender.clone(),
|
rewards_recorder_sender.clone(),
|
||||||
);
|
);
|
||||||
|
|
||||||
if let Some(bank) = poh_recorder.lock().unwrap().bank() {
|
let poh_bank = poh_recorder.lock().unwrap().bank();
|
||||||
|
if let Some(bank) = poh_bank {
|
||||||
Self::log_leader_change(
|
Self::log_leader_change(
|
||||||
&my_pubkey,
|
&my_pubkey,
|
||||||
bank.slot(),
|
bank.slot(),
|
||||||
|
|
Loading…
Reference in New Issue