Skip to main content

telltale_vm/exec/
mod.rs

1//! Instruction dispatcher split by semantic concern.
2
3use crate::coroutine::Fault;
4use crate::effect::EffectHandler;
5use crate::instr::{Endpoint, Instr};
6use crate::session::SessionId;
7use crate::vm::{StepPack, VM};
8
9pub(crate) mod comm;
10pub(crate) mod control;
11pub(crate) mod guard_effect;
12pub(crate) mod helpers;
13pub(crate) mod ownership;
14pub(crate) mod session;
15pub(crate) mod speculation;
16
17/// Dispatch one instruction to its semantic execution module.
18pub(crate) fn step_instr(
19    vm: &mut VM,
20    coro_idx: usize,
21    ep: &Endpoint,
22    role: &str,
23    sid: SessionId,
24    instr: Instr,
25    handler: &dyn EffectHandler,
26) -> Result<StepPack, Fault> {
27    match instr {
28        Instr::Send { chan, val } => comm::step_send(vm, coro_idx, role, chan, val, handler),
29        Instr::Receive { chan, dst } => comm::step_receive(vm, coro_idx, role, chan, dst, handler),
30        Instr::Offer { chan, label } => comm::step_offer(vm, coro_idx, role, chan, &label, handler),
31        Instr::Choose { chan, table } => {
32            comm::step_choose(vm, coro_idx, role, chan, &table, handler)
33        }
34        Instr::Open {
35            roles,
36            local_types,
37            handlers,
38            dsts,
39        } => session::step_open(vm, coro_idx, role, &roles, &local_types, &handlers, &dsts),
40        Instr::Close { session } => session::step_close(vm, coro_idx, session),
41        Instr::Invoke { action, dst } => {
42            guard_effect::step_invoke(vm, coro_idx, role, action, dst, handler)
43        }
44        Instr::Acquire { layer, dst } => {
45            guard_effect::step_acquire(vm, coro_idx, ep, role, sid, &layer, dst, handler)
46        }
47        Instr::Release { layer, evidence } => {
48            guard_effect::step_release(vm, coro_idx, ep, role, sid, &layer, evidence, handler)
49        }
50        Instr::Fork { ghost } => speculation::step_fork(vm, coro_idx, role, sid, ghost),
51        Instr::Join => speculation::step_join(vm, coro_idx, role, sid),
52        Instr::Abort => speculation::step_abort(vm, coro_idx, role, sid),
53        Instr::Transfer {
54            endpoint,
55            target,
56            bundle,
57        } => ownership::step_transfer(vm, coro_idx, role, sid, endpoint, target, bundle),
58        Instr::Tag { fact, dst } => ownership::step_tag(vm, coro_idx, role, sid, fact, dst),
59        Instr::Check {
60            knowledge,
61            target,
62            dst,
63        } => ownership::step_check(vm, coro_idx, role, sid, knowledge, target, dst),
64        Instr::Set { dst, val } => Ok(control::step_set(dst, val)),
65        Instr::Move { dst, src } => control::step_move(vm, coro_idx, dst, src),
66        Instr::Jump { target } => Ok(control::step_jump(target)),
67        Instr::Spawn { target, args } => control::step_spawn(vm, coro_idx, target, &args),
68        Instr::Yield => Ok(control::step_yield()),
69        Instr::Halt => control::step_halt(vm, ep),
70    }
71}