code wiki / _hdl_build / nx_backlog_feeder.nx

nx_backlog_feeder.nx

buildroot/runtime/_hdl_build/nx_backlog_feeder.nx

25803 B560 linesdepth 5pulls 7 transitivereach 0 importersview sourcekind tooltopic backlog
docsdependenciesstructsconstsfunctions

about

nx_backlog_feeder.nx -- F208 AUTONOMOUS BACKLOG FEEDER, evidence->FRONTIER half (ws=auto-f208-feeder, 2026-07-21). nx_feeder (ws-intel8) notices dropped threads and files INTAKE proposals; the router triages them; but NOTHING committed deps-resolved F-rows onto the frontier from measured evidence. This organ is that committer, rung 1 = the DEBT source: every OPEN debt at sev >= minsev becomes ONE frontier row F<auto> "debt <epoch>: <desc>" weight=<sev> prio=1 <owner> T deps=- [FEED:debt:<epoch>.<k>] <lane> HONEST WEIGHTS: the row weight IS the measured debt sev, so nx_seat ready (w-desc) ranks feeder rows truthfully against hand-filed rungs (RANKW1 contract). DEPS-RESOLVED: deps=- (a debt is actionable now). SAFETY BY CONSTRUCTION: - ids are NEVER fixed: F<max+1> batch-assigned under the SAME <prefix>plock nx_frontier_put takes (frontier ids collide across lanes; addauto semantics reused, computed in ONE critical section) - CONTENT-IDEMPOTENT: marker [FEED:debt:<epoch>.<k>] in the extra col; a re-run on unchanged evidence adds ZERO rows. k = the epoch's occurrence ordinal among debt rows, so D025 epoch-id collisions (two debts, same epoch) still yield DISTINCT markers -- never a wrong-row dedupe. - per-run cap: the frontier can never be flooded; capped findings are REPORTED, not lost (next run). - ONE sts_seed per run (one new segment) -- honors the seg-store quadratic lesson; a run that adds nothing commits NOTHING (no segment churn, planeguard-quiet). - fail-closed: unseeded frontier plane -> refuse, commit nothing (mirrors nx_frontier_put). NOTHING IS FABRICATED: every row cites its debt epoch + measured sev; eaten/low-sev debts are skipped. Residual sources (gap queues, atlas maturity-gap, intake-TRIAGED promotion) = FILED follow-on rungs. license_tier: ORIGINAL No hw writes (Rule 26). expect_exit: 0 scan <minsev> <maxfile> [debt-prefix] [frontier-prefix] -> JSON (READ-ONLY) run <minsev> <maxfile> <owner> <lane> [debt-prefix] [frontier-prefix] [exportpath] -> commit, JSON selftest <scratch-prefix-base> -> gate T1..T9

dependencies 4 imports · 0 importers

nx_store_seed_lib.nx nx_seg_store.nx nx_syscalls.nx nx_gate_verdict.nx nx_backlog_feeder.nx

imports: nx_store_seed_lib.nxnx_seg_store.nxnx_syscalls.nxnx_gate_verdict.nx

imported by: nobody (leaf or entry point)

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

main bf_werr sys_write sys_exit bf_vlen bf_lit_eq bf_selftest gv_ctr sys_mmap gv_head gv_puts sys_write ↻ sys_mmap ↻ bf_mkpfx bf_cat bf_cat ↻ sts_seed ss_begin_cap sys_mmap ↻ sts_mm sys_mmap ↻ sts_werr sys_write ↻ sys_exit ↻ sts_rowkey ss_catn sys_mmap ↻ ss_add ss_add2 ss_w32 ss_len ss_catn ↻ ss_commit ss_segid_ok sys_mmap ↻ ss_cat ss_catn ↻ sys_write ↻ ss_write_seg ss_segid_ok ↻

structs

none

consts

29const BF_CAP: i64 = 1048576
30const BF_TAB: i64 = 9
31const BF_NL: i64 = 10
32const BF_STDERR: i64 = 2
33const BF_LOCK_EX: i64 = 2
34const BF_MODE: i64 = 420
35const BF_SPAN: i64 = 16
36const BF_PATHCAP: i64 = 256
37const BF_HDRCAP: i64 = 512
38const BF_OUTJSON: i64 = 8192
39const BF_MARKCAP: i64 = 128
40const BF_TITLE_MAX: i64 = 140
41const BF_EXIT_USAGE: i64 = 2
42const BF_MAGIC_28: i64 = 28

functions

44func bf_puts(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } sys_write(1, s, n); return 0 }
calls 1: sys_write
45func bf_werr(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } sys_write(BF_STDERR, s, n); return 0 }
called by 2: bf_sweepmain calls 1: sys_write
46func bf_vlen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
called by 4: bf_findbf_row_tabsbf_row_colmain
47func bf_cat(d: *u8, o: i64, s: *u8) -> i64 { var p: i64 = o; var i: i64 = 0; while s[i] != (0 as u8) { d[p] = s[i]; p = p + 1; i = i + 1 } return p }
called by 8: bf_lockbf_exportbf_markerbf_append_rowbf_keybf_qlit+2
48func bf_catn(d: *u8, o: i64, v: i64) -> i64 { let t: *u8 = sys_mmap(BF_MAGIC_28); var m: i64 = v; var p: i64 = o; if m < 0 { m = 0 } var k: i64 = 0; if m == 0 { t[0] = 48 as u8; k = 1 } while m > 0 { t[k] = (48 + (m % 10)) as u8; m = m / 10; k = k + 1 } var i: i64 = 0; while i < k { d[p] = t[k-1-i]; p = p + 1; i = i + 1 } return p }
called by 4: bf_markerbf_catn3bf_append_rowbf_summary calls 1: sys_mmap
49func bf_atoi_c(s: *u8) -> i64 { var v: i64 = 0; var i: i64 = 0; while s[i] != (0 as u8) { let c: i64 = s[i] as i64; if c >= 48 { if c <= 57 { v = v * 10 + (c - 48) } } i = i + 1 } return v }
called by 1: main
50func bf_le(q: *u8, i: i64, n: i64) -> i64 { var e: i64 = i; var s: i64 = 1; while s == 1 { if e >= n { s = 0 } else { if q[e] == (BF_NL as u8) { s = 0 } else { e = e + 1 } } } return e }
called by 6: bf_max_fidbf_epoch_ordinalbf_sweepbf_count_idbf_row_tabsbf_row_col
51func bf_col(q: *u8, ls: i64, le: i64, c: i64, out: *i64) -> i64
called by 5: bf_max_fidbf_epoch_ordinalbf_sweepbf_count_idbf_row_col
67func bf_lit_eq(q: *u8, s: i64, e: i64, lit: *u8) -> i64
called by 4: bf_sweepbf_count_idbf_selftestmain
73func bf_span_eq(q: *u8, s1: i64, e1: i64, s2: i64, e2: i64) -> i64
called by 1: bf_epoch_ordinal
79func bf_atoi_span(q: *u8, s: i64, e: i64) -> i64
called by 1: bf_sweep
86func bf_find(d: *u8, dn: i64, lit: *u8) -> i64
called by 2: bf_sweepbf_selftest calls 1: bf_vlen
101func bf_lock(prefix: *u8) -> i64
called by 1: bf_sweep calls 4: sys_mmapbf_catsys_openat_appendsys_flock
112func bf_export(path: *u8, rows: *u8, n: i64) -> i64
called by 1: bf_sweep calls 5: sys_openat_wrsys_mmapbf_catsys_writesys_close
124func bf_max_fid(q: *u8, n: i64, letter: i64) -> i64
called by 1: bf_sweep calls 3: sys_mmapbf_lebf_col
146func bf_epoch_ordinal(q: *u8, n: i64, upto: i64, e_s: i64, e_e: i64) -> i64
called by 1: bf_sweep calls 4: sys_mmapbf_lebf_colbf_span_eq
158func bf_marker(mb: *u8, q: *u8, e_s: i64, e_e: i64, ord: i64) -> i64
called by 1: bf_sweep calls 2: bf_catbf_catn
172func bf_catn3(d: *u8, o: i64, v: i64) -> i64
called by 1: bf_append_row calls 1: bf_catn
180func bf_append_row(out: *u8, o: i64, fid: i64, q: *u8, e_s: i64, e_e: i64, d_s: i64, d_e: i64, sev: i64, owner: *u8, lane: *u8, mb: *u8) -> i64
called by 1: bf_sweep calls 3: bf_catn3bf_catbf_catn
225func bf_sweep(dpfx: *u8, fpfx: *u8, minsev: i64, maxfile: i64, owner: *u8, lane: *u8, expath: *u8, mode: i64, cx: *i64) -> i64
called by 2: bf_selftestmain calls 16: sys_mmapsts_loadbf_lockbf_werrsys_closebf_max_fid+10
284func bf_key(d: *u8, o: i64, name: *u8) -> i64
called by 1: bf_summary calls 1: bf_cat
294func bf_qlit(d: *u8, o: i64, s: *u8) -> i64
called by 1: bf_summary calls 1: bf_cat
303func bf_summary(d: *u8, modename: *u8, cx: *i64, minsev: i64, maxfile: i64) -> i64
called by 1: main calls 3: bf_keybf_catnbf_qlit
370func bf_mkpfx(dst: *u8, base: *u8, suf: *u8) -> i64
called by 1: bf_selftest calls 1: bf_cat
378func bf_count_id(q: *u8, n: i64, lit: *u8) -> i64
called by 1: bf_selftest calls 4: sys_mmapbf_lebf_colbf_lit_eq
390func bf_row_tabs(q: *u8, n: i64, needle: *u8) -> i64
called by 1: bf_selftest calls 2: bf_vlenbf_le
409func bf_row_col(q: *u8, n: i64, needle: *u8, c: i64, out: *i64) -> i64
called by 1: bf_selftest calls 3: bf_vlenbf_lebf_col
424func bf_selftest(base: *u8) -> i64
called by 1: main calls 15: gv_ctrgv_headsys_mmapbf_mkpfxbf_catsts_seed+9
509func main(argc: i64, argv: *i64) -> i64
calls 10: bf_werrsys_exitbf_vlenbf_lit_eqbf_selftestsys_mmap+4