nit
This commit is contained in:
@ -552,7 +552,7 @@ mod tests {
|
|||||||
// Wait for Poh recorder to hit max height
|
// Wait for Poh recorder to hit max height
|
||||||
loop {
|
loop {
|
||||||
let bank_tick_height = bank.tick_height();
|
let bank_tick_height = bank.tick_height();
|
||||||
if bank_tick_height >= leader_scheduler_config.ticks_per_slot {
|
if bank_tick_height >= ticks_per_slot {
|
||||||
break;
|
break;
|
||||||
}
|
}
|
||||||
sleep(Duration::from_millis(10));
|
sleep(Duration::from_millis(10));
|
||||||
|
@ -292,7 +292,7 @@ impl ReplayStage {
|
|||||||
);
|
);
|
||||||
if my_id == leader_id || my_id == last_leader_id {
|
if my_id == leader_id || my_id == last_leader_id {
|
||||||
to_leader_sender.send(current_tick_height).unwrap();
|
to_leader_sender.send(current_tick_height).unwrap();
|
||||||
} else {
|
} else if leader_id != last_leader_id {
|
||||||
// TODO: Remove this soon once we boot the leader from ClusterInfo
|
// TODO: Remove this soon once we boot the leader from ClusterInfo
|
||||||
cluster_info.write().unwrap().set_leader(leader_id);
|
cluster_info.write().unwrap().set_leader(leader_id);
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user