Struct massa_execution_worker::controller::ExecutionControllerImpl

pub struct ExecutionControllerImpl {
    pub(crate) input_data: Arc<(Condvar, Mutex<ExecutionInputData>)>,
    pub(crate) execution_state: Arc<RwLock<ExecutionState>>,
}

implementation of the execution controller

Fields

input_data: Arc<(Condvar, Mutex<ExecutionInputData>)>

input data to process in the Execution controller loop with a wake-up condition variable that needs to be triggered when the data changes

execution_state: Arc<RwLock<ExecutionState>>

current execution state (see execution.rs for details)

Trait Implementations

impl Clone for ExecutionControllerImpl

fn clone(&self) -> ExecutionControllerImpl

Returns a copy of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl ExecutionController for ExecutionControllerImpl

fn update_blockclique_status( &self, finalized_blocks: HashMap<Slot, BlockId>, new_blockclique: Option<HashMap<Slot, BlockId>>, block_metadata: PreHashMap<BlockId, ExecutionBlockMetadata>, )

Updates blockclique status by signaling newly finalized blocks and the latest blockclique.

Arguments

• finalized_blocks: newly finalized blocks indexed by slot.
• blockclique: new blockclique (if changed). Indexed by slot.
• block_metadata: storage instances and metadata for new blocks. Each storage owns refs to the block and its ops/endorsements.

fn query_state(&self, req: ExecutionQueryRequest) -> ExecutionQueryResponse

Atomically query the execution state with multiple requests

fn get_filtered_sc_output_event( &self, filter: EventFilter, ) -> Vec<SCOutputEvent>

Get the generated execution events, optionally filtered by:

• start slot
• end slot
• emitter address
• original caller address
• operation id

fn get_final_and_candidate_balance( &self, addresses: &[Address], ) -> Vec<(Option<Amount>, Option<Amount>)>

Get the final and candidate values of balance.

Return value

• (final_balance, candidate_balance)

fn get_final_and_active_data_entry( &self, input: Vec<(Address, Vec<u8>)>, ) -> Vec<(Option<Vec<u8>>, Option<Vec<u8>>)>

Get a copy of a single datastore entry with its final and active values

Return value

• Vec<(final_data_entry, active_data_entry)>

fn get_cycle_active_rolls(&self, cycle: u64) -> BTreeMap<Address, u64>

Return the active rolls distribution for the given cycle

fn execute_readonly_request( &self, req: ReadOnlyExecutionRequest, ) -> Result<ReadOnlyExecutionOutput, ExecutionError>

Executes a read-only request Read-only requests do not modify consensus state

fn get_denunciation_execution_status( &self, denunciation_index: &DenunciationIndex, ) -> (bool, bool)

Check if a denunciation has been executed given a DenunciationIndex Returns a tuple of booleans: (speculative_execution_status, final_execution_status)

fn get_addresses_infos( &self, addresses: &[Address], deferred_credits_max_slot: Bound<Slot>, ) -> Vec<ExecutionAddressInfo>

Gets information about a batch of addresses

fn get_stats(&self) -> ExecutionStats

Get execution statistics

fn get_module_lru_cache_memory_usage(&self) -> usize

Get the memory usage of the module LRU cache

fn get_active_history_total_event_len(&self) -> usize

Get the number of events currently in the active history

fn clone_box(&self) -> Box<dyn ExecutionController>

Returns a boxed clone of self. Allows cloning Box<dyn ExecutionController>, see massa-execution-exports/controller_traits.rs

fn get_ops_exec_status( &self, batch: &[OperationId], ) -> Vec<(Option<bool>, Option<bool>)>

See trait definition