code wiki / _hdl_build / nx_ws_miner.nx

nx_ws_miner.nx

buildroot/runtime/_hdl_build/nx_ws_miner.nx

30956 B835 linesdepth 3pulls 3 transitivereach 0 importersview sourcekind tooltopic ws
docsdependenciesstructsconstsfunctions

about

nx_ws_miner.nx -- F217-class HISTORIC WORKSTREAM MINER (ws=ws-intel, 2026-07-20). Mines the append-only ws_sync journal (the ecosystem's workstream HISTORY) into machine-readable intelligence: per-lane lifecycle (kickoffs/beats/dones, first/last ts, distinct actors, DONE|ACTIVE|STALE|ABANDONED), per-actor engagement, honest totals. The journal IS the historic record -- this organ makes it QUERYABLE (JSON verb) and PUBLISHABLE (HTML page verb) so monitoring parallel + historic workstreams is a live ecosystem surface, not Claude-context archaeology. Sibling of nx_ws_kickoff_sync (the writer) and nx_ws_cycle (evidence-derived phase). Composes -- does not duplicate. SCALE LAW: reads windowed + envelope DECLARED in output (window_bytes / truncated / lanes_capped / actors_capped) -- silent capping forbidden by construction. license_tier: ORIGINAL No hw writes (Rule 26). mine <journal> [stale_sec] [abandoned_sec] -> JSON to stdout page <journal> <outfile> [stale_sec] [abandoned_sec] -> HTML file + marker line selftest <scratch-journal> -> gate T1..T9 (caller pre-cleans path)

dependencies 2 imports · 0 importers

nx_syscalls.nx nx_gate_verdict.nx nx_ws_miner.nx

imports: nx_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 gv_puts sys_write sys_exit wm_vlen wm_lit_eq wm_selftest gv_ctr sys_mmap gv_head gv_puts ↻ sys_mmap ↻ sys_now_realtime_sec sys_mmap ↻ sys_clock_gettime_real wm_read sys_openat_rd sys_read sys_close wm_lanes_total sys_mmap ↻ wm_le wm_col wm_lit_eq ↻ wm_first_kick sys_mmap ↻ wm_le ↻ wm_col ↻ wm_lit_eq ↻ wm_span_eq wm_state wm_has sys_mmap ↻ wm_le ↻ wm_col ↻ wm_lit_eq ↻ wm_span_eq ↻ wm_last_ts sys_mmap ↻ wm_le ↻

structs

none

consts

17const WM_MAGIC_4096: i64 = 4096
18const WM_MAGIC_2000: i64 = 2000
19const WM_MAGIC_3000: i64 = 3000
20const WM_MAGIC_7200: i64 = 7200
22const WM_WIN: i64 = 4194304
23const WM_OUT: i64 = 262144
24const WM_SOFT: i64 = 40960
25const WM_SOFT2: i64 = 57344
26const WM_PAGE_SOFT: i64 = 245760
27const WM_NOTE_MAX: i64 = 160
28const WM_NAME_MAX: i64 = 120
29const WM_STALE_DEF: i64 = 3600
30const WM_ABAND_DEF: i64 = 604800

functions

33func wm_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 6: wm_appendwm_keywm_qlitwm_hescwm_td_nwm_page_html
34func wm_catn(d: *u8, o: i64, v: i64) -> i64
called by 6: wm_appendwm_emit_lanewm_emit_actorwm_mine_jsonwm_td_nwm_page_html calls 1: sys_mmap
46func wm_vlen(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} return n }
called by 3: wm_mine_jsonwm_findmain
47func wm_atoi_z(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
48func wm_read(path: *u8, buf: *u8, cap: i64) -> i64
called by 2: wm_selftestmain calls 3: sys_openat_rdsys_readsys_close
58func wm_append(journal: *u8, ts: i64, verb: *u8, ws: *u8, actor: *u8, note: *u8) -> i64
called by 1: wm_selftest calls 7: sys_now_realtime_secsys_mmapwm_catnwm_catsys_openat_appendsys_write+1
79func wm_le(q: *u8, i: i64, n: i64) -> i64
called by 17: wm_frameswm_first_kickwm_haswm_count_verbwm_first_tswm_last_ts+11
85func wm_col(q: *u8, ls: i64, le: i64, c: i64, out: *i64) -> i64
called by 16: wm_first_kickwm_haswm_count_verbwm_first_tswm_last_tswm_note_span+10
101func wm_lit_eq(q: *u8, s: i64, e: i64, lit: *u8) -> i64
called by 9: wm_first_kickwm_haswm_count_verbwm_lanes_totalwm_ws_span_litwm_actor_span_lit+3
107func wm_span_eq(q: *u8, s1: i64, e1: i64, s2: i64, e2: i64) -> i64
called by 10: wm_first_kickwm_haswm_count_verbwm_first_tswm_last_tswm_note_span+4
113func wm_atoi(q: *u8, s: i64, e: i64) -> i64
called by 2: wm_first_tswm_last_ts
119func wm_frames(q: *u8, n: i64) -> i64
called by 2: wm_mine_jsonwm_page_html calls 1: wm_le
127func wm_first_kick(q: *u8, upto: i64, ws_s: i64, ws_e: i64) -> i64
called by 3: wm_lanes_totalwm_mine_jsonwm_page_html calls 5: sys_mmapwm_lewm_colwm_lit_eqwm_span_eq
140func wm_has(q: *u8, n: i64, verb: *u8, ws_s: i64, ws_e: i64) -> i64
called by 1: wm_state calls 5: sys_mmapwm_lewm_colwm_lit_eqwm_span_eq
153func wm_count_verb(q: *u8, cx: *i64, verb: *u8, ws_s: i64, ws_e: i64) -> i64
called by 3: wm_emit_lanewm_page_htmlwm_selftest calls 5: sys_mmapwm_lewm_colwm_lit_eqwm_span_eq
168func wm_first_ts(q: *u8, cx: *i64, ws_s: i64, ws_e: i64) -> i64
called by 2: wm_emit_lanewm_selftest calls 5: sys_mmapwm_lewm_colwm_span_eqwm_atoi
182func wm_last_ts(q: *u8, cx: *i64, ws_s: i64, ws_e: i64) -> i64
called by 4: wm_statewm_emit_lanewm_page_htmlwm_selftest calls 5: sys_mmapwm_lewm_colwm_span_eqwm_atoi
197func wm_note_span(q: *u8, cx: *i64, ws_s: i64, ws_e: i64, out: *i64) -> i64
called by 2: wm_emit_lanewm_page_html calls 4: sys_mmapwm_lewm_colwm_span_eq
214func wm_ws_actors(q: *u8, cx: *i64, ws_s: i64, ws_e: i64) -> i64
called by 2: wm_emit_lanewm_page_html calls 4: sys_mmapwm_lewm_colwm_span_eq
243func wm_state(q: *u8, cx: *i64, ws_s: i64, ws_e: i64) -> i64
called by 4: wm_lanes_totalwm_emit_lanewm_page_htmlwm_selftest calls 2: wm_haswm_last_ts
252func wm_state_name(st: i64) -> *u8
called by 2: wm_emit_lanewm_page_html
258func wm_lanes_total(q: *u8, cx: *i64, t: *i64) -> i64
called by 3: wm_mine_jsonwm_page_htmlwm_selftest calls 6: sys_mmapwm_lewm_colwm_lit_eqwm_first_kickwm_state
277func wm_ws_span_lit(q: *u8, cx: *i64, ws: *u8, out: *i64) -> i64
called by 1: wm_selftest calls 4: sys_mmapwm_lewm_colwm_lit_eq
288func wm_actor_span_lit(q: *u8, cx: *i64, actor: *u8, out: *i64) -> i64
called by 1: wm_selftest calls 4: sys_mmapwm_lewm_colwm_lit_eq
301func wm_actor_seen(q: *u8, upto: i64, a_s: i64, a_e: i64) -> i64
called by 2: wm_actors_distinctwm_mine_json calls 4: sys_mmapwm_lewm_colwm_span_eq
311func wm_actors_distinct(q: *u8, cx: *i64) -> i64
called by 3: wm_mine_jsonwm_page_htmlwm_selftest calls 4: sys_mmapwm_lewm_colwm_actor_seen
323func wm_actor_frames(q: *u8, cx: *i64, a_s: i64, a_e: i64) -> i64
called by 1: wm_emit_actor calls 4: sys_mmapwm_lewm_colwm_span_eq
335func wm_actor_ws(q: *u8, cx: *i64, a_s: i64, a_e: i64) -> i64
called by 2: wm_emit_actorwm_selftest calls 4: sys_mmapwm_lewm_colwm_span_eq
365func wm_jesc(d: *u8, o: i64, q: *u8, s: i64, e: i64, maxb: i64) -> i64
called by 3: wm_emit_lanewm_emit_actorwm_mine_json
379func wm_key(d: *u8, o: i64, name: *u8) -> i64
called by 3: wm_emit_lanewm_emit_actorwm_mine_json calls 1: wm_cat
389func wm_qlit(d: *u8, o: i64, s: *u8) -> i64
called by 2: wm_emit_lanewm_mine_json calls 1: wm_cat
396func wm_emit_lane(d: *u8, o: i64, q: *u8, cx: *i64, ws_s: i64, ws_e: i64) -> i64
called by 1: wm_mine_json calls 12: wm_keywm_jescwm_statewm_state_namewm_qlitwm_count_verb+6
447func wm_emit_actor(d: *u8, o: i64, q: *u8, cx: *i64, a_s: i64, a_e: i64) -> i64
called by 1: wm_mine_json calls 5: wm_keywm_jescwm_actor_frameswm_catnwm_actor_ws
465func wm_mine_json(q: *u8, cx: *i64, d: *u8) -> i64
called by 2: wm_selftestmain calls 16: wm_keywm_catnwm_qlitwm_vlenwm_jescwm_frames+10
583func wm_hesc(d: *u8, o: i64, q: *u8, s: i64, e: i64, maxb: i64) -> i64
called by 1: wm_page_html calls 1: wm_cat
597func wm_td_n(d: *u8, o: i64, v: i64) -> i64
called by 1: wm_page_html calls 2: wm_catwm_catn
604func wm_page_html(q: *u8, cx: *i64, d: *u8) -> i64
called by 1: main calls 18: wm_catsys_mmapwm_lanes_totalwm_actors_distinctwm_frameswm_catn+12
692func wm_find(d: *u8, dn: i64, lit: *u8) -> i64
called by 1: wm_selftest calls 1: wm_vlen
707func wm_selftest(journal: *u8) -> i64
called by 1: main calls 19: gv_ctrgv_headsys_mmapsys_now_realtime_secwm_readwm_lanes_total+13
789func main(argc: i64, argv: *i64) -> i64
calls 15: gv_putssys_exitwm_vlenwm_lit_eqwm_selftestsys_mmap+9