`nx_workmix.nx` source

↩ module page · 180 lines · 8434 B
1// nx_workmix.nx -- THE WORK-MIX CENSUS (ecosystem EC56, 2026-09-17): what LANDED in the window, classed FEATURE,
2// ENABLEMENT, REWORK or UNCLASSED, so investment is a measured axis and the mix can be steered toward features.
3//   usage: nx_workmix census [days] [ledger]
4//   reads  the costcal ledger (land, retract and open rows; ONE reader of the boards' journals wrote them),
5//          every published board's plan (rungrole rows and deps only), the class table compare/workmix.conf
6//   prints the partition, the boards no class row names (the shrink-only worklist), then ONE canonical WORKMIX line LAST
7//   writes that line to knowledge/status/workmix.status (truncate) and appends it to knowledge/status/workmix.log;
8//          a run over a non-default ledger writes BESIDE that ledger, never over the production status
9//   exit 0 CENSUSED | 2 usage | 3 NO-LEDGER or NO-POPULATION (could not look is never an empty window)
10// The ruler is nx_workmix_lib (wm_mix_census); this file only gathers the inputs and publishes the line.
11// license_tier: ORIGINAL   No hw writes (Rule 26).
12import "nx_syscalls.nx"
13import "nx_costest_lib.nx"
14import "nx_ladder_lib.nx"
15import "nx_comparetree_lib.nx"
16import "nx_workmix_lib.nx"
17
18const WP_LEDGER: *u8 = "knowledge/status/costcal.ledger"
19const WP_STATUS: *u8 = "knowledge/status/workmix.status"   // ONE canonical line, truncate-written
20const WP_LOG: *u8 = "knowledge/status/workmix.log"         // the same line appended: one census says a level, two say a trend
21const WP_STATUS_SFX: *u8 = ".workmix.status"
22const WP_LOG_SFX: *u8 = ".workmix.log"
23const WP_CONF_NAME: *u8 = "workmix"
24const WP_CONF_SFX: *u8 = ".conf"
25const WP_LIST_NAME: *u8 = "regen"
26const WP_LIST_SFX: *u8 = ".list"
27const WP_DAY_S: i64 = 86400
28const WP_EXIT_OK: i64 = 0
29const WP_EXIT_USAGE: i64 = 2
30const WP_EXIT_UNOBS: i64 = 3
31
32func wp_w(s: *u8) -> i64 { return sys_write(1, s, ces_slen(s)) }
33func wp_n(v: i64) -> i64 {
  let b: *u8 = sys_mmap(CES_NUM_CAP + 1)
  let o: i64 = ces_fmt_int(b, 0, v)
  return sys_write(1, b, o)
37}
38
39func wp_usage() -> i64 {
  wp_w("usage: nx_workmix census [days] [ledger]\n" as *u8)
  wp_w("exit 0 CENSUSED | 2 usage | 3 NO-LEDGER or NO-POPULATION\n" as *u8)
  return WP_EXIT_USAGE
43}
44
45func wp_span_copy(buf: *u8, off: i64, len: i64) -> *u8 {
  let d: *u8 = sys_mmap(len + 1)
  wm_copy_span(d, 0, buf, off, len)
  return d
49}
50
51// a compare-tree file by name, first published tree then the second: the resolver, never a hand-rolled path
52func wp_read_compare(name: *u8, sfx: *u8, lenp: *i64) -> *u8 {
  let path: *u8 = sys_mmap(CT_PATH_CAP)
  lenp[0] = 0
  ct_build_path(ct_first_published(), name, sfx, path)
  var b: *u8 = sys_read_file(path, lenp)
  if lenp[0] <= 0 {
      ct_build_path(ct_second_published(), name, sfx, path)
      b = sys_read_file(path, lenp)
  }
  return b
62}
63
64func wp_beside(base: *u8, sfx: *u8) -> *u8 {
  let d: *u8 = sys_mmap(ces_slen(base) + ces_slen(sfx) + 1)
  let o: i64 = ces_cat(d, 0, base)
  ces_cat(d, o, sfx)
  return d
69}
70
71func wp_census(days: i64, ledger: *u8, isdefault: i64) -> i64 {
  let lenp: *i64 = sys_mmap(WM_I64) as *i64
  lenp[0] = 0
  let led: *u8 = sys_read_file(ledger, lenp)
  let ln: i64 = lenp[0]
  if ln <= 0 {
      wp_w("WORKMIX ledger=" as *u8); wp_w(ledger); wp_w(" UNREADABLE: the costcal beat has not written it, so what landed is UNMEASURED verdict=NO-LEDGER\n" as *u8)
      return WP_EXIT_UNOBS
  }
  let st: *i64 = sys_mmap(CES_S_SLOTS * WM_I64) as *i64
  var ledger_asof: i64 = CES_NONE
  if ces_cal_parse(led, ln, st) == 1 { ledger_asof = st[CES_S_ASOF] }
  let cnp: *i64 = sys_mmap(WM_I64) as *i64
  let conf: *u8 = wp_read_compare(WP_CONF_NAME, WP_CONF_SFX, cnp)
  var cn: i64 = cnp[0]
  if cn < 0 { cn = 0 }
  let lnp: *i64 = sys_mmap(WM_I64) as *i64
  let lst: *u8 = wp_read_compare(WP_LIST_NAME, WP_LIST_SFX, lnp)
  let lsn: i64 = lnp[0]
  if lsn <= 0 { wp_w("WORKMIX regen.list UNREADABLE in both trees verdict=NO-POPULATION\n" as *u8); return WP_EXIT_UNOBS }
  // the boards: arrays sized from the list itself (one slot per line)
  var nlines: i64 = 1
  var c0: i64 = 0
  while c0 < lsn { if lst[c0] == (CES_CH_NL as u8) { nlines = nlines + 1 } c0 = c0 + 1 }
  let names: *i64 = sys_mmap(nlines * WM_I64) as *i64
  let pbuf: *i64 = sys_mmap(nlines * WM_I64) as *i64
  let plen: *i64 = sys_mmap(nlines * WM_I64) as *i64
  let which: *i64 = sys_mmap(WM_I64) as *i64
  var np: i64 = 0
  var noplan: i64 = 0
  var ibound: i64 = 1
  var nclassless: i64 = 0
  var p: i64 = 0
  wp_w("WORKMIX-UNCLASSED-BOARDS (no row in the class table; their rungs class only by rungrole):" as *u8)
  while p < lsn {
      let e: i64 = ces_line_end(lst, lsn, p)
      let l: i64 = e - p
      if l > 0 { if lst[p] != (CES_CH_HASH as u8) {
          let name: *u8 = wp_span_copy(lst, p, l)
          if wm_board_class(conf, cn, name) == WM_B_NONE { nclassless = nclassless + 1; wp_w(" " as *u8); wp_w(name) }
          lenp[0] = 0
          let plan: *u8 = bf_read_plan(ct_first_published(), ct_second_published(), name, lenp, which)
          if lenp[0] > 0 {
              names[np] = name as i64
              pbuf[np] = plan as i64
              plen[np] = lenp[0]
              ibound = ibound + wm_index_bound(lenp[0], name)
              np = np + 1
          } else { noplan = noplan + 1 }
      } }
      p = e + 1
  }
  wp_w("\n" as *u8)
  // the feature-deps index, built once: which rungs does a FEATURE rung stand on
  let idx: *u8 = sys_mmap(ibound)
  var idxn: i64 = 0
  var b: i64 = 0
  while b < np {
      let nm: *u8 = names[b] as *u8
      idxn = wm_index_board(pbuf[b] as *u8, plen[b], nm, wm_board_class(conf, cn, nm), idx, idxn)
      b = b + 1
  }
  let now: i64 = sys_now_realtime_sec()
  let acc: *i64 = sys_mmap(WM_A_SLOTS * WM_I64) as *i64
  wm_mix_census(led, ln, now - days * WP_DAY_S, now + 1, conf, cn, names, pbuf, plen, np, idx, idxn, acc)
  wp_w("WORKMIX-INPUTS ledger=" as *u8); wp_w(ledger); wp_w(" ledger_bytes=" as *u8); wp_n(ln)
  wp_w(" ledger_asof=" as *u8); wp_n(ledger_asof)
  wp_w(" ledger_age_s=" as *u8)
  if ledger_asof >= 0 { wp_n(now - ledger_asof) } else { wp_n(CES_NONE) }
  wp_w(" class_table_bytes=" as *u8); wp_n(cn); wp_w(" boards_read=" as *u8); wp_n(np); wp_w(" boards_noplan=" as *u8); wp_n(noplan)
  wp_w(" boards_without_a_class=" as *u8); wp_n(nclassless); wp_w(" feature_deps_index_bytes=" as *u8); wp_n(idxn); wp_w("\n" as *u8)
  var k: i64 = 0
  while k < WM_CLASSES {
      wp_w("  class=" as *u8); wp_w(wm_class_name(k)); wp_w(" land_rows=" as *u8); wp_n(acc[WM_A_EV + k])
      wp_w(" deciu=" as *u8); wp_n(acc[WM_A_DECIU + k]); wp_w(" permil_of_rows=" as *u8); wp_n(wm_permil(acc[WM_A_EV + k], acc[WM_A_LAND])); wp_w("\n" as *u8)
      k = k + 1
  }
  let line: *u8 = sys_mmap(wm_line_bound())
  let lo: i64 = wm_line(line, 0, now, days, np, acc)
  // publish: the status line truncate-written, the same line appended to the log. A non-default ledger publishes beside itself.
  var sp: *u8 = WP_STATUS
  var lp: *u8 = WP_LOG
  if isdefault == 0 { sp = wp_beside(ledger, WP_STATUS_SFX); lp = wp_beside(ledger, WP_LOG_SFX) }
  var swrote: i64 = 0
  let sfd: i64 = sys_openat_wr(sp, MODE_0644)
  if sfd >= 0 { if sys_write(sfd, line, lo) == lo { swrote = 1 } sys_close(sfd) }
  var lwrote: i64 = 0
  let lfd: i64 = sys_openat_append(lp, MODE_0644)
  if lfd >= 0 { if sys_write(lfd, line, lo) == lo { lwrote = 1 } sys_close(lfd) }
  wp_w("WORKMIX-PUBLISH status=" as *u8); wp_w(sp); wp_w(" wrote=" as *u8); wp_n(swrote); wp_w(" log=" as *u8); wp_w(lp); wp_w(" appended=" as *u8); wp_n(lwrote); wp_w("\n" as *u8)
  sys_write(1, line, lo)
  return WP_EXIT_OK
163}
164
165func main(argc: i64, argv: *i64) -> i64 {
  if argc < 2 { return wp_usage() }
  let verb: *u8 = argv[1] as *u8
  if ces_span_is(verb, 0, ces_slen(verb), "census" as *u8) == 0 { return wp_usage() }
  var days: i64 = CES_WIP_ACTIVE_S / WP_DAY_S
  if argc > 2 {
      let a: *u8 = argv[2] as *u8
      let d: i64 = ces_parse_int(a, 0, ces_slen(a))
      if d <= 0 { return wp_usage() }
      days = d
  }
  var ledger: *u8 = WP_LEDGER
  var isdefault: i64 = 1
  if argc > 3 { ledger = argv[3] as *u8; isdefault = 0 }
  return wp_census(days, ledger, isdefault)
180}
nx_workmix.nx source

`nx_workmix.nx` source
