{"header":{"message":"eval-vm increment 7: host_backend_stream, the server-streaming effect leaf (twin of host_backend_call). Bridge carries chunk/last events (push_chunk/finish); tonic server_streaming pushes each decoded reply as a chunk and terminates at end-of-stream; Vm_prelude backend_stream feeds chunks to an Lwt callback (the grpc_call_streaming pattern) and resolves at EOS. Demo test streams a real Derivation RPC. Unblocks porting derivation.ml Derivation/UbuntuPackage.","description":null,"timestamp":"2026-08-05T04:40:25.665811997Z","authors":[{}]},"hash":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC","authors":[{"login":"pmeunier","key":"AAAAC3NzaC1lZDI1NTE5AAAAILagOJFgwaMNhBWQINinKOXmqS4Gh5NgxgriXwdOoINJ"}],"deps":{"hashes":[["W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC","eval-vm increment 7: host_backend_stream, the server-streaming effect leaf (twin of host_backend_call). Bridge carries chunk/last events (push_chunk/finish); tonic server_streaming pushes each decoded reply as a chunk and terminates at end-of-stream; Vm_prelude backend_stream feeds chunks to an Lwt callback (the grpc_call_streaming pattern) and resolves at EOS. Demo test streams a real Derivation RPC. Unblocks porting derivation.ml Derivation/UbuntuPackage."],["AA",null],["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","First working shell (with ocaml code)"],["KOWYPLMX4TCQANL33QW5VQTKWBQVCMOVLBQUQCTOK6YVQUHZJR5QC","Nix and config.toml"],["M3QHDB5R3JN7WDWAS2ZH5QP44TZ4DROYRUJFZ5Z7XP5OLC5MI24QC","seed & build: Nix-free bootstrap scripts, examples, workspace build scaffolding (flake/default/shell.nix, Cargo.*), .ignore hygiene, design notes"],["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"],["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."],["7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC","eval-vm: increment 4 — host_read_source (local_src leaf, CWD path policy in Rust; caml_failwith bridge) + OCaml Vm_prelude packaging the effect surface & Lwt run-loop so user bytecode is clean. Multi-source bytecode compile."],["JCR3N3JHGT5S2WZQRRF623Z2TTZZJMVRZ7TZC322HBYD5STP3GUAC","eval-vm: increment 6 — the REAL Elpe protobuf layer (ocaml-protoc-generated elpegrpc.ml, pure) runs INSIDE the curated sandbox VM. A real Handshake RPC is encoded/decoded with Service.make_client_functions (the exact grpc_call_unary pattern) and round-trips against the live backend -> real PlatformReply (arch=amd64). Proves the real-DSL port is mechanical: only the transport (h2 -> host_backend_call) changes."]],"deps":["UWQB743KR36X6A6JVNK3VH6KMEFUHOUT6ZS2Y2SWIJR55JSF5WQAC","KOWYPLMX4TCQANL33QW5VQTKWBQVCMOVLBQUQCTOK6YVQUHZJR5QC","M3QHDB5R3JN7WDWAS2ZH5QP44TZ4DROYRUJFZ5Z7XP5OLC5MI24QC","7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC","6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC","7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC","JCR3N3JHGT5S2WZQRRF623Z2TTZZJMVRZ7TZC322HBYD5STP3GUAC"],"known":[]},"hunks":[{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":11,"ins":{"up_context":[{"change":6,"pos":1452}],"down_context":[{"change":5,"pos":18710}],"flag":"BLOCK","start":4340,"end":4839,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":6,"pos":1452},"to":{"change":5,"start":18667,"end":18710},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":18667},"to":{"change":5,"start":18667,"end":18710},"introduced_by":5}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":"//!","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4343"}},{"Add":{"text":"//! Two effect shapes share the queue:","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4382"}},{"Add":{"text":"//! * unary — exactly one event, `last = true` (a `complete`);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4449"}},{"Add":{"text":"//! * server-streaming — zero or more chunk events (`last = false`, each a","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4528"}},{"Add":{"text":"//! decoded message) followed by one terminating event (`last = true`,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4603"}},{"Add":{"text":"//! empty payload) marking end-of-stream.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4649"}},{"Add":{"text":"//! `outstanding` counts an effect as in flight until its terminating (`last`)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4728"}},{"Add":{"text":"//! event is drained, so a stream keeps the loop awake across all its chunks.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4806"}},{"Add":{"text":"use std::collections::VecDeque;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4838"}}],"del_contents":[{"Del":{"text":"use std::collections::{HashMap, VecDeque};","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:18709"}}]}},{"Edit":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":23,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":18778}],"down_context":[{"change":5,"pos":18778}],"flag":"BLOCK","start":4840,"end":5027,"inode":{"change":5,"pos":18039}}},"contents":[{"Add":{"text":"/// One ready event for the OCaml loop: the bytes for effect `id`, and whether","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4918"}},{"Add":{"text":"/// this is the final event for that id.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4959"}},{"Add":{"text":"struct Event {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4974"}},{"Add":{"text":" id: i64,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4987"}},{"Add":{"text":" bytes: Vec,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5007"}},{"Add":{"text":" last: bool,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5023"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5025"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5026"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":33,"ins":{"up_context":[{"change":5,"pos":18812}],"down_context":[{"change":5,"pos":18869}],"flag":"BLOCK","start":5028,"end":5300,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":18812},"to":{"change":5,"start":18812,"end":18837},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":18837},"to":{"change":6,"start":1453,"end":1489},"introduced_by":6}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" done: VecDeque,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5054"}},{"Add":{"text":" /// The event most recently returned by `wait`, awaiting `take_result` /","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5131"}},{"Add":{"text":" /// `is_last`. The OCaml loop is single-threaded and always drains an event","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5211"}},{"Add":{"text":" /// fully before the next `wait`, so one slot suffices.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5271"}},{"Add":{"text":" current: Option,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5299"}}],"del_contents":[{"Del":{"text":" done: VecDeque,","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:18836"}},{"Del":{"text":" results: HashMap>,","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1488"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":53,"ins":{"up_context":[{"change":5,"pos":19177}],"down_context":[{"change":6,"pos":1490}],"flag":"BLOCK","start":5301,"end":5419,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":19177},"to":{"change":5,"start":19177,"end":19253},"introduced_by":5}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" /// A worker reports completion of a unary `id` with `result`, waking the","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5378"}},{"Add":{"text":" /// loop. Single terminating event.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5418"}}],"del_contents":[{"Del":{"text":" /// A worker reports completion of `id` with `result`, waking the loop.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19252"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":56,"ins":{"up_context":[{"change":6,"pos":1545}],"down_context":[{"change":5,"pos":19437}],"flag":"BLOCK","start":5420,"end":6119,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":6,"pos":1545},"to":{"change":5,"start":19304,"end":19437},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":19304},"to":{"change":5,"start":19304,"end":19437},"introduced_by":5}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" self.push(Event {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5445"}},{"Add":{"text":" id,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5461"}},{"Add":{"text":" bytes: result,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5488"}},{"Add":{"text":" last: true,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5512"}},{"Add":{"text":" });","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5524"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5530"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5531"}},{"Add":{"text":" /// A streaming worker reports one decoded chunk for `id` (not the last).","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5609"}},{"Add":{"text":" pub fn push_chunk(&self, id: i64, chunk: Vec) {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5665"}},{"Add":{"text":" self.push(Event {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5691"}},{"Add":{"text":" id,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5707"}},{"Add":{"text":" bytes: chunk,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5733"}},{"Add":{"text":" last: false,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5758"}},{"Add":{"text":" });","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5770"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5776"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5777"}},{"Add":{"text":" /// A streaming worker reports end-of-stream for `id` (terminating event,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5855"}},{"Add":{"text":" /// empty payload).","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5879"}},{"Add":{"text":" pub fn finish(&self, id: i64) {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5915"}},{"Add":{"text":" self.push(Event {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5941"}},{"Add":{"text":" id,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5957"}},{"Add":{"text":" bytes: Vec::new(),","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:5988"}},{"Add":{"text":" last: true,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6012"}},{"Add":{"text":" });","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6024"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6030"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6031"}},{"Add":{"text":" fn push(&self, ev: Event) {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6063"}},{"Add":{"text":" self.inner.lock().unwrap().done.push_back(ev);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6118"}}],"del_contents":[{"Del":{"text":" let mut g = self.inner.lock().unwrap();","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19351"}},{"Del":{"text":" g.results.insert(id, result);","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19389"}},{"Del":{"text":" g.done.push_back(id);","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19419"}},{"Del":{"text":" drop(g);","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19436"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":87,"ins":{"up_context":[{"change":5,"pos":19477}],"down_context":[{"change":5,"pos":19605}],"flag":"BLOCK","start":6120,"end":6330,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":19477},"to":{"change":5,"start":19477,"end":19605},"introduced_by":5}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" /// Block until an event is ready; stash it and return its id, or -1 if no","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6198"}},{"Add":{"text":" /// effect is in flight (so the OCaml loop can't deadlock). The caller then","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6278"}},{"Add":{"text":" /// reads it with `take_result` and `is_last`.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6329"}}],"del_contents":[{"Del":{"text":" /// Block until an effect completes; return its id, or -1 if none are in","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19553"}},{"Del":{"text":" /// flight (so the OCaml loop can't deadlock).","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19604"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":93,"ins":{"up_context":[{"change":5,"pos":19700}],"down_context":[{"change":5,"pos":19787}],"flag":"BLOCK","start":6331,"end":6539,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":19700},"to":{"change":5,"start":19700,"end":19787},"introduced_by":5}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" if let Some(ev) = g.done.pop_front() {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6381"}},{"Add":{"text":" if ev.last {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6410"}},{"Add":{"text":" g.outstanding -= 1;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6450"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6468"}},{"Add":{"text":" let id = ev.id;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6500"}},{"Add":{"text":" g.current = Some(ev);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6538"}}],"del_contents":[{"Del":{"text":" if let Some(id) = g.done.pop_front() {","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19750"}},{"Del":{"text":" g.outstanding -= 1;","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:19786"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":108,"ins":{"up_context":[{"change":5,"pos":19967}],"down_context":[{"change":6,"pos":1598}],"flag":"BLOCK","start":6540,"end":6646,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":19967},"to":{"change":6,"start":1546,"end":1598},"introduced_by":6}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" /// The bytes of the event `wait` just returned.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6592"}},{"Add":{"text":" pub fn take_result(&self, _id: i64) -> Vec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6645"}}],"del_contents":[{"Del":{"text":" pub fn take_result(&self, id: i64) -> Vec {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1597"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":113,"ins":{"up_context":[{"change":6,"pos":1659}],"down_context":[{"change":6,"pos":1705}],"flag":"BLOCK","start":6647,"end":6728,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":1659},"to":{"change":6,"start":1659,"end":1705},"introduced_by":6}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" .current","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6667"}},{"Add":{"text":" .as_ref()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6689"}},{"Add":{"text":" .map(|e| e.bytes.clone())","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6727"}}],"del_contents":[{"Del":{"text":" .results","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1679"}},{"Del":{"text":" .remove(&id)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1704"}}]}},{"Edit":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":117,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":1738}],"down_context":[{"change":5,"pos":20083}],"flag":"BLOCK","start":6729,"end":7078,"inode":{"change":5,"pos":18039}}},"contents":[{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6734"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6735"}},{"Add":{"text":" /// Whether the event `wait` just returned is the final one for its id","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6810"}},{"Add":{"text":" /// (unary reply, or a stream's end-of-stream marker).","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6869"}},{"Add":{"text":" pub fn is_last(&self, _id: i64) -> bool {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6915"}},{"Add":{"text":" self.inner","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6934"}},{"Add":{"text":" .lock()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6954"}},{"Add":{"text":" .unwrap()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6976"}},{"Add":{"text":" .current","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:6997"}},{"Add":{"text":" .as_ref()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7019"}},{"Add":{"text":" .map(|e| e.last)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7048"}},{"Add":{"text":" .unwrap_or(true)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7077"}}]}},{"Replacement":{"inode":{"change":5,"pos":18039},"path":"eval-vm/ocaml-vm/src/bridge.rs","line":140,"ins":{"up_context":[{"change":5,"pos":20385}],"down_context":[{"change":5,"pos":20430}],"flag":"BLOCK","start":7079,"end":7215,"inode":{"change":5,"pos":18039}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":20385},"to":{"change":5,"start":20385,"end":20430},"introduced_by":5}],"inode":{"change":5,"pos":18039}},"ins_contents":[{"Add":{"text":" inner: Mutex::new(Inner {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7112"}},{"Add":{"text":" done: VecDeque::new(),","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7147"}},{"Add":{"text":" current: None,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7174"}},{"Add":{"text":" outstanding: 0,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7202"}},{"Add":{"text":" }),","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7214"}}],"del_contents":[{"Del":{"text":" inner: Mutex::new(Inner::default()),","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:20429"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":1,"ins":{"up_context":[{"change":5,"pos":20888}],"down_context":[{"change":5,"pos":21099}],"flag":"BLOCK","start":7220,"end":7538,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":20888},"to":{"change":6,"start":1739,"end":2114},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":"//! Demo host: a Rust host driving the curated OCaml bytecode VM.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7285"}},{"Add":{"text":"//! `host_backend_call` is now a REAL tonic gRPC call (generic bytes passthrough)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7367"}},{"Add":{"text":"//! to the elpe backend on :50051, run on tokio off the OCaml thread and bridged","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7448"}},{"Add":{"text":"//! into Lwt. `host_read_source` is the local_src leaf (CWD-policed in Rust).","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7526"}},{"Add":{"text":"mod grpc;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7536"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7537"}}],"del_contents":[{"Del":{"text":"//! Increment-3 demo: the first real effect leaf, `host_backend_call`.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1809"}},{"Del":{"text":"//! An async bytes-in/bytes-out primitive that does REAL network I/O (a TCP","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1885"}},{"Del":{"text":"//! round-trip) off the OCaml thread, bridged into Lwt via the completion queue.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:1966"}},{"Del":{"text":"//! Swapping the worker body for a tonic gRPC call to the elpe backend is the","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2044"}},{"Del":{"text":"//! only change needed for production. Two concurrent calls overlap.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2113"}}]}},{"Edit":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":10,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21149},"to":{"change":6,"start":2164,"end":2232},"introduced_by":6}],"inode":{"change":5,"pos":20888}}},"contents":[{"Del":{"text":"use std::io::{Read, Write};","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2191"}},{"Del":{"text":"use std::net::{TcpListener, TcpStream};","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2231"}}]}},{"Edit":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":11,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21175},"to":{"change":6,"start":2233,"end":2258},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":2258},"to":{"change":5,"start":21175,"end":21200},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21175},"to":{"change":5,"start":21175,"end":21200},"introduced_by":5}],"inode":{"change":5,"pos":20888}}},"contents":[{"Del":{"text":"use std::sync::OnceLock;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2257"}},{"Del":{"text":"use std::time::Duration;","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21199"}}]}},{"Edit":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":22,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":2347},"to":{"change":6,"start":2347,"end":2402},"introduced_by":6}],"inode":{"change":5,"pos":20888}}},"contents":[{"Del":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2347"}},{"Del":{"text":"static BACKEND_PORT: OnceLock = OnceLock::new();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2401"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":23,"ins":{"up_context":[{"change":6,"pos":2403}],"down_context":[{"change":5,"pos":21577}],"flag":"BLOCK","start":7539,"end":7755,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":2403},"to":{"change":6,"start":2403,"end":3324},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":3324},"to":{"change":5,"start":21387,"end":21389},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21387},"to":{"change":5,"start":21387,"end":21389},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21426},"to":{"change":5,"start":21426,"end":21427},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21427},"to":{"change":6,"start":3325,"end":3481},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":"/// `external host_backend_call : int -> string -> string -> unit` — issue a","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7617"}},{"Add":{"text":"/// unary gRPC call (`path`, serialized-protobuf `req`) to the backend for effect","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7699"}},{"Add":{"text":"/// `id`; the reply bytes arrive later via the bridge.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7754"}}],"del_contents":[{"Del":{"text":"/// A stand-in backend: read a request \"`DELAY_MS payload`\", wait, echo the","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2478"}},{"Del":{"text":"/// payload back. Stands in for the elpe gRPC server; the point is that","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2550"}},{"Del":{"text":"/// host_backend_call does a genuine async round-trip over a socket.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2619"}},{"Del":{"text":"fn start_backend() -> u16 {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2647"}},{"Del":{"text":" let listener = TcpListener::bind(\"127.0.0.1:0\").unwrap();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2709"}},{"Del":{"text":" let port = listener.local_addr().unwrap().port();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2763"}},{"Del":{"text":" std::thread::spawn(move || {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2796"}},{"Del":{"text":" for stream in listener.incoming().flatten() {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2850"}},{"Del":{"text":" std::thread::spawn(move || handle(stream));","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2906"}},{"Del":{"text":" }","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2916"}},{"Del":{"text":" });","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2924"}},{"Del":{"text":" port","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2933"}},{"Del":{"text":"}","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2935"}},{"Del":{"text":"","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2936"}},{"Del":{"text":"fn handle(mut s: TcpStream) {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2966"}},{"Del":{"text":" let mut req = Vec::new();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:2996"}},{"Del":{"text":" s.read_to_end(&mut req).ok(); // client shuts down its write side","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3066"}},{"Del":{"text":" let text = String::from_utf8_lossy(&req);","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3112"}},{"Del":{"text":" let (delay, payload) = text.split_once(' ').unwrap_or((\"0\", &text));","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3185"}},{"Del":{"text":" std::thread::sleep(Duration::from_millis(delay.parse().unwrap_or(0)));","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3260"}},{"Del":{"text":" let _ = s.write_all(format!(\"echo:{payload}\").as_bytes());","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3323"}},{"Del":{"text":"}","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21388"}},{"Del":{"text":"","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21426"}},{"Del":{"text":"/// `external host_backend_call : int -> string -> unit` — fire request bytes at","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3407"}},{"Del":{"text":"/// the backend for effect `id`; the reply arrives later via the bridge.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3480"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":27,"ins":{"up_context":[{"change":5,"pos":21590}],"down_context":[{"change":6,"pos":3552}],"flag":"BLOCK","start":7756,"end":7839,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21590},"to":{"change":6,"start":3482,"end":3552},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":"pub extern \"C\" fn host_backend_call(id: usize, path: usize, req: usize) -> usize {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7838"}}],"del_contents":[{"Del":{"text":"pub extern \"C\" fn host_backend_call(id: usize, req: usize) -> usize {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3551"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":29,"ins":{"up_context":[{"change":6,"pos":3578}],"down_context":[{"change":6,"pos":3661}],"flag":"BLOCK","start":7840,"end":8031,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":3578},"to":{"change":6,"start":3578,"end":3661},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":" // Copy request + path OUT of OCaml memory before crossing threads / GC.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7916"}},{"Add":{"text":" let path = unsafe { CStr::from_ptr(path as *const c_char) }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:7980"}},{"Add":{"text":" .to_string_lossy()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8007"}},{"Add":{"text":" .into_owned();","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8030"}}],"del_contents":[{"Del":{"text":" // Copy the request OUT of OCaml memory before crossing threads / allowing GC.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3660"}}]}},{"Edit":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":34,"atom":{"EdgeMap":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":3716},"to":{"change":6,"start":3716,"end":3761},"introduced_by":6}],"inode":{"change":5,"pos":20888}}},"contents":[{"Del":{"text":" let port = *BACKEND_PORT.get().unwrap();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3760"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":35,"ins":{"up_context":[{"change":5,"pos":21721}],"down_context":[{"change":5,"pos":21899}],"flag":"BLOCK","start":8032,"end":8103,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21721},"to":{"change":5,"start":21721,"end":21754},"introduced_by":5},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21754},"to":{"change":6,"start":3762,"end":3938},"introduced_by":6},{"previous":"","flag":"DELETED","from":{"change":6,"pos":3938},"to":{"change":5,"start":21891,"end":21899},"introduced_by":6},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21891},"to":{"change":5,"start":21891,"end":21899},"introduced_by":5}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":" grpc::unary(path, req, move |reply| global().complete(id, reply));","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8102"}}],"del_contents":[{"Del":{"text":" std::thread::spawn(move || {","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21753"}},{"Del":{"text":" let reply = round_trip(port, &req).unwrap_or_else(|e| format!(\"error:{e}\").into_bytes());","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3859"}},{"Del":{"text":" global().complete(id, reply); // stand-in for a tokio gRPC completion","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:3937"}},{"Del":{"text":" });","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:21898"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":39,"ins":{"up_context":[{"change":6,"pos":3942}],"down_context":[{"change":5,"pos":21908}],"flag":"BLOCK","start":8104,"end":9365,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":6,"pos":3942},"to":{"change":6,"start":3942,"end":4209},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":"/// `external host_backend_stream : int -> string -> string -> unit` — issue a","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8184"}},{"Add":{"text":"/// server-streaming gRPC call (`path`, serialized-protobuf `req`) to the backend","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8266"}},{"Add":{"text":"/// for effect `id`. Each decoded reply message arrives as a bridge chunk; the","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8345"}},{"Add":{"text":"/// stream's end arrives as the terminating event. The OCaml side interleaves the","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8427"}},{"Add":{"text":"/// chunks into its per-effect Lwt callback.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8472"}},{"Add":{"text":"#[no_mangle]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8485"}},{"Add":{"text":"pub extern \"C\" fn host_backend_stream(id: usize, path: usize, req: usize) -> usize {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8570"}},{"Add":{"text":" let id = int_val(id);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8596"}},{"Add":{"text":" let path = unsafe { CStr::from_ptr(path as *const c_char) }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8660"}},{"Add":{"text":" .to_string_lossy()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8687"}},{"Add":{"text":" .into_owned();","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8710"}},{"Add":{"text":" let req = unsafe { bytes_of_value(req) }.to_vec();","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8765"}},{"Add":{"text":" global().begin();","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8787"}},{"Add":{"text":" grpc::server_streaming(","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8815"}},{"Add":{"text":" path,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8829"}},{"Add":{"text":" req,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8842"}},{"Add":{"text":" move |chunk| global().push_chunk(id, chunk),","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8895"}},{"Add":{"text":" move |err| match err {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:8926"}},{"Add":{"text":" // Surface a transport error as a final chunk the OCaml decoder will","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9007"}},{"Add":{"text":" // reject, then close the stream. (The DSL treats decode failure as a","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9089"}},{"Add":{"text":" // transport error, matching the h2 path.)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9144"}},{"Add":{"text":" Some(e) => {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9169"}},{"Add":{"text":" global().push_chunk(id, format!(\"error:{e}\").into_bytes());","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9245"}},{"Add":{"text":" global().finish(id);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9282"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9296"}},{"Add":{"text":" None => global().finish(id),","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9337"}},{"Add":{"text":" },","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9348"}},{"Add":{"text":" );","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9355"}},{"Add":{"text":" UNIT","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9364"}}],"del_contents":[{"Del":{"text":"fn round_trip(port: u16, req: &[u8]) -> std::io::Result> {","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4008"}},{"Del":{"text":" let mut s = TcpStream::connect((\"127.0.0.1\", port))?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4066"}},{"Del":{"text":" s.write_all(req)?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4089"}},{"Del":{"text":" s.shutdown(std::net::Shutdown::Write)?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4133"}},{"Del":{"text":" let mut resp = Vec::new();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4164"}},{"Del":{"text":" s.read_to_end(&mut resp)?;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4195"}},{"Del":{"text":" Ok(resp)","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4208"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":89,"ins":{"up_context":[{"change":7,"pos":2327}],"down_context":[{"change":6,"pos":4289}],"flag":"BLOCK","start":9366,"end":9502,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"","flag":"DELETED","from":{"change":7,"pos":2327},"to":{"change":6,"start":4210,"end":4289},"introduced_by":7},{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":21911},"to":{"change":6,"start":4210,"end":4289},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":"/// `external host_result_bytes : int -> string` — the reply/chunk bytes for the","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9448"}},{"Add":{"text":"/// event `host_wait` just returned (`id` names it).","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9501"}}],"del_contents":[{"Del":{"text":"/// `external host_result_bytes : int -> string` — the reply bytes for `id`.","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4288"}}]}},{"Edit":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":97,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":4452}],"down_context":[{"change":5,"pos":21911}],"flag":"BLOCK","start":9503,"end":9816,"inode":{"change":5,"pos":20888}}},"contents":[{"Add":{"text":"/// `external host_is_last : int -> bool` — whether that event is the final one","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9584"}},{"Add":{"text":"/// for `id` (a unary reply, or a stream's end-of-stream marker).","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9650"}},{"Add":{"text":"#[no_mangle]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9663"}},{"Add":{"text":"pub extern \"C\" fn host_is_last(id: usize) -> usize {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9716"}},{"Add":{"text":" if global().is_last(int_val(id)) {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9755"}},{"Add":{"text":" val_int(1)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9774"}},{"Add":{"text":" } else {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9787"}},{"Add":{"text":" val_int(0)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9806"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9812"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9814"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9815"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":130,"ins":{"up_context":[{"change":5,"pos":22941}],"down_context":[{"change":5,"pos":23003}],"flag":"BLOCK","start":9817,"end":9893,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":22941},"to":{"change":6,"start":4510,"end":4579},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":"static K0: extern \"C\" fn(usize, usize, usize) -> usize = host_backend_call;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9892"}}],"del_contents":[{"Del":{"text":"static K0: extern \"C\" fn(usize, usize) -> usize = host_backend_call;","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4578"}}]}},{"Edit":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":133,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":4642}],"down_context":[{"change":5,"pos":23065}],"flag":"BLOCK","start":9894,"end":10045,"inode":{"change":5,"pos":20888}}},"contents":[{"Add":{"text":"#[used]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9901"}},{"Add":{"text":"static K6: extern \"C\" fn(usize) -> usize = host_is_last;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9958"}},{"Add":{"text":"#[used]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:9966"}},{"Add":{"text":"static K7: extern \"C\" fn(usize, usize, usize) -> usize = host_backend_stream;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10044"}}]}},{"Replacement":{"inode":{"change":5,"pos":20888},"path":"eval-vm/demo/src/main.rs","line":147,"ins":{"up_context":[{"change":5,"pos":23268}],"down_context":[{"change":5,"pos":23352}],"flag":"BLOCK","start":10046,"end":10129,"inode":{"change":5,"pos":20888}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":23268},"to":{"change":6,"start":4698,"end":4846},"introduced_by":6}],"inode":{"change":5,"pos":20888}},"ins_contents":[{"Add":{"text":" println!(\"[demo] gRPC to backend 127.0.0.1:50051; driving embedded OCaml VM\");","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10128"}}],"del_contents":[{"Del":{"text":" let port = start_backend();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4729"}},{"Del":{"text":" BACKEND_PORT.set(port).unwrap();","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4766"}},{"Del":{"text":" println!(\"[demo] backend on 127.0.0.1:{port}; driving embedded OCaml VM\");","pos":"6SSYBO2KOD3UVRNSVJ7KITNEEJYXSK2QZO4WP7DGZHABKDWKZWWAC:4845"}}]}},{"FileAdd":{"meta":{"basename":"grpc.rs","metadata":0},"context":[{"change":5,"pos":20854}],"contents":[{"Add":{"text":"//! Real gRPC transport for the backend effect leaf: a GENERIC bytes-passthrough","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:82"}},{"Add":{"text":"//! tonic client. The OCaml DSL serializes its protobuf request and names the","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:160"}},{"Add":{"text":"//! method path; we ship the bytes as-is and hand back the raw reply bytes, so","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:239"}},{"Add":{"text":"//! the gRPC schema can evolve without touching the host (or the primitive","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:314"}},{"Add":{"text":"//! table). tokio runs the calls off the OCaml thread.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:369"}},{"Add":{"text":"use bytes::{Buf, BufMut};","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:395"}},{"Add":{"text":"use std::sync::OnceLock;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:420"}},{"Add":{"text":"use tonic::codec::{Codec, DecodeBuf, Decoder, EncodeBuf, Encoder};","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:487"}},{"Add":{"text":"use tonic::transport::Channel;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:518"}},{"Add":{"text":"use tonic::{Request, Status};","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:548"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:549"}},{"Add":{"text":"/// A codec that neither encodes nor decodes: the payload is already-serialized","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:629"}},{"Add":{"text":"/// protobuf on both directions.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:662"}},{"Add":{"text":"#[derive(Default)]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:681"}},{"Add":{"text":"pub struct BytesCodec;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:704"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:705"}},{"Add":{"text":"pub struct BytesCoder;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:728"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:729"}},{"Add":{"text":"impl Codec for BytesCodec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:757"}},{"Add":{"text":" type Encode = Vec;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:784"}},{"Add":{"text":" type Decode = Vec;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:811"}},{"Add":{"text":" type Encoder = BytesCoder;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:842"}},{"Add":{"text":" type Decoder = BytesCoder;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:873"}},{"Add":{"text":" fn encoder(&mut self) -> BytesCoder {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:915"}},{"Add":{"text":" BytesCoder","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:934"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:940"}},{"Add":{"text":" fn decoder(&mut self) -> BytesCoder {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:982"}},{"Add":{"text":" BytesCoder","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1001"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1007"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1009"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1010"}},{"Add":{"text":"impl Encoder for BytesCoder {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1040"}},{"Add":{"text":" type Item = Vec;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1065"}},{"Add":{"text":" type Error = Status;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1090"}},{"Add":{"text":" fn encode(&mut self, item: Vec, dst: &mut EncodeBuf<'_>) -> Result<(), Status> {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1179"}},{"Add":{"text":" dst.put_slice(&item);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1209"}},{"Add":{"text":" Ok(())","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1224"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1230"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1232"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1233"}},{"Add":{"text":"impl Decoder for BytesCoder {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1263"}},{"Add":{"text":" type Item = Vec;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1288"}},{"Add":{"text":" type Error = Status;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1313"}},{"Add":{"text":" fn decode(&mut self, src: &mut DecodeBuf<'_>) -> Result>, Status> {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1400"}},{"Add":{"text":" let mut v = vec![0u8; src.remaining()];","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1448"}},{"Add":{"text":" src.copy_to_slice(&mut v);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1483"}},{"Add":{"text":" Ok(Some(v))","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1503"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1509"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1511"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1512"}},{"Add":{"text":"fn runtime() -> &'static tokio::runtime::Runtime {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1563"}},{"Add":{"text":" static RT: OnceLock = OnceLock::new();","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1631"}},{"Add":{"text":" RT.get_or_init(|| {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1655"}},{"Add":{"text":" tokio::runtime::Builder::new_multi_thread()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1707"}},{"Add":{"text":" .enable_all()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1733"}},{"Add":{"text":" .build()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1754"}},{"Add":{"text":" .expect(\"tokio runtime\")","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1791"}},{"Add":{"text":" })","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1798"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1800"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1801"}},{"Add":{"text":"fn channel() -> &'static Channel {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1836"}},{"Add":{"text":" static CH: OnceLock = OnceLock::new();","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1888"}},{"Add":{"text":" CH.get_or_init(|| Channel::from_static(\"http://127.0.0.1:50051\").connect_lazy())","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1973"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1975"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:1976"}},{"Add":{"text":"/// Spawn a unary gRPC call on tokio; `done` is invoked with the reply bytes (or","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2057"}},{"Add":{"text":"/// an \"error:\" marker) when it completes, off the OCaml thread.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2122"}},{"Add":{"text":"pub fn unary(path: String, req: Vec, done: impl FnOnce(Vec) + Send + 'static) {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2210"}},{"Add":{"text":" runtime().spawn(async move {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2243"}},{"Add":{"text":" let reply = call(path, req)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2279"}},{"Add":{"text":" .await","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2298"}},{"Add":{"text":" .unwrap_or_else(|e| format!(\"error:{e}\").into_bytes());","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2366"}},{"Add":{"text":" done(reply);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2387"}},{"Add":{"text":" });","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2395"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2397"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2398"}},{"Add":{"text":"async fn call(path: String, req: Vec) -> Result, Status> {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2469"}},{"Add":{"text":" let mut grpc = tonic::client::Grpc::new(channel().clone());","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2533"}},{"Add":{"text":" grpc.ready()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2550"}},{"Add":{"text":" .await","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2565"}},{"Add":{"text":" .map_err(|e| Status::unavailable(format!(\"connect: {e}\")))?;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2634"}},{"Add":{"text":" let path = http::uri::PathAndQuery::try_from(path)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2689"}},{"Add":{"text":" .map_err(|e| Status::internal(format!(\"bad path: {e}\")))?;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2756"}},{"Add":{"text":" let resp = grpc.unary(Request::new(req), path, BytesCodec).await?;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2827"}},{"Add":{"text":" Ok(resp.into_inner())","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2853"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2855"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2856"}},{"Add":{"text":"/// Spawn a server-streaming gRPC call on tokio. `chunk` is invoked once per","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:2933"}},{"Add":{"text":"/// decoded reply message (raw bytes), `done` once at end-of-stream (with the","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3011"}},{"Add":{"text":"/// transport error, if any). All run off the OCaml thread; the OCaml side","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3086"}},{"Add":{"text":"/// interleaves the chunks into its Lwt callback via the bridge.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3151"}},{"Add":{"text":"pub fn server_streaming(","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3176"}},{"Add":{"text":" path: String,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3194"}},{"Add":{"text":" req: Vec,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3212"}},{"Add":{"text":" chunk: impl Fn(Vec) + Send + Sync + 'static,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3265"}},{"Add":{"text":" done: impl FnOnce(Option) + Send + 'static,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3321"}},{"Add":{"text":") {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3325"}},{"Add":{"text":" runtime().spawn(async move {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3358"}},{"Add":{"text":" let err = stream(path, req, chunk).await.err().map(|e| e.to_string());","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3437"}},{"Add":{"text":" done(err);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3456"}},{"Add":{"text":" });","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3464"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3466"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3467"}},{"Add":{"text":"async fn stream(","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3484"}},{"Add":{"text":" path: String,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3502"}},{"Add":{"text":" req: Vec,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3520"}},{"Add":{"text":" chunk: impl Fn(Vec) + Send + Sync + 'static,","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3573"}},{"Add":{"text":") -> Result<(), Status> {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3599"}},{"Add":{"text":" use tonic::codegen::tokio_stream::StreamExt;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3648"}},{"Add":{"text":" let mut grpc = tonic::client::Grpc::new(channel().clone());","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3712"}},{"Add":{"text":" grpc.ready()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3729"}},{"Add":{"text":" .await","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3744"}},{"Add":{"text":" .map_err(|e| Status::unavailable(format!(\"connect: {e}\")))?;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3813"}},{"Add":{"text":" let path = http::uri::PathAndQuery::try_from(path)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3868"}},{"Add":{"text":" .map_err(|e| Status::internal(format!(\"bad path: {e}\")))?;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3935"}},{"Add":{"text":" let resp = grpc","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:3955"}},{"Add":{"text":" .server_streaming(Request::new(req), path, BytesCodec)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4018"}},{"Add":{"text":" .await?;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4035"}},{"Add":{"text":" let mut messages = resp.into_inner();","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4077"}},{"Add":{"text":" while let Some(msg) = messages.next().await {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4127"}},{"Add":{"text":" chunk(msg?);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4148"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4154"}},{"Add":{"text":" Ok(())","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4165"}},{"Add":{"text":"}","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:4167"}}]}},{"Replacement":{"inode":{"change":7,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":6,"ins":{"up_context":[{"change":7,"pos":4199}],"down_context":[{"change":7,"pos":4595}],"flag":"BLOCK","start":10132,"end":11019,"inode":{"change":7,"pos":3915}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4199},"to":{"change":7,"start":4199,"end":4595},"introduced_by":7}],"inode":{"change":7,"pos":3915}},"ins_contents":[{"Add":{"text":"external emit : string -> unit = \"host_emit\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10193"}},{"Add":{"text":"external host_backend_call : int -> string -> string -> unit = \"host_backend_call\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10277"}},{"Add":{"text":"external host_backend_stream: int -> string -> string -> unit = \"host_backend_stream\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10363"}},{"Add":{"text":"external host_result_bytes : int -> string = \"host_result_bytes\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10433"}},{"Add":{"text":"external host_is_last : int -> bool = \"host_is_last\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10499"}},{"Add":{"text":"external host_read_source : string -> string = \"host_read_source\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10568"}},{"Add":{"text":"external host_wait : unit -> int = \"host_wait\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10630"}},{"Add":{"text":"external now_ms : unit -> int = \"host_now_ms\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10695"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10696"}},{"Add":{"text":"(* Per-effect state, keyed by the id we hand the host. A unary effect resolves","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10775"}},{"Add":{"text":" its promise on the single terminating event; a streaming effect feeds each","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10853"}},{"Add":{"text":" chunk to [on_chunk] and resolves [fin] at end-of-stream. *)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10916"}},{"Add":{"text":"type effect =","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10930"}},{"Add":{"text":" | Unary of string Lwt.u","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:10956"}},{"Add":{"text":" | Stream of { on_chunk : string -> unit; fin : unit Lwt.u }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11018"}}],"del_contents":[{"Del":{"text":"external emit : string -> unit = \"host_emit\"","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4259"}},{"Del":{"text":"external host_backend_call : int -> string -> unit = \"host_backend_call\"","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4332"}},{"Del":{"text":"external host_result_bytes : int -> string = \"host_result_bytes\"","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4401"}},{"Del":{"text":"external host_read_source : string -> string = \"host_read_source\"","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4469"}},{"Del":{"text":"external host_wait : unit -> int = \"host_wait\"","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4530"}},{"Del":{"text":"external now_ms : unit -> int = \"host_now_ms\"","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4594"}}]}},{"Replacement":{"inode":{"change":7,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":22,"ins":{"up_context":[{"change":7,"pos":4596}],"down_context":[{"change":7,"pos":4656}],"flag":"BLOCK","start":11020,"end":11074,"inode":{"change":7,"pos":3915}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4596},"to":{"change":7,"start":4596,"end":4656},"introduced_by":7}],"inode":{"change":7,"pos":3915}},"ins_contents":[{"Add":{"text":"let tbl : (int, effect) Hashtbl.t = Hashtbl.create 16","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11073"}}],"del_contents":[{"Del":{"text":"let tbl : (int, string Lwt.u) Hashtbl.t = Hashtbl.create 16","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4655"}}]}},{"Replacement":{"inode":{"change":7,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":25,"ins":{"up_context":[{"change":7,"pos":4673}],"down_context":[{"change":7,"pos":4882}],"flag":"BLOCK","start":11075,"end":11413,"inode":{"change":7,"pos":3915}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4673},"to":{"change":7,"start":4673,"end":4882},"introduced_by":7}],"inode":{"change":7,"pos":3915}},"ins_contents":[{"Add":{"text":"let fresh_id () = incr ctr; !ctr","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11107"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11108"}},{"Add":{"text":"(* Async effect leaf: unary gRPC to the backend at method [path] with serialized","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11189"}},{"Add":{"text":" protobuf [req]; resolve to the raw reply bytes. Many can be in flight at once;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11271"}},{"Add":{"text":" Lwt.all resolves them together (this is what beats Nix import-from-derivation). *)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11357"}},{"Add":{"text":"let backend_call ~path req =","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11386"}},{"Add":{"text":" let id = fresh_id () in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11412"}}],"del_contents":[{"Del":{"text":"(* Async effect leaf: send [req] to the backend, resolve to its reply bytes.","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4749"}},{"Del":{"text":" Many of these can be in flight at once; Lwt.all resolves them together. *)","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4827"}},{"Del":{"text":"let backend_call req =","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4850"}},{"Del":{"text":" incr ctr;","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4862"}},{"Del":{"text":" let id = !ctr in","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4881"}}]}},{"Replacement":{"inode":{"change":7,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":33,"ins":{"up_context":[{"change":7,"pos":4910}],"down_context":[{"change":7,"pos":4966}],"flag":"BLOCK","start":11414,"end":11997,"inode":{"change":7,"pos":3915}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":4910},"to":{"change":7,"start":4910,"end":4966},"introduced_by":7}],"inode":{"change":7,"pos":3915}},"ins_contents":[{"Add":{"text":" Hashtbl.replace tbl id (Unary r);","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11449"}},{"Add":{"text":" host_backend_call id path req;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11482"}},{"Add":{"text":" p","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11486"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11487"}},{"Add":{"text":"(* Async effect leaf: server-streaming gRPC. Each decoded reply message is passed","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11569"}},{"Add":{"text":" to [f] (the DSL's per-message handler, e.g. accumulate Ok/Error/Loading, print","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11651"}},{"Add":{"text":" Stdout/Stderr); the thread resolves to unit at end-of-stream. This is the twin","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11733"}},{"Add":{"text":" of [grpc_call_streaming] (Derivation, UbuntuPackage) in the real Elpe lib. *)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11814"}},{"Add":{"text":"let backend_stream ~path req ~f =","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11848"}},{"Add":{"text":" let id = fresh_id () in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11874"}},{"Add":{"text":" let p, fin = Lwt.wait () in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11904"}},{"Add":{"text":" Hashtbl.replace tbl id (Stream { on_chunk = f; fin });","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11961"}},{"Add":{"text":" host_backend_stream id path req;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11996"}}],"del_contents":[{"Del":{"text":" Hashtbl.replace tbl id r;","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4937"}},{"Del":{"text":" host_backend_call id req;","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:4965"}}]}},{"Edit":{"inode":{"change":7,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":50,"atom":{"NewVertex":{"up_context":[{"change":7,"pos":5086}],"down_context":[{"change":7,"pos":5086}],"flag":"BLOCK","start":11998,"end":12564,"inode":{"change":7,"pos":3915}}},"contents":[{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:11998"}},{"Add":{"text":"(* Deliver one host event to its effect. A terminating event (unary reply, or a","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12078"}},{"Add":{"text":" stream's end-of-stream) resolves the promise and drops the id; a stream chunk","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12159"}},{"Add":{"text":" feeds the handler and leaves the effect in flight for more. *)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12225"}},{"Add":{"text":"let deliver id =","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12242"}},{"Add":{"text":" let last = host_is_last id in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12274"}},{"Add":{"text":" match Hashtbl.find_opt tbl id with","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12311"}},{"Add":{"text":" | None -> ()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12326"}},{"Add":{"text":" | Some (Unary r) ->","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12348"}},{"Add":{"text":" Hashtbl.remove tbl id;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12377"}},{"Add":{"text":" Lwt.wakeup r (host_result_bytes id)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12419"}},{"Add":{"text":" | Some (Stream { on_chunk; fin }) ->","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12458"}},{"Add":{"text":" if last then (Hashtbl.remove tbl id; Lwt.wakeup fin ())","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12520"}},{"Add":{"text":" else on_chunk (host_result_bytes id)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12563"}}]}},{"Replacement":{"inode":{"change":7,"pos":3915},"path":"eval-vm/demo/ocaml/vm_prelude.ml","line":73,"ins":{"up_context":[{"change":7,"pos":5357}],"down_context":[{"change":7,"pos":5536}],"flag":"BLOCK","start":12565,"end":12601,"inode":{"change":7,"pos":3915}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":7,"pos":5357},"to":{"change":7,"start":5357,"end":5536},"introduced_by":7}],"inode":{"change":7,"pos":3915}},"ins_contents":[{"Add":{"text":" if id >= 0 then deliver id;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12600"}}],"del_contents":[{"Del":{"text":" (if id >= 0 then","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:5381"}},{"Del":{"text":" match Hashtbl.find_opt tbl id with","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:5427"}},{"Del":{"text":" | Some r -> Hashtbl.remove tbl id; Lwt.wakeup r (host_result_bytes id)","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:5509"}},{"Del":{"text":" | None -> ());","pos":"7BSPPOMJXFL3SXPYFKLSW7UIC3YVYWOB66OR4JOLD4P7QJ4OJOXQC:5535"}}]}},{"Edit":{"inode":{"change":5,"pos":23492},"path":"eval-vm/demo/ocaml/test.ml","line":33,"atom":{"NewVertex":{"up_context":[{"change":8,"pos":1907}],"down_context":[{"change":7,"pos":3373}],"flag":"BLOCK","start":12603,"end":14385,"inode":{"change":5,"pos":23492}}},"contents":[{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12603"}},{"Add":{"text":" (* SERVER-STREAMING vertical slice: the exact [grpc_call_streaming] pattern","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12681"}},{"Add":{"text":" (Derivation is `returns (stream DerivationReply)`). We ship one","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12750"}},{"Add":{"text":" DerivationRequest and decode EACH streamed DerivationReply oneof — Stdout /","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12833"}},{"Add":{"text":" Stderr chunks interleave, then a terminal Ok/Error — over the async","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12908"}},{"Add":{"text":" [backend_stream] host primitive instead of h2/Grpc_lwt. Whatever the backend","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:12990"}},{"Add":{"text":" does (a trivial build succeeds, or errors), we get >=1 chunk then","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13061"}},{"Add":{"text":" end-of-stream: proof the chunk+finish bridge and the Lwt callback wiring","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13139"}},{"Add":{"text":" match the real streaming leaf. *)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13178"}},{"Add":{"text":" let dstream_encode, dreply_decode =","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13216"}},{"Add":{"text":" Service.make_client_functions Elpe.derivation","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13266"}},{"Add":{"text":" in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13271"}},{"Add":{"text":" let dreq =","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13284"}},{"Add":{"text":" DerivationRequest.make ~name:\"vm-stream-smoke\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13335"}},{"Add":{"text":" ~builder:\"echo hello-from-stream\" ~paths:[]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13385"}},{"Add":{"text":" ~target:\"x86_64-unknown-linux-gnu\" ()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13429"}},{"Add":{"text":" in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13434"}},{"Add":{"text":" let dreq = dstream_encode dreq |> Writer.contents in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13489"}},{"Add":{"text":" let stdout_buf = Buffer.create 256 in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13529"}},{"Add":{"text":" let final = ref \"(no terminal reply)\" in","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13572"}},{"Add":{"text":" run","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13578"}},{"Add":{"text":" (backend_stream ~path:\"/elpe.Elpe/Derivation\" dreq ~f:(fun bytes ->","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13650"}},{"Add":{"text":" match Reader.create bytes |> dreply_decode with","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13707"}},{"Add":{"text":" | Error e ->","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13729"}},{"Add":{"text":" final := \"decode error: \" ^ Result.show_error e;","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13791"}},{"Add":{"text":" Lwt.return ()","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13818"}},{"Add":{"text":" | Ok reply ->","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13841"}},{"Add":{"text":" (match reply with","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13872"}},{"Add":{"text":" | `Stdout b -> Buffer.add_bytes stdout_buf b","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13930"}},{"Add":{"text":" | `Stderr b -> Buffer.add_bytes stdout_buf b","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:13988"}},{"Add":{"text":" | `Loading p -> emit (\" [stream] loading \" ^ p)","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14050"}},{"Add":{"text":" | `Ok r -> final := \"Ok destdir=\" ^ String.concat \",\" r.DerivationResult.destdir","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14144"}},{"Add":{"text":" | `Error _ -> final := \"Error reply (streamed)\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14205"}},{"Add":{"text":" | `not_set -> ());","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14237"}},{"Add":{"text":" Lwt.return ()));","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14267"}},{"Add":{"text":" emit","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14274"}},{"Add":{"text":" (Printf.sprintf \"streamed Derivation done -> %s | stdout=%S\" !final","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14346"}},{"Add":{"text":" (Buffer.contents stdout_buf));","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14384"}}]}},{"Edit":{"inode":{"change":5,"pos":25468},"path":"eval-vm/demo/build.rs","line":25,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":5996}],"down_context":[{"change":6,"pos":5996}],"flag":"BLOCK","start":14388,"end":14419,"inode":{"change":5,"pos":25468}}},"contents":[{"Add":{"text":" \"host_backend_stream\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14418"}}]}},{"Edit":{"inode":{"change":5,"pos":25468},"path":"eval-vm/demo/build.rs","line":27,"atom":{"NewVertex":{"up_context":[{"change":6,"pos":6025}],"down_context":[{"change":7,"pos":2398}],"flag":"BLOCK","start":14420,"end":14444,"inode":{"change":5,"pos":25468}}},"contents":[{"Add":{"text":" \"host_is_last\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14443"}}]}},{"Replacement":{"inode":{"change":5,"pos":27088},"path":"eval-vm/demo/Cargo.toml","line":7,"ins":{"up_context":[{"change":5,"pos":27246}],"down_context":[{"change":5,"pos":27399}],"flag":"BLOCK","start":14446,"end":14601,"inode":{"change":5,"pos":27088}},"del":{"edges":[{"previous":"BLOCK","flag":"BLOCK | DELETED","from":{"change":5,"pos":27246},"to":{"change":5,"start":27246,"end":27399},"introduced_by":5}],"inode":{"change":5,"pos":27088}},"ins_contents":[{"Add":{"text":"# drives the VM. host_backend_call is a REAL tonic gRPC call (generic bytes","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14521"}},{"Add":{"text":"# passthrough) to the backend; tokio runs the async work off the OCaml thread.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14600"}}],"del_contents":[{"Del":{"text":"# drives the VM. Also directly depends on -sys so its build.rs sees the runtime","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:27325"}},{"Del":{"text":"# link, and on -build to generate the table + compile the demo bytecode.","pos":"7J54GGTWZKM5Y4K24D5GO7XZJGTVUJJPB6CFE54YN3L2YIHEDWDAC:27398"}}]}},{"Edit":{"inode":{"change":5,"pos":27088},"path":"eval-vm/demo/Cargo.toml","line":13,"atom":{"NewVertex":{"up_context":[{"change":5,"pos":27495}],"down_context":[{"change":5,"pos":27495}],"flag":"BLOCK","start":14602,"end":14698,"inode":{"change":5,"pos":27088}}},"contents":[{"Add":{"text":"tokio = { version = \"1\", features = [\"rt-multi-thread\"] }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14659"}},{"Add":{"text":"tonic = \"0.13\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14674"}},{"Add":{"text":"bytes = \"1\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14686"}},{"Add":{"text":"http = \"1\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14697"}}]}},{"Edit":{"inode":{"change":3,"pos":3315},"path":"Cargo.nix","line":46,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":4730}],"down_context":[{"change":3,"pos":4730}],"flag":"BLOCK","start":14790,"end":15109,"inode":{"change":3,"pos":3315}}},"contents":[{"Add":{"text":" \"demo\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14808"}},{"Add":{"text":" packageId = \"demo\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14834"}},{"Add":{"text":" build = internal.buildRustCrateWithFeatures {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14886"}},{"Add":{"text":" packageId = \"demo\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14914"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14923"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14924"}},{"Add":{"text":" # Debug support which might change between releases.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:14983"}},{"Add":{"text":" # File a bug if you depend on any for non-debug work!","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15043"}},{"Add":{"text":" debug = internal.debugCrate { inherit packageId; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15101"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15108"}}]}},{"Edit":{"inode":{"change":3,"pos":3315},"path":"Cargo.nix","line":100,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":190167}],"down_context":[{"change":4,"pos":190167}],"flag":"BLOCK","start":15110,"end":15441,"inode":{"change":3,"pos":3315}}},"contents":[{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15118"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15119"}},{"Add":{"text":" # Debug support which might change between releases.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15178"}},{"Add":{"text":" # File a bug if you depend on any for non-debug work!","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15238"}},{"Add":{"text":" debug = internal.debugCrate { inherit packageId; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15296"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15303"}},{"Add":{"text":" \"ocaml-vm\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15326"}},{"Add":{"text":" packageId = \"ocaml-vm\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15356"}},{"Add":{"text":" build = internal.buildRustCrateWithFeatures {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15408"}},{"Add":{"text":" packageId = \"ocaml-vm\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15440"}}]}},{"Edit":{"inode":{"change":3,"pos":3315},"path":"Cargo.nix","line":116,"atom":{"NewVertex":{"up_context":[{"change":4,"pos":190361}],"down_context":[{"change":3,"pos":5717}],"flag":"BLOCK","start":15442,"end":16134,"inode":{"change":3,"pos":3315}}},"contents":[{"Add":{"text":" \"ocaml-vm-build\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15470"}},{"Add":{"text":" packageId = \"ocaml-vm-build\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15506"}},{"Add":{"text":" build = internal.buildRustCrateWithFeatures {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15558"}},{"Add":{"text":" packageId = \"ocaml-vm-build\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15596"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15605"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15606"}},{"Add":{"text":" # Debug support which might change between releases.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15665"}},{"Add":{"text":" # File a bug if you depend on any for non-debug work!","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15725"}},{"Add":{"text":" debug = internal.debugCrate { inherit packageId; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15783"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15790"}},{"Add":{"text":" \"ocaml-vm-sys\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15817"}},{"Add":{"text":" packageId = \"ocaml-vm-sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15851"}},{"Add":{"text":" build = internal.buildRustCrateWithFeatures {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15903"}},{"Add":{"text":" packageId = \"ocaml-vm-sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15939"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15948"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:15949"}},{"Add":{"text":" # Debug support which might change between releases.","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16008"}},{"Add":{"text":" # File a bug if you depend on any for non-debug work!","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16068"}},{"Add":{"text":" debug = internal.debugCrate { inherit packageId; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16126"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16133"}}]}},{"Edit":{"inode":{"change":3,"pos":3315},"path":"Cargo.nix","line":1672,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":41630}],"down_context":[{"change":3,"pos":41630}],"flag":"BLOCK","start":16135,"end":17246,"inode":{"change":3,"pos":3315}}},"contents":[{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16143"}},{"Add":{"text":" \"demo\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16164"}},{"Add":{"text":" crateName = \"demo\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16192"}},{"Add":{"text":" version = \"0.1.0\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16219"}},{"Add":{"text":" edition = \"2021\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16245"}},{"Add":{"text":" crateBin = [","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16266"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16278"}},{"Add":{"text":" name = \"demo\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16305"}},{"Add":{"text":" path = \"src/main.rs\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16339"}},{"Add":{"text":" requiredFeatures = [ ];","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16375"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16387"}},{"Add":{"text":" ];","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16398"}},{"Add":{"text":" src = lib.cleanSourceWith { filter = sourceFilter; src = ./eval-vm/demo; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16483"}},{"Add":{"text":" dependencies = [","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16508"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16520"}},{"Add":{"text":" name = \"bytes\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16548"}},{"Add":{"text":" packageId = \"bytes 1.10.1\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16588"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16600"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16612"}},{"Add":{"text":" name = \"http\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16639"}},{"Add":{"text":" packageId = \"http\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16671"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16683"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16695"}},{"Add":{"text":" name = \"ocaml-vm\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16726"}},{"Add":{"text":" packageId = \"ocaml-vm\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16762"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16774"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16786"}},{"Add":{"text":" name = \"ocaml-vm-sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16821"}},{"Add":{"text":" packageId = \"ocaml-vm-sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16861"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16873"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16885"}},{"Add":{"text":" name = \"tokio\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16913"}},{"Add":{"text":" packageId = \"tokio\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16946"}},{"Add":{"text":" features = [ \"rt-multi-thread\" ];","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:16992"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17004"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17016"}},{"Add":{"text":" name = \"tonic\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17044"}},{"Add":{"text":" packageId = \"tonic\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17077"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17089"}},{"Add":{"text":" ];","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17100"}},{"Add":{"text":" buildDependencies = [","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17130"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17142"}},{"Add":{"text":" name = \"ocaml-vm-build\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17179"}},{"Add":{"text":" packageId = \"ocaml-vm-build\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17221"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17233"}},{"Add":{"text":" ];","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17244"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17245"}}]}},{"Edit":{"inode":{"change":3,"pos":3315},"path":"Cargo.nix","line":4852,"atom":{"NewVertex":{"up_context":[{"change":3,"pos":127341}],"down_context":[{"change":3,"pos":127341}],"flag":"BLOCK","start":17247,"end":18166,"inode":{"change":3,"pos":3315}}},"contents":[{"Add":{"text":" \"ocaml-vm\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17271"}},{"Add":{"text":" crateName = \"ocaml-vm\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17303"}},{"Add":{"text":" version = \"0.1.0\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17330"}},{"Add":{"text":" edition = \"2021\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17356"}},{"Add":{"text":" src = lib.cleanSourceWith { filter = sourceFilter; src = ./eval-vm/ocaml-vm; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17445"}},{"Add":{"text":" libName = \"ocaml_vm\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17475"}},{"Add":{"text":" dependencies = [","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17500"}},{"Add":{"text":" {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17512"}},{"Add":{"text":" name = \"ocaml-vm-sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17547"}},{"Add":{"text":" packageId = \"ocaml-vm-sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17587"}},{"Add":{"text":" }","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17599"}},{"Add":{"text":" ];","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17610"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17611"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17620"}},{"Add":{"text":" \"ocaml-vm-build\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17651"}},{"Add":{"text":" crateName = \"ocaml-vm-build\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17689"}},{"Add":{"text":" version = \"0.1.0\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17716"}},{"Add":{"text":" edition = \"2021\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17742"}},{"Add":{"text":" src = lib.cleanSourceWith { filter = sourceFilter; src = ./eval-vm/ocaml-vm-build; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17837"}},{"Add":{"text":" libName = \"ocaml_vm_build\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17873"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17874"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17883"}},{"Add":{"text":" \"ocaml-vm-sys\" = rec {","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17912"}},{"Add":{"text":" crateName = \"ocaml-vm-sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17948"}},{"Add":{"text":" version = \"0.1.0\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:17975"}},{"Add":{"text":" edition = \"2021\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18001"}},{"Add":{"text":" links = \"camlrun\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18028"}},{"Add":{"text":" src = lib.cleanSourceWith { filter = sourceFilter; src = ./eval-vm/ocaml-vm-sys; };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18121"}},{"Add":{"text":" libName = \"ocaml_vm_sys\";","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18155"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18156"}},{"Add":{"text":" };","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18165"}}]}},{"Edit":{"inode":{"change":2,"pos":71904},"path":"Cargo.lock","line":546,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":78861}],"down_context":[{"change":4,"pos":181555}],"flag":"BLOCK","start":18168,"end":18327,"inode":{"change":2,"pos":71904}}},"contents":[{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18168"}},{"Add":{"text":"[[package]]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18180"}},{"Add":{"text":"name = \"demo\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18194"}},{"Add":{"text":"version = \"0.1.0\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18212"}},{"Add":{"text":"dependencies = [","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18229"}},{"Add":{"text":" \"bytes 1.10.1\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18246"}},{"Add":{"text":" \"http\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18255"}},{"Add":{"text":" \"ocaml-vm\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18268"}},{"Add":{"text":" \"ocaml-vm-build\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18287"}},{"Add":{"text":" \"ocaml-vm-sys\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18304"}},{"Add":{"text":" \"tokio\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18314"}},{"Add":{"text":" \"tonic\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18324"}},{"Add":{"text":"]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18326"}}]}},{"Edit":{"inode":{"change":2,"pos":71904},"path":"Cargo.lock","line":1534,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":99200}],"down_context":[{"change":2,"pos":99200}],"flag":"BLOCK","start":18328,"end":18413,"inode":{"change":2,"pos":71904}}},"contents":[{"Add":{"text":"]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18329"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18330"}},{"Add":{"text":"[[package]]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18342"}},{"Add":{"text":"name = \"ocaml-vm\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18360"}},{"Add":{"text":"version = \"0.1.0\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18378"}},{"Add":{"text":"dependencies = [","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18395"}},{"Add":{"text":" \"ocaml-vm-sys\",","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18412"}}]}},{"Edit":{"inode":{"change":2,"pos":71904},"path":"Cargo.lock","line":1542,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":99202}],"down_context":[{"change":2,"pos":99202}],"flag":"BLOCK","start":18414,"end":18469,"inode":{"change":2,"pos":71904}}},"contents":[{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18414"}},{"Add":{"text":"[[package]]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18426"}},{"Add":{"text":"name = \"ocaml-vm-build\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18450"}},{"Add":{"text":"version = \"0.1.0\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18468"}}]}},{"Edit":{"inode":{"change":2,"pos":71904},"path":"Cargo.lock","line":1548,"atom":{"NewVertex":{"up_context":[{"change":2,"pos":99215}],"down_context":[{"change":2,"pos":99215}],"flag":"BLOCK","start":18470,"end":18523,"inode":{"change":2,"pos":71904}}},"contents":[{"Add":{"text":"name = \"ocaml-vm-sys\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18491"}},{"Add":{"text":"version = \"0.1.0\"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18509"}},{"Add":{"text":"","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18510"}},{"Add":{"text":"[[package]]","pos":"W6QJSED2GPQ5KZT5DBJ3RESVZL26Z3QCYZQVUD4AZ2ZGQXPA35UAC:18522"}}]}}],"owner":"pmeunier","repo":"elpe","token":"KI8LMBQRP7rR3PuM9bbU+O23Em44G812O9Vh4DtFTXc=","login":null}

…

Dependencies

Change contents

Review