Struct DefaultExecutor 

pub struct DefaultExecutor<K>
where
    K: Kernel,
{
    engine_pool: EnginePool,
    machine: Option<<<K as Kernel>::CallManager as CallManager>::Machine>,
}

The default Executor.

Warning

Message execution might run out of stack and crash (the entire process) if it doesn’t have at least 64MiB of stack space. If you can’t guarantee 64MiB of stack space, wrap this executor in a ThreadedExecutor.

Fields

engine_pool: EnginePool

machine: Option<<<K as Kernel>::CallManager as CallManager>::Machine>

Implementations

impl<K> DefaultExecutor<K>

where K: Kernel,

pub fn new( engine_pool: EnginePool, machine: <<K as Kernel>::CallManager as CallManager>::Machine, ) -> Result<DefaultExecutor<K>, Error>

Create a new DefaultExecutor for executing messages on the Machine.

pub fn into_machine( self, ) -> Option<<<K as Kernel>::CallManager as CallManager>::Machine>

Consume consumes the executor and returns the Machine. If the Machine had been poisoned during execution, the Option will be None.

Trait Implementations

impl<K> Deref for DefaultExecutor<K>

where K: Kernel,

type Target = <<K as Kernel>::CallManager as CallManager>::Machine

The resulting type after dereferencing.

fn deref(&self) -> &<DefaultExecutor<K> as Deref>::Target

Dereferences the value.

impl<K> DerefMut for DefaultExecutor<K>

where K: Kernel,

fn deref_mut(&mut self) -> &mut <DefaultExecutor<K> as Deref>::Target

Mutably dereferences the value.

impl<K> Executor for DefaultExecutor<K>

where K: Kernel,

fn execute_message( &mut self, msg: Message, apply_kind: ApplyKind, raw_length: usize, ) -> Result<ApplyRet, Error>

This is the entrypoint to execute a message.

fn flush(&mut self) -> Result<Cid<64>, Error>

Flush the state-tree to the underlying blockstore.

type Kernel = K

The Kernel on which messages will be applied. We specify a Kernel here, not a Machine, because the Kernel implies the Machine.