Remove unnecessary if
This commit is contained in:
parent
9adbc1dd60
commit
16e2443f61
|
@ -195,25 +195,23 @@ pub fn process_blocktree(
|
||||||
continue;
|
continue;
|
||||||
}
|
}
|
||||||
|
|
||||||
if slot_complete && !meta.next_slots.is_empty() {
|
// reached end of slot, look for next slots
|
||||||
// reached end of slot, look for next slots
|
|
||||||
|
|
||||||
// TODO merge with locktower, voting
|
// TODO merge with locktower, voting
|
||||||
bank.squash();
|
bank.squash();
|
||||||
|
|
||||||
// This is a fork point, create a new child bank for each fork
|
// This is a fork point, create a new child bank for each fork
|
||||||
pending_slots.extend(meta.next_slots.iter().map(|next_slot| {
|
pending_slots.extend(meta.next_slots.iter().map(|next_slot| {
|
||||||
let leader = LeaderScheduler::default().slot_leader_at(*next_slot, &bank);
|
let leader = LeaderScheduler::default().slot_leader_at(*next_slot, &bank);
|
||||||
let child_bank = Bank::new_from_parent_and_id(&bank, leader, *next_slot);
|
let child_bank = Bank::new_from_parent_and_id(&bank, leader, *next_slot);
|
||||||
trace!("Add child bank for slot={}", next_slot);
|
trace!("Add child bank for slot={}", next_slot);
|
||||||
bank_forks.insert(*next_slot, child_bank);
|
bank_forks.insert(*next_slot, child_bank);
|
||||||
(*next_slot, entry_height, last_entry_id)
|
(*next_slot, entry_height, last_entry_id)
|
||||||
}));
|
}));
|
||||||
|
|
||||||
// reverse sort by slot, so the next slot to be processed can be pop()ed
|
// reverse sort by slot, so the next slot to be processed can be pop()ed
|
||||||
// TODO: remove me once leader_scheduler can hang with out-of-order slots?
|
// TODO: remove me once leader_scheduler can hang with out-of-order slots?
|
||||||
pending_slots.sort_by(|a, b| b.0.cmp(&a.0));
|
pending_slots.sort_by(|a, b| b.0.cmp(&a.0));
|
||||||
}
|
|
||||||
}
|
}
|
||||||
|
|
||||||
info!(
|
info!(
|
||||||
|
|
Loading…
Reference in New Issue