{"header":{"message":"eval-vm: increment 3 — first real effect leaf host_backend_call (async bytes-in/bytes-out over a real socket round-trip, bridged into Lwt; two calls overlap). Bytes marshaling both ways via caml_string_length/caml_alloc_string.","description":null,"timestamp":"2026-08-04T21:36:59.265103093Z","authors":[{}]},"hash":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC","eval-vm: increment 3 — first real effect leaf host_backend_call (async bytes-in/bytes-out over a real socket round-trip, bridged into Lwt; two calls overlap). Bytes marshaling both ways via caml_string_length/caml_alloc_string."],["AA",null],["7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC","eval-vm: Rust host embedding a sandboxed OCaml bytecode VM (increments 1-2) — curated prim table (no IO), async host prims bridged into Lwt (Lwt.all overlaps); crates ocaml-vm-sys/-build/-vm + demo"]],"deps":["7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC"],"known":[]},"hunks":[{"Replacement":{"inode":{"change":2,"pos":501},"path":"eval-vm/ocaml-vm-sys/src/lib.rs","line":2,"ins":{"up_context":[{"change":2,"pos":579}],"down_context":[{"change":2,"pos":698}],"flag":"BLOCK","start":0,"end":137,"inode":{"change":2,"pos":501}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":579},"to":{"change":2,"start":579,"end":698},"introduced_by":2}],"inode":{"change":2,"pos":501}},"ins_contents":[{"Add":{"text":"//! points and value helpers we drive. The curated primitive table is supplied","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:78"}},{"Add":{"text":"//! by the final binary (see `ocaml-vm-build`), not here.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:136"}}],"del_contents":[{"Del":{"text":"//! points we drive. The curated primitive table is supplied by the final","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:652"}},{"Del":{"text":"//! binary (see `ocaml-vm-build`), not here.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:697"}}]}},{"Edit":{"inode":{"change":2,"pos":501},"path":"eval-vm/ocaml-vm-sys/src/lib.rs","line":11,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":1016}],"down_context":[{"change":2,"pos":1016}],"flag":"BLOCK","start":138,"end":459,"inode":{"change":2,"pos":501}}},"contents":[{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:138"}},{"Add":{"text":" /// Byte length of an OCaml `string`/`bytes` value.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:194"}},{"Add":{"text":" pub fn caml_string_length(v: usize) -> usize;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:244"}},{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:245"}},{"Add":{"text":" /// Allocate an OCaml `string` of `len` bytes (uninitialised). May trigger","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:324"}},{"Add":{"text":" /// GC, so copy any input out first and hold no other OCaml pointer across it.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:407"}},{"Add":{"text":" pub fn caml_alloc_string(len: usize) -> usize;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:458"}}]}},{"Replacement":{"inode":{"change":2,"pos":17043},"path":"eval-vm/ocaml-vm/src/lib.rs","line":5,"ins":{"up_context":[{"change":2,"pos":17268}],"down_context":[{"change":2,"pos":17340}],"flag":"BLOCK","start":460,"end":575,"inode":{"change":2,"pos":17043}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":17268},"to":{"change":2,"start":17268,"end":17340},"introduced_by":2}],"inode":{"change":2,"pos":17043}},"ins_contents":[{"Add":{"text":"//! runtime and offers the value <-> bytes helpers. Single VM per process (the","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:538"}},{"Add":{"text":"//! OCaml runtime is global state).","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:574"}}],"del_contents":[{"Del":{"text":"//! runtime. Single VM per process (the OCaml runtime is global state).","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:17339"}}]}},{"Edit":{"inode":{"change":2,"pos":17043},"path":"eval-vm/ocaml-vm/src/lib.rs","line":22,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":18004}],"down_context":[],"flag":"BLOCK","start":576,"end":1382,"inode":{"change":2,"pos":17043}}},"contents":[{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:576"}},{"Add":{"text":"/// View an OCaml `string`/`bytes` value's bytes. The slice borrows OCaml-managed","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:658"}},{"Add":{"text":"/// memory: copy it out (`.to_vec()`) before any allocation/GC or before handing","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:739"}},{"Add":{"text":"/// control back to OCaml.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:766"}},{"Add":{"text":"///","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:770"}},{"Add":{"text":"/// # Safety","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:783"}},{"Add":{"text":"/// `v` must be a live OCaml string value.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:826"}},{"Add":{"text":"pub unsafe fn bytes_of_value(v: usize) -> &'static [u8] {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:884"}},{"Add":{"text":" let len = ocaml_vm_sys::caml_string_length(v);","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:935"}},{"Add":{"text":" std::slice::from_raw_parts(v as *const u8, len)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:987"}},{"Add":{"text":"}","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:989"}},{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:990"}},{"Add":{"text":"/// Allocate an OCaml `string` holding `b`. Copies `b` in; `b` must not alias","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1068"}},{"Add":{"text":"/// OCaml memory (the allocation may move the heap).","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1121"}},{"Add":{"text":"///","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1125"}},{"Add":{"text":"/// # Safety","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1138"}},{"Add":{"text":"/// Must run on the OCaml thread (holding the runtime lock).","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1199"}},{"Add":{"text":"pub unsafe fn value_of_bytes(b: &[u8]) -> usize {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1249"}},{"Add":{"text":" let v = ocaml_vm_sys::caml_alloc_string(b.len());","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1303"}},{"Add":{"text":" std::ptr::copy_nonoverlapping(b.as_ptr(), v as *mut u8, b.len());","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1373"}},{"Add":{"text":" v","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1379"}},{"Add":{"text":"}","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1381"}}]}},{"Replacement":{"inode":{"change":2,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":10,"ins":{"up_context":[{"change":2,"pos":18587}],"down_context":[{"change":2,"pos":18667}],"flag":"BLOCK","start":1383,"end":1452,"inode":{"change":2,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":18587},"to":{"change":2,"start":18587,"end":18667},"introduced_by":2}],"inode":{"change":2,"pos":18039}},"ins_contents":[{"Add":{"text":"//! Results are byte buffers (a gRPC reply, a file's contents, ...).","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1451"}}],"del_contents":[{"Del":{"text":"//! Results are `i64` here (enough for the spike); the real host carries bytes.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:18666"}}]}},{"Replacement":{"inode":{"change":2,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":18,"ins":{"up_context":[{"change":2,"pos":18837}],"down_context":[{"change":2,"pos":18869}],"flag":"BLOCK","start":1453,"end":1489,"inode":{"change":2,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":18837},"to":{"change":2,"start":18837,"end":18869},"introduced_by":2}],"inode":{"change":2,"pos":18039}},"ins_contents":[{"Add":{"text":" results: HashMap>,","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1488"}}],"del_contents":[{"Del":{"text":" results: HashMap,","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:18868"}}]}},{"Replacement":{"inode":{"change":2,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":35,"ins":{"up_context":[{"change":2,"pos":19253}],"down_context":[{"change":2,"pos":19304}],"flag":"BLOCK","start":1490,"end":1545,"inode":{"change":2,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":19253},"to":{"change":2,"start":19253,"end":19304},"introduced_by":2}],"inode":{"change":2,"pos":18039}},"ins_contents":[{"Add":{"text":" pub fn complete(&self, id: i64, result: Vec) {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1544"}}],"del_contents":[{"Del":{"text":" pub fn complete(&self, id: i64, result: i64) {","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19303"}}]}},{"Replacement":{"inode":{"change":2,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":59,"ins":{"up_context":[{"change":2,"pos":19967}],"down_context":[{"change":2,"pos":20083}],"flag":"BLOCK","start":1546,"end":1738,"inode":{"change":2,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":19967},"to":{"change":2,"start":19967,"end":20083},"introduced_by":2}],"inode":{"change":2,"pos":18039}},"ins_contents":[{"Add":{"text":" pub fn take_result(&self, id: i64) -> Vec {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1597"}},{"Add":{"text":" self.inner","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1616"}},{"Add":{"text":" .lock()","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1636"}},{"Add":{"text":" .unwrap()","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1658"}},{"Add":{"text":" .results","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1679"}},{"Add":{"text":" .remove(&id)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1704"}},{"Add":{"text":" .unwrap_or_default()","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1737"}}],"del_contents":[{"Del":{"text":" pub fn take_result(&self, id: i64) -> i64 {","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:20014"}},{"Del":{"text":" self.inner.lock().unwrap().results.remove(&id).unwrap_or(0)","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:20082"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":1,"ins":{"up_context":[{"change":2,"pos":20888}],"down_context":[{"change":2,"pos":21099}],"flag":"BLOCK","start":1739,"end":2114,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":20888},"to":{"change":2,"start":20889,"end":21099},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"//! Increment-3 demo: the first real effect leaf, `host_backend_call`.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1809"}},{"Add":{"text":"//! An async bytes-in/bytes-out primitive that does REAL network I/O (a TCP","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1885"}},{"Add":{"text":"//! round-trip) off the OCaml thread, bridged into Lwt via the completion queue.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1966"}},{"Add":{"text":"//! Swapping the worker body for a tonic gRPC call to the elpe backend is the","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2044"}},{"Add":{"text":"//! only change needed for production. Two concurrent calls overlap.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2113"}}],"del_contents":[{"Del":{"text":"//! Increment-2 demo: a Rust host driving the curated OCaml bytecode VM, with an","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:20969"}},{"Del":{"text":"//! ASYNC host effect bridged into Lwt. Worker threads (tokio in production)","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21046"}},{"Del":{"text":"//! complete out of order; `Lwt.all` overlaps them.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21098"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":7,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":21129}],"down_context":[{"change":2,"pos":21129}],"flag":"BLOCK","start":2115,"end":2163,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"use ocaml_vm::{bytes_of_value, value_of_bytes};","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2162"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":9,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":21149}],"down_context":[{"change":2,"pos":21149}],"flag":"BLOCK","start":2164,"end":2232,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"use std::io::{Read, Write};","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2191"}},{"Add":{"text":"use std::net::{TcpListener, TcpStream};","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2231"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":12,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":21175}],"down_context":[{"change":2,"pos":21175}],"flag":"BLOCK","start":2233,"end":2258,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"use std::sync::OnceLock;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2257"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":15,"ins":{"up_context":[{"change":2,"pos":21201}],"down_context":[{"change":2,"pos":21255}],"flag":"BLOCK","start":2259,"end":2293,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":21201},"to":{"change":2,"start":21201,"end":21255},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"// OCaml int <-> C value tagging.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2292"}}],"del_contents":[{"Del":{"text":"// OCaml int <-> C value tagging (Val_int / Int_val).","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21254"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":22,"ins":{"up_context":[{"change":2,"pos":21357}],"down_context":[{"change":2,"pos":21387}],"flag":"BLOCK","start":2294,"end":3324,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":21357},"to":{"change":2,"start":21357,"end":21387},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":" ((n << 1) | 1) as usize","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2321"}},{"Add":{"text":"}","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2323"}},{"Add":{"text":"const UNIT: usize = 1;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2346"}},{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2347"}},{"Add":{"text":"static BACKEND_PORT: OnceLock = OnceLock::new();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2401"}},{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2402"}},{"Add":{"text":"/// A stand-in backend: read a request \"`DELAY_MS payload`\", wait, echo the","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2478"}},{"Add":{"text":"/// payload back. Stands in for the elpe gRPC server; the point is that","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2550"}},{"Add":{"text":"/// host_backend_call does a genuine async round-trip over a socket.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2619"}},{"Add":{"text":"fn start_backend() -> u16 {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2647"}},{"Add":{"text":" let listener = TcpListener::bind(\"127.0.0.1:0\").unwrap();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2709"}},{"Add":{"text":" let port = listener.local_addr().unwrap().port();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2763"}},{"Add":{"text":" std::thread::spawn(move || {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2796"}},{"Add":{"text":" for stream in listener.incoming().flatten() {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2850"}},{"Add":{"text":" std::thread::spawn(move || handle(stream));","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2906"}},{"Add":{"text":" }","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2916"}},{"Add":{"text":" });","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2924"}},{"Add":{"text":" port","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2933"}},{"Add":{"text":"}","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2935"}},{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2936"}},{"Add":{"text":"fn handle(mut s: TcpStream) {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2966"}},{"Add":{"text":" let mut req = Vec::new();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2996"}},{"Add":{"text":" s.read_to_end(&mut req).ok(); // client shuts down its write side","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3066"}},{"Add":{"text":" let text = String::from_utf8_lossy(&req);","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3112"}},{"Add":{"text":" let (delay, payload) = text.split_once(' ').unwrap_or((\"0\", &text));","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3185"}},{"Add":{"text":" std::thread::sleep(Duration::from_millis(delay.parse().unwrap_or(0)));","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3260"}},{"Add":{"text":" let _ = s.write_all(format!(\"echo:{payload}\").as_bytes());","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3323"}}],"del_contents":[{"Del":{"text":" (((n) << 1) | 1) as usize","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21386"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":50,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":21389},"to":{"change":2,"start":21389,"end":21426},"introduced_by":2}],"inode":{"change":2,"pos":20888}}},"contents":[{"Del":{"text":"const UNIT: usize = 1; // Val_int(0)","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21425"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":51,"ins":{"up_context":[{"change":2,"pos":21427}],"down_context":[{"change":2,"pos":21577}],"flag":"BLOCK","start":3325,"end":3481,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":21427},"to":{"change":2,"start":21427,"end":21577},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"/// `external host_backend_call : int -> string -> unit` — fire request bytes at","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3407"}},{"Add":{"text":"/// the backend for effect `id`; the reply arrives later via the bridge.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3480"}}],"del_contents":[{"Del":{"text":"/// `external host_start : int -> int -> unit` — launch an async effect `id`","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21505"}},{"Del":{"text":"/// that completes after `ms`, resolving to `ms`. Returns immediately.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21576"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":54,"ins":{"up_context":[{"change":2,"pos":21590}],"down_context":[{"change":2,"pos":21699}],"flag":"BLOCK","start":3482,"end":3761,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":21590},"to":{"change":2,"start":21590,"end":21699},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"pub extern \"C\" fn host_backend_call(id: usize, req: usize) -> usize {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3551"}},{"Add":{"text":" let id = int_val(id);","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3577"}},{"Add":{"text":" // Copy the request OUT of OCaml memory before crossing threads / allowing GC.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3660"}},{"Add":{"text":" let req = unsafe { bytes_of_value(req) }.to_vec();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3715"}},{"Add":{"text":" let port = *BACKEND_PORT.get().unwrap();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3760"}}],"del_contents":[{"Del":{"text":"pub extern \"C\" fn host_start(id: usize, ms: usize) -> usize {","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21651"}},{"Del":{"text":" let (id, ms) = (int_val(id), int_val(ms));","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21698"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":61,"ins":{"up_context":[{"change":2,"pos":21754}],"down_context":[{"change":2,"pos":21891}],"flag":"BLOCK","start":3762,"end":3938,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":21754},"to":{"change":2,"start":21754,"end":21891},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":" let reply = round_trip(port, &req).unwrap_or_else(|e| format!(\"error:{e}\").into_bytes());","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3859"}},{"Add":{"text":" global().complete(id, reply); // stand-in for a tokio gRPC completion","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3937"}}],"del_contents":[{"Del":{"text":" std::thread::sleep(Duration::from_millis(ms as u64));","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21815"}},{"Del":{"text":" global().complete(id, ms); // stand-in for a gRPC/build completion","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21890"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":65,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":21908}],"down_context":[{"change":2,"pos":21908}],"flag":"BLOCK","start":3939,"end":4209,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"}","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3940"}},{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3941"}},{"Add":{"text":"fn round_trip(port: u16, req: &[u8]) -> std::io::Result> {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4008"}},{"Add":{"text":" let mut s = TcpStream::connect((\"127.0.0.1\", port))?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4066"}},{"Add":{"text":" s.write_all(req)?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4089"}},{"Add":{"text":" s.shutdown(std::net::Shutdown::Write)?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4133"}},{"Add":{"text":" let mut resp = Vec::new();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4164"}},{"Add":{"text":" s.read_to_end(&mut resp)?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4195"}},{"Add":{"text":" Ok(resp)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4208"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":76,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":21911}],"down_context":[{"change":2,"pos":21911}],"flag":"BLOCK","start":4210,"end":4452,"inode":{"change":2,"pos":20888}}},"contents":[{"Add":{"text":"/// `external host_result_bytes : int -> string` — the reply bytes for `id`.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4288"}},{"Add":{"text":"#[no_mangle]","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4301"}},{"Add":{"text":"pub extern \"C\" fn host_result_bytes(id: usize) -> usize {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4359"}},{"Add":{"text":" let bytes = global().take_result(int_val(id));","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4410"}},{"Add":{"text":" unsafe { value_of_bytes(&bytes) }","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4448"}},{"Add":{"text":"}","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4450"}},{"Add":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4451"}}]}},{"Edit":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":87,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":22082},"to":{"change":2,"start":22082,"end":22275},"introduced_by":2}],"inode":{"change":2,"pos":20888}}},"contents":[{"Del":{"text":"}","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22083"}},{"Del":{"text":"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22084"}},{"Del":{"text":"/// `external host_result : int -> int` — the result an effect resolved to.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22162"}},{"Del":{"text":"#[no_mangle]","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22175"}},{"Del":{"text":"pub extern \"C\" fn host_result(id: usize) -> usize {","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22227"}},{"Del":{"text":" val_int(global().take_result(int_val(id)))","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22274"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":103,"ins":{"up_context":[{"change":2,"pos":22730}],"down_context":[{"change":2,"pos":22933}],"flag":"BLOCK","start":4453,"end":4509,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":22730},"to":{"change":2,"start":22730,"end":22933},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"// Keep the host prims from being dead-code-eliminated.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4508"}}],"del_contents":[{"Del":{"text":"// Keep the host prims from being dead-code-eliminated; the curated table","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22803"}},{"Del":{"text":"// references them by symbol at link time. `#[used]` on a typed fn-pointer","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22878"}},{"Del":{"text":"// static (per prim, since arities differ) is enough.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:22932"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":105,"ins":{"up_context":[{"change":2,"pos":22941}],"down_context":[{"change":2,"pos":23003}],"flag":"BLOCK","start":4510,"end":4579,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":22941},"to":{"change":2,"start":22941,"end":23003},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"static K0: extern \"C\" fn(usize, usize) -> usize = host_backend_call;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4578"}}],"del_contents":[{"Del":{"text":"static K0: extern \"C\" fn(usize, usize) -> usize = host_start;","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23002"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":107,"ins":{"up_context":[{"change":2,"pos":23011}],"down_context":[{"change":2,"pos":23065}],"flag":"BLOCK","start":4580,"end":4642,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23011},"to":{"change":2,"start":23011,"end":23065},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"static K1: extern \"C\" fn(usize) -> usize = host_result_bytes;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4641"}}],"del_contents":[{"Del":{"text":"static K1: extern \"C\" fn(usize) -> usize = host_wait;","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23064"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":109,"ins":{"up_context":[{"change":2,"pos":23073}],"down_context":[{"change":2,"pos":23129}],"flag":"BLOCK","start":4643,"end":4697,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23073},"to":{"change":2,"start":23073,"end":23129},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":"static K2: extern \"C\" fn(usize) -> usize = host_wait;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4696"}}],"del_contents":[{"Del":{"text":"static K2: extern \"C\" fn(usize) -> usize = host_result;","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23128"}}]}},{"Replacement":{"inode":{"change":2,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":116,"ins":{"up_context":[{"change":2,"pos":23268}],"down_context":[{"change":2,"pos":23352}],"flag":"BLOCK","start":4698,"end":4846,"inode":{"change":2,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23268},"to":{"change":2,"start":23268,"end":23352},"introduced_by":2}],"inode":{"change":2,"pos":20888}},"ins_contents":[{"Add":{"text":" let port = start_backend();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4729"}},{"Add":{"text":" BACKEND_PORT.set(port).unwrap();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4766"}},{"Add":{"text":" println!(\"[demo] backend on 127.0.0.1:{port}; driving embedded OCaml VM\");","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4845"}}],"del_contents":[{"Del":{"text":" println!(\"[demo] driving embedded OCaml bytecode VM from Rust (async bridge)\");","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23351"}}]}},{"Replacement":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":1,"ins":{"up_context":[{"change":2,"pos":23492}],"down_context":[{"change":2,"pos":24115}],"flag":"BLOCK","start":4847,"end":5447,"inode":{"change":2,"pos":23492}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":23492},"to":{"change":2,"start":23493,"end":24115},"introduced_by":2}],"inode":{"change":2,"pos":23492}},"ins_contents":[{"Add":{"text":"(* Untrusted eval stand-in exercising the first real effect leaf.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4912"}},{"Add":{"text":" [backend_call] is an async request/reply over a socket, fulfilled by a Rust","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4991"}},{"Add":{"text":" worker and bridged into Lwt. Two calls run concurrently (Lwt.all) and","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5064"}},{"Add":{"text":" overlap; the reply BYTES round-trip correctly. Raw IO stays denied. *)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5138"}},{"Add":{"text":"external host_emit : string -> unit = \"host_emit\"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5196"}},{"Add":{"text":"external host_backend_call : int -> string -> unit = \"host_backend_call\"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5269"}},{"Add":{"text":"external host_result_bytes : int -> string = \"host_result_bytes\"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5334"}},{"Add":{"text":"external host_wait : unit -> int = \"host_wait\"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5389"}},{"Add":{"text":"external now_ms : unit -> int = \"host_now_ms\"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5446"}}],"del_contents":[{"Del":{"text":"(* Untrusted eval stand-in, now with real concurrency.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23547"}},{"Del":{"text":" Host effects are async Lwt promises fulfilled by Rust worker threads; a DIY","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23626"}},{"Del":{"text":" run loop drives Lwt off the completion bridge (no Lwt_unix -> no Unix prims).","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23707"}},{"Del":{"text":" Lwt.all over out-of-order effects overlaps (elapsed = max, not sum). Raw IO","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23786"}},{"Del":{"text":" (open_out -> caml_sys_open) stays denied by the curated table. *)","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23855"}},{"Del":{"text":"external host_emit : string -> unit = \"host_emit\"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23907"}},{"Del":{"text":"external host_start : int -> int -> unit = \"host_start\"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:23964"}},{"Del":{"text":"external host_wait : unit -> int = \"host_wait\"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24013"}},{"Del":{"text":"external host_result : int -> int = \"host_result\"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24063"}},{"Del":{"text":"external now_ms : unit -> int = \"host_now_ms\"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24114"}}]}},{"Replacement":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":11,"ins":{"up_context":[{"change":2,"pos":24116}],"down_context":[{"change":2,"pos":24173}],"flag":"BLOCK","start":5448,"end":5508,"inode":{"change":2,"pos":23492}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24116},"to":{"change":2,"start":24116,"end":24173},"introduced_by":2}],"inode":{"change":2,"pos":23492}},"ins_contents":[{"Add":{"text":"let tbl : (int, string Lwt.u) Hashtbl.t = Hashtbl.create 16","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5507"}}],"del_contents":[{"Del":{"text":"let tbl : (int, int Lwt.u) Hashtbl.t = Hashtbl.create 16","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24172"}}]}},{"Replacement":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":14,"ins":{"up_context":[{"change":2,"pos":24190}],"down_context":[{"change":2,"pos":24270}],"flag":"BLOCK","start":5509,"end":5607,"inode":{"change":2,"pos":23492}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24190},"to":{"change":2,"start":24190,"end":24270},"introduced_by":2}],"inode":{"change":2,"pos":23492}},"ins_contents":[{"Add":{"text":"(* Async effect: send [req] to the backend, resolve to its reply bytes. *)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5583"}},{"Add":{"text":"let backend_call req =","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5606"}}],"del_contents":[{"Del":{"text":"(* An async host effect: completes after [ms], resolving to [ms]. *)","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24258"}},{"Del":{"text":"let h ms =","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24269"}}]}},{"Replacement":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":20,"ins":{"up_context":[{"change":2,"pos":24357}],"down_context":[{"change":2,"pos":24377}],"flag":"BLOCK","start":5608,"end":5636,"inode":{"change":2,"pos":23492}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24357},"to":{"change":2,"start":24357,"end":24377},"introduced_by":2}],"inode":{"change":2,"pos":23492}},"ins_contents":[{"Add":{"text":" host_backend_call id req;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5635"}}],"del_contents":[{"Del":{"text":" host_start id ms;","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24376"}}]}},{"Edit":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":23,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24382},"to":{"change":2,"start":24382,"end":24539},"introduced_by":2}],"inode":{"change":2,"pos":23492}}},"contents":[{"Del":{"text":"(* The bridge: run Lwt to completion, blocking in the host only when nothing is","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24461"}},{"Del":{"text":" runnable. This is the custom \"engine\" minus Lwt_engine's fd/timer API. *)","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24538"}}]}},{"Replacement":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":32,"ins":{"up_context":[{"change":2,"pos":24797}],"down_context":[{"change":2,"pos":24873}],"flag":"BLOCK","start":5637,"end":5719,"inode":{"change":2,"pos":23492}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":24797},"to":{"change":2,"start":24797,"end":24873},"introduced_by":2}],"inode":{"change":2,"pos":23492}},"ins_contents":[{"Add":{"text":" | Some r -> Hashtbl.remove tbl id; Lwt.wakeup r (host_result_bytes id)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5718"}}],"del_contents":[{"Del":{"text":" | Some r -> Hashtbl.remove tbl id; Lwt.wakeup r (host_result id)","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:24872"}}]}},{"Replacement":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":43,"ins":{"up_context":[{"change":2,"pos":25000}],"down_context":[{"change":2,"pos":25081}],"flag":"BLOCK","start":5720,"end":5853,"inode":{"change":2,"pos":23492}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":25000},"to":{"change":2,"start":25000,"end":25081},"introduced_by":2}],"inode":{"change":2,"pos":23492}},"ins_contents":[{"Add":{"text":" run","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5727"}},{"Add":{"text":" ( Lwt.all [ backend_call \"300 hello\"; backend_call \"100 world\" ]","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5798"}},{"Add":{"text":" >>= fun rs -> Lwt.return (rs, now_ms () - t0) )","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5852"}}],"del_contents":[{"Del":{"text":" run (Lwt.all [ h 300; h 100 ] >>= fun rs -> Lwt.return (rs, now_ms () - t0))","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:25080"}}]}},{"Replacement":{"inode":{"change":2,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":48,"ins":{"up_context":[{"change":2,"pos":25098}],"down_context":[{"change":2,"pos":25243}],"flag":"BLOCK","start":5854,"end":5966,"inode":{"change":2,"pos":23492}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":25098},"to":{"change":2,"start":25098,"end":25243},"introduced_by":2}],"inode":{"change":2,"pos":23492}},"ins_contents":[{"Add":{"text":" (Printf.sprintf \"Lwt.all backend_call = [%s]; elapsed = %d ms (%s)\"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5926"}},{"Add":{"text":" (String.concat \"; \" rs) elapsed","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5965"}}],"del_contents":[{"Del":{"text":" (Printf.sprintf \"Lwt.all [h 300; h 100] = [%s]; elapsed = %d ms (%s)\"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:25172"}},{"Del":{"text":" (String.concat \";\" (List.map string_of_int rs))","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:25227"}},{"Del":{"text":" elapsed","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:25242"}}]}},{"Replacement":{"inode":{"change":2,"pos":25468},"path":"eval-vm/demo/build.rs","line":24,"ins":{"up_context":[{"change":2,"pos":26286}],"down_context":[{"change":2,"pos":26308}],"flag":"BLOCK","start":5967,"end":6025,"inode":{"change":2,"pos":25468}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":26286},"to":{"change":2,"start":26286,"end":26308},"introduced_by":2}],"inode":{"change":2,"pos":25468}},"ins_contents":[{"Add":{"text":" \"host_backend_call\",","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:5995"}},{"Add":{"text":" \"host_result_bytes\",","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:6024"}}],"del_contents":[{"Del":{"text":" \"host_start\",","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:26307"}}]}},{"Edit":{"inode":{"change":2,"pos":25468},"path":"eval-vm/demo/build.rs","line":27,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":2,"pos":26329},"to":{"change":2,"start":26329,"end":26352},"introduced_by":2}],"inode":{"change":2,"pos":25468}}},"contents":[{"Del":{"text":" \"host_result\",","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:26351"}}]}}],"owner":"pmeunier","repo":"elpe","token":"5fcq/Lqw0v5bZaHhM3taejUl/m6IOASk4u6iblU1w+0=","login":null}

…

Dependencies

Change contents

Review