Struct NestedVMHandler 

pub struct NestedVMHandler { /* private fields */ }

Effect handler that dispatches to inner VMs keyed by outer role name.

Implementations

impl NestedVMHandler

pub fn new() -> Self

Create an empty nested handler.

pub fn with_rounds_per_step(self, rounds: usize) -> Self

Set how many inner VM rounds to advance per outer handler call.

pub fn rounds_per_step(&self) -> usize

Number of inner VM rounds attempted per outer handler call.

pub fn add_site( &mut self, name: impl Into<String>, vm: VM, handler: Box<dyn EffectHandler>, )

Register a site by name with its inner VM and handler.

pub fn site_trace(&self, name: &str) -> Option<Vec<ObsEvent>>

Get a copy of the inner VM trace for a site.

Panics

Panics if the site VM mutex is poisoned.

pub fn site_all_done(&self, name: &str) -> Option<bool>

Check whether all coroutines in a site VM are terminal.

Panics

Panics if the site VM mutex is poisoned.

Trait Implementations

impl Default for NestedVMHandler

fn default() -> Self

Returns the “default value” for a type.

impl EffectHandler for NestedVMHandler

fn handle_send( &self, role: &str, _partner: &str, _label: &str, _state: &[Value], ) -> Result<Value, String>

Compute the payload for a send instruction.

fn handle_recv( &self, role: &str, _partner: &str, _label: &str, _state: &mut Vec<Value>, _payload: &Value, ) -> Result<(), String>

Process a received value.

fn handle_choose( &self, _role: &str, _partner: &str, labels: &[String], _state: &[Value], ) -> Result<String, String>

Choose which branch to take for internal choice (select).

fn step(&self, role: &str, _state: &mut Vec<Value>) -> Result<(), String>

Perform an integration step after a protocol round.

fn handler_identity(&self) -> String

Stable identifier for effect-trace attribution.

fn send_decision_fast_path( &self, _fast_path: SendDecisionFastPathInput<'_>, _state: &[Value], _payload: Option<&Value>, ) -> Option<Result<SendDecision, String>>

Optional fast-path hook for send decision dispatch.

fn send_decision( &self, input: SendDecisionInput<'_>, ) -> Result<SendDecision, String>

Decide how to handle a send, optionally with a precomputed payload.

fn handle_acquire( &self, _sid: SessionId, _role: &str, _layer: &str, _state: &[Value], ) -> Result<AcquireDecision, String>

Attempt to acquire a guard layer.

fn handle_release( &self, _sid: SessionId, _role: &str, _layer: &str, _evidence: &Value, _state: &[Value], ) -> Result<(), String>

Release a guard layer using previously acquired evidence.

fn topology_events( &self, _tick: u64, ) -> Result<Vec<TopologyPerturbation>, String>

Topology perturbations injected by the environment for this scheduler tick.

fn output_condition_hint( &self, _sid: SessionId, _role: &str, _state: &[Value], ) -> Option<OutputConditionHint>

Optional output-condition metadata for commit gating.