code wiki / _hdl_build / nx_parallel_runner.nx

nx_parallel_runner.nx

buildroot/runtime/_hdl_build/nx_parallel_runner.nx

7272 B107 linesdepth 3pulls 8 transitivereach 0 importersview sourcekind tooltopic parallel
docsdependenciesstructsconstsfunctions

about

nx_parallel_runner.nx -- the TEAM runs the 3 workstreams IN PARALLEL, isolated + monitored + governed, while Claude MONITORS (operator: "if the team could do all three in parallel that would be a great test with you monitoring like you did with the overnight runner... i want the team to build this and run it... with you doing it yourself as a FAIL CASE"). Each workstream gets its own branch+worktree (conflict-free); the team DOES what needs no authoring and ESCALATES what does (the novel-module gap = a flagged FAIL CASE = a capability to build next). Writes /tmp/nishi_parallel_run.log (monitorable progress) + escalations to the PM review log. license_tier: ORIGINAL Composes ownership-map + workstream-git + merge-queue + loop-monitor + governed-ingest + pm-review-log.

dependencies 7 imports · 0 importers

nx_ownership_map.nx nx_itoa_lib.nx nx_workstream_git.nx nx_merge_queue.nx nx_loop_monitor.nx nx_pm_review_log.nx nx_syscalls.nx nx_parallel_runner.nx

imports: nx_ownership_map.nxnx_itoa_lib.nxnx_workstream_git.nxnx_merge_queue.nxnx_loop_monitor.nxnx_pm_review_log.nxnx_syscalls.nx

imported by: nobody (leaf or entry point)

call flow from main pre-order; caps 40 nodes / depth 6 declared; ↻ = already shown

main sys_openat_wr pm_open sys_openat_append pr_w sys_write sys_mmap wsg_isolation_ok pr_n nxi_fd sys_mmap ↻ ccz_cat_num sys_write ↻ sys_munmap om_role om_has om_role_name om_count_orphans om_role ↻ pm_flag pm_w sys_write ↻ pm_cstr_len lm_classify mq_process sys_close sys_exit

structs

none

consts

18const WS_FULL: i64 = 2 // team does it fully, autonomously (no authoring)
19const WS_VERIFY: i64 = 1 // team verifies; authoring the artifact escalates
20const WS_ESCALATE: i64 = 0 // needs novel authoring -> reach out for help (the FAIL CASE)

functions

22func pr_w(fd: i64, s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(fd,s,n); return 0 }
called by 1: main calls 1: sys_write
27func pr_n(fd: i64, v: i64) -> i64 { nxi_fd(fd, v); return 0 }
called by 1: main calls 1: nxi_fd
29func main() -> i64