Struct massa_execution_worker::speculative_executed_ops::SpeculativeExecutedOps

pub(crate) struct SpeculativeExecutedOps {
    final_state: Arc<RwLock<dyn FinalStateController>>,
    active_history: Arc<RwLock<ActiveHistory>>,
    executed_ops: ExecutedOpsChanges,
}

Speculative state of executed operations

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_ops: ExecutedOpsChanges

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

Implementations

impl SpeculativeExecutedOps

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

Creates a new SpeculativeExecutedOps

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) -> ExecutedOpsChanges

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

pub fn get_snapshot(&self) -> ExecutedOpsChanges

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

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

Resets the SpeculativeRollState to a snapshot (see get_snapshot method)

pub fn is_op_executed(&self, op_id: &OperationId) -> bool

Checks if an operation was executed previously

pub fn insert_executed_op( &mut self, op_id: OperationId, op_exec_status: bool, op_valid_until_slot: Slot, )

Insert an executed operation. Does not check for reuse, please use SpeculativeExecutedOps::is_op_executed before.

Arguments

• op_id: operation ID
• op_exec_status : the status of the execution of the operation.
• op_valid_until_slot: slot until which the operation remains valid (included)