Struct massa_execution_worker::worker::ExecutionThread

pub(crate) struct ExecutionThread {
    input_data: Arc<(Condvar, Mutex<ExecutionInputData>)>,
    slot_sequencer: SlotSequencer,
    execution_state: Arc<RwLock<ExecutionState>>,
    readonly_requests: RequestQueue<ReadOnlyExecutionRequest, ReadOnlyExecutionOutput>,
    selector: Box<dyn SelectorController>,
}

Structure gathering all elements needed by the execution thread

Fields

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

slot_sequencer: SlotSequencer

execution_state: Arc<RwLock<ExecutionState>>

readonly_requests: RequestQueue<ReadOnlyExecutionRequest, ReadOnlyExecutionOutput>

queue for read-only requests and response MPSCs to send back their outputs

selector: Box<dyn SelectorController>

Selector controller

Implementations

impl ExecutionThread

pub fn new( config: ExecutionConfig, input_data: Arc<(Condvar, Mutex<ExecutionInputData>)>, execution_state: Arc<RwLock<ExecutionState>>, selector: Box<dyn SelectorController>, ) -> Self

Creates the ExecutionThread structure to gather all data and references needed by the execution worker thread.

Arguments

• config: execution configuration
• input_data: a copy of the input data interface to get incoming requests from
• execution_state: an thread-safe shared access to the execution state, which can be bootstrapped or newly created

fn update_readonly_requests( &mut self, new_requests: RequestQueue<ReadOnlyExecutionRequest, ReadOnlyExecutionOutput>, )

Append incoming read-only requests to the relevant queue, Cancel those that are in excess if there are too many.

fn execute_one_readonly_request(&mut self) -> bool

Executes a read-only request from the queue, if any. The result of the execution is sent asynchronously through the response channel provided with the request.

Returns

true if a request was executed, false otherwise

fn wait_loop_event(&mut self) -> (ExecutionInputData, bool)

Waits for an event to trigger a new iteration in the execution main loop.

Returns

ExecutionInputData representing the input requests, and a boolean saying whether we should stop the loop.

pub fn main_loop(&mut self)

Main loop of the execution worker