Struct massa_execution_worker::speculative_deferred_calls::SpeculativeDeferredCallRegistry

pub(crate) struct SpeculativeDeferredCallRegistry {
    final_state: Arc<RwLock<dyn FinalStateController>>,
    active_history: Arc<RwLock<ActiveHistory>>,
    deferred_calls_changes: DeferredCallRegistryChanges,
    config: DeferredCallsConfig,
}

Fields

final_state: Arc<RwLock<dyn FinalStateController>>

active_history: Arc<RwLock<ActiveHistory>>

deferred_calls_changes: DeferredCallRegistryChanges

config: DeferredCallsConfig

Implementations

impl SpeculativeDeferredCallRegistry

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

Creates a new SpeculativeDeferredCallRegistry

Arguments

pub fn get_snapshot(&self) -> DeferredCallRegistryChanges

Takes a snapshot (clone) of the message states

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

Resets the SpeculativeDeferredCallRegistry to a snapshot (see get_snapshot method)

pub fn push_new_call(&mut self, id: DeferredCallId, call: DeferredCall)

Add a new call to the list of changes of this SpeculativeDeferredCallRegistry

pub fn get_effective_total_gas(&self) -> u128

pub fn get_effective_slot_gas(&self, slot: &Slot) -> u64

pub fn get_slot_base_fee(&self, slot: &Slot) -> Amount

pub fn advance_slot(&mut self, current_slot: Slot) -> DeferredSlotCalls

Consumes and deletes the current slot, prepares a new slot in the future and returns the calls that need to be executed in the current slot

pub fn get_calls_by_slot(&self, slot: Slot) -> DeferredSlotCalls

pub fn get_call(&self, id: &DeferredCallId) -> Option<DeferredCall>

pub fn delete_call(&mut self, id: &DeferredCallId, slot: Slot)

pub fn cancel_call( &mut self, id: &DeferredCallId, ) -> Result<(Address, Amount), ExecutionError>

Cancel a call Returns the sender address and the amount of coins to reimburse them

fn overbooking_fee( resource_supply: u128, target_occupancy: u128, current_occupancy: u128, resource_request: u128, max_penalty: Amount, ) -> Result<Amount, ExecutionError>

pub fn compute_call_fee( &self, target_slot: Slot, max_gas_request: u64, current_slot: Slot, params_size: u64, ) -> Result<Amount, ExecutionError>

Compute call fee

pub fn register_call( &mut self, call: DeferredCall, trail_hash: Hash, ) -> Result<DeferredCallId, ExecutionError>

Register a new call Returns the call id

Arguments

• call - The call to register
• trail_hash - The hash of the execution trail hash

pub(crate) fn take(&mut self) -> DeferredCallRegistryChanges

Take the deferred registry slot changes