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

Fix leader scheduling in replay stage

Browse Source
This commit is contained in:
Greg Fitzgerald 2019-02-26 09:38:31 -07:00
parent b752511f41
commit ec35c1fc79
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

5
src/replay_stage.rs
View File

@ -89,11 +89,12 @@ impl ReplayStage {
); );
let num_ticks = bank.tick_height(); let num_ticks = bank.tick_height();
let (mut num_ticks_to_next_vote, slot_height) = { let (mut num_ticks_to_next_vote, slot_height, leader_id) = {
let rl = leader_scheduler.read().unwrap(); let rl = leader_scheduler.read().unwrap();
( (
rl.num_ticks_left_in_slot(num_ticks), rl.num_ticks_left_in_slot(num_ticks),
rl.tick_height_to_slot(num_ticks), rl.tick_height_to_slot(num_ticks),
rl.get_leader_for_slot(slot).expect("Leader not known"),
) )
}; };
@ -115,7 +116,7 @@ impl ReplayStage {
entries_with_meta.push(EntryMeta { entries_with_meta.push(EntryMeta {
tick_height: entry_tick_height, tick_height: entry_tick_height,
slot, slot,
slot_leader: bank.slot_leader(), slot_leader: leader_id,
num_ticks_left_in_slot: num_ticks_to_next_vote, num_ticks_left_in_slot: num_ticks_to_next_vote,
parent_slot, parent_slot,
entry: entry.clone(), entry: entry.clone(),