blockworks-foundation
/
solana
mirror of https://github.com/blockworks-foundation/solana.git
1
0
Fork 0
Code Issues Projects Releases Wiki Activity

refactor: combine SlotStateUpdate impls (#31578)

This commit is contained in:
Ashwin Sekar 2023-05-10 15:12:39 -06:00 committed by GitHub
parent 18a118b438
commit c900ef8290
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 23 additions and 25 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

48
core/src/cluster_slot_state_verifier.rs
View File

@ -266,6 +266,29 @@ pub enum SlotStateUpdate {
}
impl SlotStateUpdate {
fn into_state_changes(self, slot: Slot) -> Vec<ResultingStateChange> {
let bank_frozen_hash = self.bank_hash();
if bank_frozen_hash.is_none() {
// If the bank hasn't been frozen yet, then there's nothing to do
// since replay of the slot hasn't finished yet.
return vec![];
}
match self {
SlotStateUpdate::Dead(dead_state) => on_dead_slot(slot, dead_state),
SlotStateUpdate::BankFrozen(bank_frozen_state) => {
on_frozen_slot(slot, bank_frozen_state)
}
SlotStateUpdate::DuplicateConfirmed(duplicate_confirmed_state) => {
on_duplicate_confirmed(slot, duplicate_confirmed_state)
}
SlotStateUpdate::Duplicate(duplicate_state) => on_duplicate(duplicate_state),
SlotStateUpdate::EpochSlotsFrozen(epoch_slots_frozen_state) => {
on_epoch_slots_frozen(slot, epoch_slots_frozen_state)
}
}
}
fn bank_hash(&self) -> Option<Hash> {
match self {
SlotStateUpdate::BankFrozen(bank_frozen_state) => Some(bank_frozen_state.frozen_hash),
@ -297,31 +320,6 @@ pub enum ResultingStateChange {
SendAncestorHashesReplayUpdate(AncestorHashesReplayUpdate),
}
impl SlotStateUpdate {
fn into_state_changes(self, slot: Slot) -> Vec<ResultingStateChange> {
let bank_frozen_hash = self.bank_hash();
if bank_frozen_hash.is_none() {
// If the bank hasn't been frozen yet, then there's nothing to do
// since replay of the slot hasn't finished yet.
return vec![];
}
match self {
SlotStateUpdate::Dead(dead_state) => on_dead_slot(slot, dead_state),
SlotStateUpdate::BankFrozen(bank_frozen_state) => {
on_frozen_slot(slot, bank_frozen_state)
}
SlotStateUpdate::DuplicateConfirmed(duplicate_confirmed_state) => {
on_duplicate_confirmed(slot, duplicate_confirmed_state)
}
SlotStateUpdate::Duplicate(duplicate_state) => on_duplicate(duplicate_state),
SlotStateUpdate::EpochSlotsFrozen(epoch_slots_frozen_state) => {
on_epoch_slots_frozen(slot, epoch_slots_frozen_state)
}
}
}
}
fn check_duplicate_confirmed_hash_against_frozen_hash(
state_changes: &mut Vec<ResultingStateChange>,
slot: Slot,