bb-ops 0.3.3

Canonical concrete components for the bytesandbrains framework — syscalls, wire transport, backends, protocols, role implementations.
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57

//! `DeadlineMatch` syscall - first-arrival selector between a
//! `then` trigger and a `timeout` trigger. Sub-F.

use bb_ir::proto::onnx::NodeProto;
use bb_runtime::atomic::DispatchResult;
use bb_runtime::bus::OpError;
use bb_runtime::runtime::RuntimeResourceRef;
use bb_runtime::slot_value::SlotValue;
use bb_runtime::syscall::values::TriggerValue;

/// Marker struct.
pub struct DeadlineMatchOp;

/// Op domain.
pub const DOMAIN: &str = "ai.bytesandbrains.syscall";
/// Op type name.
pub const OP_TYPE: &str = "DeadlineMatch";

/// Invoke fn - emits a single `winner` Trigger per IR_AND_DSL.md
/// §5a. First-to-fire semantics: whichever of `then` / `timeout`
/// has a non-empty slot becomes the winner. Once a winner is
/// determined, the per-Op latch absorbs subsequent invocations so
/// downstream consumers don't double-fire.
pub fn invoke(
    _node: &NodeProto,
    inputs: &[(&str, &dyn SlotValue)],
    ctx: &mut RuntimeResourceRef<'_>,
) -> Result<DispatchResult, OpError> {
    if inputs.is_empty() {
        return Err(OpError {
            detail: "DeadlineMatch requires at least one input".to_string(),
            ..Default::default()
        });
    }
    // Latch on first fire per execution. Keyed by (OpRef, ExecId)
    // so the same op fires once per logical execution rather than
    // once per Node lifetime.
    let latch_key = (ctx.current.op_ref.as_u64(), ctx.current.exec_id.as_u64());
    if !ctx.syscall.deadline_match_fired.insert(latch_key) {
        return Ok(DispatchResult::Immediate(vec![]));
    }
    Ok(DispatchResult::Immediate(vec![(
        "winner".to_string(),
        Box::new(TriggerValue),
    )]))
}

use bb_runtime::registry::OpRegistration as _BbOpsSyscallReg;

inventory::submit! {
    _BbOpsSyscallReg {
        domain: DOMAIN,
        op_type: OP_TYPE,
        invoke,
        kind: bb_runtime::registry::RegistrationKind::Syscall,
    }
}