nx_store_collision_check.nx source

1// nx_store_collision_check.nx -- acl lane F745. Scans a TAB-separated store VIEW (export) for 2// DUPLICATE ids in column <col> = the KEY-COLLISION signature: two independent writers grabbed the 3// SAME id, so last-writer-wins silently overwrote one (seq71 docs-vs-design-market both id 17; seq40 4// frontier F-id races; seq96 pmdash elf). Detect-and-refuse, fail-closed. No hardware writes (Rule 26). 5// nx_store_collision_check dupid <path> <col0based> 6// exit: 0 CLEAN | 3 COLLISION (>=1 reused id) | 4 ABSENT | 2 usage. stdout carries verdict + first dups. 7// license_tier: ORIGINAL expect_exit: 0 8import "nx_syscalls.nx" 9const K_MAGIC_4194304: i64 = 4194304 10const K_MAGIC_1048576: i64 = 1048576 11const K_MAGIC_65536: i64 = 65536 12 13func sc_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 } 14func sc_wn(fd: i64, v: i64) -> i64 { var m: i64 = v; if m < 0 { sc_w(fd, "-" as *u8); m = 0 - m } let t: *u8 = sys_mmap(28); 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 } let o: *u8 = sys_mmap(28); var i: i64 = 0; while i < k { o[i] = t[k - 1 - i]; i = i + 1 } sys_write(fd, o, k); return 0 } 15func sc_read(path: *u8, buf: *u8, cap: i64) -> i64 { 16 let fd: i64 = sys_openat_rd(path) 17 if fd < 0 { return 0 - 1 } 18 var n: i64 = 0 19 var go: i64 = 1 20 while go == 1 { let r: i64 = sys_read(fd, (buf as i64 + n) as *u8, cap - n); if r <= 0 { go = 0 } else { n = n + r } if n >= cap { go = 0 } } 21 sys_close(fd) 22 return n 23} 24func sc_atoi(s: *u8) -> i64 { var v: i64 = 0; var i: i64 = 0; while s[i] != (0 as u8) { let c: i64 = s[i]; if c < 48 { i = i + 1 } else { if c > 57 { i = i + 1 } else { v = v * 10 + (c - 48); i = i + 1 } } } return v } 25func sc_eq(ids: *u8, a: i64, b: i64) -> i64 { 26 var i: i64 = 0 27 var go: i64 = 1 28 var res: i64 = 0 29 while go == 1 { 30 let ca: i64 = ids[a + i] 31 let cb: i64 = ids[b + i] 32 if ca != cb { go = 0 } else { if ca == 0 { res = 1; go = 0 } else { i = i + 1 } } 33 } 34 return res 35} 36func main(argc: i64, argv: *i64) -> i64 { 37 if argc < 4 { sc_w(2, "usage: nx_store_collision_check dupid <path> <col0based>\n" as *u8); sys_exit(2); return 2 } 38 let path: *u8 = argv[2] as *u8 39 let col: i64 = sc_atoi(argv[3] as *u8) 40 let cap: i64 = K_MAGIC_4194304 41 let buf: *u8 = sys_mmap(cap) 42 let n: i64 = sc_read(path, buf, cap) 43 if n < 0 { sc_w(1, "COLLISION-CHECK verdict=ABSENT path=" as *u8); sc_w(1, path); sc_w(1, "\n" as *u8); sys_exit(4); return 4 } 44 let ids: *u8 = sys_mmap(K_MAGIC_1048576) 45 let offs: *i64 = sys_mmap(8 * K_MAGIC_65536) as *i64 46 var idc: i64 = 0 47 var idoff: i64 = 0 48 var dups: i64 = 0 49 var ls: i64 = 0 50 var i: i64 = 0 51 while i <= n { 52 var eol: i64 = 0 53 if i == n { eol = 1 } else { if buf[i] == (10 as u8) { eol = 1 } } 54 if eol == 1 { 55 var p: i64 = ls 56 var c: i64 = 0 57 var okcol: i64 = 1 58 while c < col { 59 var s: i64 = 1 60 while s == 1 { if p >= i { okcol = 0; s = 0 } else { if buf[p] == (9 as u8) { s = 0 } else { p = p + 1 } } } 61 if okcol == 0 { c = col } else { p = p + 1; c = c + 1 } 62 } 63 if okcol == 1 { 64 let st: i64 = idoff 65 var q: i64 = p 66 var go: i64 = 1 67 while go == 1 { if q >= i { go = 0 } else { if buf[q] == (9 as u8) { go = 0 } else { ids[idoff] = buf[q]; idoff = idoff + 1; q = q + 1 } } } 68 ids[idoff] = 0 as u8 69 idoff = idoff + 1 70 if ids[st] != (0 as u8) { 71 var d: i64 = 0 72 var k: i64 = 0 73 while k < idc { if sc_eq(ids, offs[k], st) == 1 { d = 1; k = idc } else { k = k + 1 } } 74 if d == 1 { 75 dups = dups + 1 76 if dups <= 8 { sc_w(1, " DUP id=" as *u8); sc_w(1, (ids as i64 + st) as *u8); sc_w(1, "\n" as *u8) } 77 } else { 78 offs[idc] = st 79 idc = idc + 1 80 } 81 } 82 } 83 ls = i + 1 84 } 85 i = i + 1 86 } 87 sc_w(1, "COLLISION-CHECK distinct_ids=" as *u8); sc_wn(1, idc) 88 sc_w(1, " duplicates=" as *u8); sc_wn(1, dups) 89 if dups > 0 { sc_w(1, " verdict=COLLISION (id reused -- key clobber; assign a fresh id via addauto)\n" as *u8); sys_exit(3); return 3 } 90 sc_w(1, " verdict=CLEAN\n" as *u8) 91 sys_exit(0) 92 return 0 93}