Skip to content

Commit

Permalink
Make code more compact and fix deadlock in test.
Browse files Browse the repository at this point in the history
  • Loading branch information
wen-coding committed Jan 26, 2025
1 parent 5c3fb7f commit 28db4e9
Showing 1 changed file with 4 additions and 5 deletions.
9 changes: 4 additions & 5 deletions wen-restart/src/wen_restart.rs
Original file line number Diff line number Diff line change
Expand Up @@ -619,9 +619,7 @@ pub(crate) fn find_bankhash_of_heaviest_fork(
return Err(WenRestartError::Exiting.into());
}
let saved_bank = bank_forks.read().unwrap().get_with_scheduler(slot);
let bank_with_scheduler = if let Some(bank) = saved_bank {
bank
} else {
let bank_with_scheduler = saved_bank.unwrap_or_else(|| {
let new_bank = Bank::new_from_parent(
parent_bank.clone(),
&leader_schedule_cache
Expand All @@ -630,7 +628,7 @@ pub(crate) fn find_bankhash_of_heaviest_fork(
slot,
);
bank_forks.write().unwrap().insert_from_ledger(new_bank)
};
});
let bank = if bank_with_scheduler.is_frozen() {
bank_with_scheduler.clone_without_scheduler()
} else {
Expand Down Expand Up @@ -3749,13 +3747,14 @@ mod tests {
slot: Slot,
) {
let exit = Arc::new(AtomicBool::new(false));
let root_bank = test_state.bank_forks.read().unwrap().root_bank();
assert_eq!(
find_bankhash_of_heaviest_fork(
slot,
slots.to_vec(),
test_state.blockstore.clone(),
test_state.bank_forks.clone(),
test_state.bank_forks.read().unwrap().root_bank(),
root_bank,
&exit,
)
.unwrap(),
Expand Down

0 comments on commit 28db4e9

Please sign in to comment.