Struct massa_execution_worker::speculative_executed_denunciations::SpeculativeExecutedDenunciations

pub(crate) struct SpeculativeExecutedDenunciations {
    final_state: Arc<RwLock<dyn FinalStateController>>,
    active_history: Arc<RwLock<ActiveHistory>>,
    executed_denunciations: ExecutedDenunciationsChanges,
}

Speculative state of executed denunciations

Fields

final_state: Arc<RwLock<dyn FinalStateController>>

Thread-safe shared access to the final state. For reading only.

active_history: Arc<RwLock<ActiveHistory>>

History of the outputs of recently executed slots. Slots should be consecutive, newest at the back.

executed_denunciations: ExecutedDenunciationsChanges

executed operations: maps the operation ID to its validity slot end - included

Implementations

impl SpeculativeExecutedDenunciations

pub fn new( final_state: Arc<RwLock<dyn FinalStateController>>, active_history: Arc<RwLock<ActiveHistory>>, ) -> Self

Creates a new SpeculativeExecutedDenunciations

Arguments

• final_state: thread-safe shared access the final state
• active_history: thread-safe shared access the speculative execution history

pub fn take(&mut self) -> ExecutedDenunciationsChanges

Returns the set of operation IDs caused to the SpeculativeExecutedDenunciations since its creation, and resets their local value to nothing

pub fn get_snapshot(&self) -> ExecutedDenunciationsChanges

Takes a snapshot (clone) of the changes since its creation

pub fn reset_to_snapshot(&mut self, snapshot: ExecutedDenunciationsChanges)

Resets the SpeculativeRollState to a snapshot (see get_snapshot method)

pub fn is_denunciation_executed(&self, de_idx: &DenunciationIndex) -> bool

Checks if a denunciation was executed previously

pub fn insert_executed_denunciation(&mut self, de_idx: DenunciationIndex)

Insert an executed denunciation.