code wiki / _hdl_build / nx_role_queue.nx

nx_role_queue.nx

buildroot/runtime/_hdl_build/nx_role_queue.nx

7527 B115 linesdepth 4pulls 6 transitivereach 4 importersview sourcekind tooltopic role
docsdependenciesstructsconstsfunctions

about

nx_role_queue.nx -- the ROLE-PARAMETERIZED serialized work intake (generalizes nx_doctor_queue so the SAME mechanism serves EVERY change-applying role: Doctor=fix, Engineer=optimize, ... each with its OWN isolated queue/ledger/lock). A role SUBMITs a change request; the role PUMPs its own queue one-at-a-time under its per-role lock, applying each via the gated graceful doc_apply_mem (lock + exact-context-match + atomic), then flips the line to APPLIED/CONFLICT/AMBIGUOUS + ledgers. Idempotent. Per-role isolation = roles never compete. queue line: status<TAB>ts<TAB>role<TAB>requester<TAB>target<TAB>oldstr-path<TAB>newstr-path usage: nx_role_queue <role> submit <target> <oldfile> <newfile> <requester> nx_role_queue <role> pump license_tier: ORIGINAL

dependencies 4 imports · 3 importers

nx_syscalls.nx nx_arbiter.nx nx_doctor_apply.nx nx_role_store.nx nx_role_queue.nx nx_pm.nx nx_pm_gate.nx nx_role_store_gate.nx

imports: nx_syscalls.nxnx_arbiter.nxnx_doctor_apply.nxnx_role_store.nx

imported by: nx_pm.nxnx_pm_gate.nxnx_role_store_gate.nx

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

main rq_w sys_write da_slen rq_streq rq_submit sys_mmap rq_cat rq_n sys_mmap ↻ sys_now_realtime_sec sys_mmap ↻ sys_clock_gettime_real rs_chan ss_cat rs_append rs_lock sys_openat_append sys_flock rs_segcount sys_mmap ↻ ss_manifest ss_manifest_file sys_mmap ↻ ss_cat ↻ ss_readall rs_unlock sys_flock ↻ sys_close sys_write ↻ rs_count sys_mmap ↻ rs_nkey ss_cat ↻ ss_get sys_mmap ↻ ss_scan sys_mmap ↻ ss_manifest_dyn ss_scan_seglist

structs

none

consts

15const RQ_MAGIC_4096: i64 = 4096
16const RQ_MAGIC_100000: i64 = 100000
17const RQ_MAGIC_1024: i64 = 1024
18const RQ_MAGIC_2048: i64 = 2048
20const RQ_DIR: *u8 = "knowledge/roles"

functions

22func rq_w(s: *u8) -> i64 { return sys_write(1, s, da_slen(s)) }
called by 4: pm_routepm_publishmainmain calls 2: sys_writeda_slen
23func rq_streq(a: *u8, b: *u8) -> i64 { var i: i64=0; while a[i]!=(0 as u8){ if a[i]!=b[i]{return 0} i=i+1 } if b[i]!=(0 as u8){return 0} return 1 }
called by 5: pm_routemainpg_role_isrq_pumpmain
24func rq_cat(dst: *u8, off: i64, s: *u8) -> i64 { var o: i64=off; var i: i64=0; while s[i]!=(0 as u8){ dst[o]=s[i]; o=o+1; i=i+1 } return o }
called by 5: pm_recordpms_registerrq_pathrq_submitrq_pump
25func rq_n(dst: *u8, off: i64, v: i64) -> i64 { var o: i64=off; var m: i64=v; if m<0{dst[o]=45 as u8;o=o+1;m=0-m} let t: *u8=sys_mmap(24); var k: i64=0; if m==0{t[0]=48 as u8;k=1} while m>0{t[k]=(48+(m-(m/10)*10)) as u8;m=m/10;k=k+1} var i: i64=0; while i<k{dst[o+i]=t[k-1-i];i=i+1} return o+k }
called by 5: pm_recordpm_publishpms_registerrq_submitmain calls 1: sys_mmap
26func rq_field(line: *u8, len: i64, idx: i64, out: *u8, outcap: i64) -> i64
32func rq_path(role: *u8, suffix: *u8, out: *u8) -> i64
calls 1: rq_cat
40func rq_submit(role: *u8, target: *u8, oldp: *u8, newp: *u8, requester: *u8) -> i64
called by 3: pm_routemainmain calls 6: sys_mmaprq_catrq_nsys_now_realtime_secrs_chanrs_append
58func rq_pump(role: *u8) -> i64
called by 1: main calls 13: sys_mmaprs_chanrq_catfl_acquirers_countrs_get_seq+7
101func main(argc: i64, argv: *i64) -> i64
calls 7: rq_wrq_streqrq_submitrq_pumpsys_mmaprq_n+1