1use 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
17pub(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}