code wiki / _hdl_build / nx_wfcost_outcomes_gate_t144.nx
nx_wfcost_outcomes_gate_t144.nx source
↩ module page · 158 lines · 19994 B
1import "nx_wfcost_outcomes_t144.nx"
2func main(argc:i64,argv:*i64)->i64{
3 if argc!=2{return 2}
4 if cd_len(argv[1] as *u8)>CH_AH_PATHCELL-32{return 2}
5 if sys_mkdir(argv[1] as *u8,448)!=0{return 2}
6 let ctr:*i64=gv_ctr();gv_head("WORKFLOW-ATTRIBUTION-PRIVATE")
7 let meta:*i64=sys_mmap_shared(16) as *i64
8 let q:*u8=wfj_read("/tmp/usage-t76-actual.jsonl",CH_WIN,meta)
9 gv_check("checked actual baseline read",(q as i64)>0&&meta[0]==39729&&meta[1]==0,ctr)
10 if (q as i64)<=0{return 1}
11 let table:*i64=sys_mmap_shared(CH_AH_MAXPATHS*CHU_ROW*8) as *i64
12 let r:*i64=sys_mmap_shared(CHU_ROW*8) as *i64;let c:*i64=sys_mmap_shared(80) as *i64
13 let t:*NxJsonTok=nx_json_new(q,meta[0]);let h:*u8=sys_mmap_shared(CD_HASH_CHARS+1)
14 let stats:*i64=sys_mmap_shared(WFJ_STATS*8) as *i64;let usage:*i64=sys_mmap_shared(30*8) as *i64
15 let digest:*u8="ac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4"
16 var rc:i64=chu_totals(q,meta[0],1789076880,1789077120,table,t,r,c)
17 gv_check("canonical parser reconciles44 unique requests",rc==0&&c[2]==44,ctr)
18 gv_check("actual owned snapshot hash",wfj_digest(q,meta[0],h)==0&&cd_equal(h,digest)==1,ctr)
19 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,"",0,stats,usage)
20 gv_check("empty binding set preserves44 unknown requests",rc==0&&stats[0]==44&&stats[1]==0&&stats[2]==44&&stats[13]==44,ctr)
21 gv_check("unknown attribution includes all44 role and phase requests",stats[24]==44&&stats[19]==44,ctr)
22 gv_check("all six counters preserved in unknown bucket",usage[24]==7918450&&usage[25]==7737984&&usage[26]==0&&usage[27]==9780&&usage[28]==2337&&usage[29]==7928230,ctr)
23 let b:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
24 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,b,cd_len(b),stats,usage)
25 gv_check("explicit fixture request binding partitions1 plus43",rc==0&&stats[1]==1&&stats[2]==43&&stats[0]==44,ctr)
26 gv_check("hash matched evidence is counted separately",stats[6]==1&&stats[10]==1&&stats[11]==1,ctr)
27 gv_check("asserted work and role request coverage separate from costs",stats[16]==1&&stats[19]==43&&stats[20]==1&&stats[24]==43,ctr)
28 gv_check("fixture role retains exact request counters",usage[0]==160686&&usage[1]==160384&&usage[3]==138&&usage[4]==44&&usage[5]==160824,ctr)
29 gv_check("unknown plus bound tokens conserve baseline",usage[0]+usage[24]==c[4]&&usage[5]+usage[29]==c[9],ctr)
30 gv_check("elapsed known120 with43 unknown no walltime claim",stats[12]==1&&stats[13]==43&&stats[14]==120,ctr)
31 let x0:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\nfixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
32 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x0,cd_len(x0),stats,usage)
33 gv_check("duplicate binding ID refused",rc==2,ctr)
34 let x1:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\nfixture-2\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
35 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x1,cd_len(x1),stats,usage)
36 gv_check("duplicate request with distinct ID refused",rc==2,ctr)
37 let x2:*u8="fixture-1\t0000000000000000000000000000000000000000000000000000000000000000\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
38 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x2,cd_len(x2),stats,usage)
39 gv_check("different snapshot does not claim a request",rc==0&&stats[4]==1&&stats[1]==0&&stats[2]==44,ctr)
40 let x3:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tnot-the-request\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
41 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x3,cd_len(x3),stats,usage)
42 gv_check("unmatched request remains unknown",rc==0&&stats[5]==1&&stats[2]==44,ctr)
43 let x4:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\t0000000000000000000000000000000000000000000000000000000000000000\taccepted-deployed\tfixture-reviewer\n"
44 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x4,cd_len(x4),stats,usage)
45 gv_check("same-size wrong evidence hash classified drift",rc==0&&stats[9]==1&&stats[6]==0&&stats[11]==0,ctr)
46 let x5:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/no-such-roi-evidence-t144-file\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
47 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x5,cd_len(x5),stats,usage)
48 gv_check("missing evidence observed separately",rc==0&&stats[7]==1&&stats[8]==0&&stats[11]==0,ctr)
49 let x6:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
50 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x6,cd_len(x6),stats,usage)
51 gv_check("directory read failure remains unobservable",rc==0&&stats[8]==1&&stats[7]==0,ctr)
52 let x7:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\tpretend-root\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
53 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x7,cd_len(x7),stats,usage)
54 gv_check("invalid role refused",rc==2,ctr)
55 let x8:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\tsuccess\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
56 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x8,cd_len(x8),stats,usage)
57 gv_check("invalid phase refused",rc==2,ctr)
58 let x9:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t-1\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
59 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x9,cd_len(x9),stats,usage)
60 gv_check("negative elapsed refused",rc==2,ctr)
61 let x10:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t9007199254740992\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
62 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x10,cd_len(x10),stats,usage)
63 gv_check("unsafe numeric elapsed refused",rc==2,ctr)
64 let x11:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\t-\n"
65 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x11,cd_len(x11),stats,usage)
66 gv_check("acceptance without reviewer refused",rc==2,ctr)
67 let x12:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t-\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\n"
68 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x12,cd_len(x12),stats,usage)
69 gv_check("unknown evidence requires unknown hash",rc==2,ctr)
70 let x13:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer"
71 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x13,cd_len(x13),stats,usage)
72 gv_check("truncated binding row refused",rc==2,ctr)
73 let x14:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\n"
74 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x14,cd_len(x14),stats,usage)
75 gv_check("missing column refused",rc==2,ctr)
76 let x15:*u8="fixture-1\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t01a0893b-7403-7111-a0c1-6f0c6099a919\tresp_0883d41a10d828ad016aa3258b036887d1b67f4683907faf3c\tfixture-workflow\tfixture-task\tfixture-attempt\troot\t-\t-\twork\t120\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\taccepted-deployed\tfixture-reviewer\textra\n"
77 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,x15,cd_len(x15),stats,usage)
78 gv_check("extra column refused",rc==2,ctr)
79
80 let prefix:*u8=sys_mmap_shared(CH_AH_PATHCELL);var po:i64=sj_cat(prefix,0,argv[1] as *u8);po=sj_cat(prefix,po,"/bindings-")
81 gv_check("private plane seeded with one explicit fixture row",sts_seed(prefix,b,cd_len(b))==1,ctr)
82 let pm:*i64=sys_mmap_shared(40) as *i64;var plane:*u8=wfj_plane(prefix,WFJ_COLS,pm)
83 gv_check("declared plane row read without truncation",(plane as i64)>0&&pm[1]==0&&pm[2]==1&&pm[3]==1&&pm[0]==cd_len(b),ctr)
84 if (plane as i64)>0{
85 gv_check("plane row bytes preserved",wfj_span_eq(plane,0,pm[0],b,0,cd_len(b))==1,ctr)
86 rc=wfj_join(q,table,c[0],1789076880,1789077120,digest,plane,pm[0],stats,usage)
87 gv_check("actual plane join partitions one and43",rc==0&&stats[1]==1&&stats[2]==43&&stats[6]==1,ctr)
88
89 let bh:*u8=sys_mmap_shared(CD_HASH_CHARS+1);let bh2:*u8=sys_mmap_shared(CD_HASH_CHARS+1)
90 gv_check("decoded binding hash equals exact joined row hash",wfj_digest(plane,pm[0],bh)==0&&wfj_digest(b,cd_len(b),bh2)==0&&cd_equal(bh,bh2)==1,ctr)
91 plane[0]=103 as u8
92 gv_check("one-byte attribution identity change changes snapshot hash",wfj_digest(plane,pm[0],bh2)==0&&cd_equal(bh,bh2)==0,ctr)
93 plane[0]=b[0]
94 let artifact:*u8=sys_mmap_shared(CH_AH_PATHCELL);var ap:i64=sj_cat(artifact,0,argv[1] as *u8);ap=sj_cat(artifact,ap,"/bindings.tsv")
95 gv_check("exact decoded snapshot exclusively retained and synced",wfj_retain_bindings(artifact,plane,pm[0])==0,ctr)
96 let am:*i64=sys_mmap_shared(16) as *i64;var retained:*u8=wfj_read(artifact,0,am)
97 gv_check("retained bytes exactly equal consumed rows",(retained as i64)>0&&am[0]==pm[0]&&wfj_span_eq(retained,0,am[0],plane,0,pm[0])==1,ctr)
98 gv_check("existing snapshot is not overwritten",wfj_retain_bindings(artifact,"changed",7)==FIO_EEXIST,ctr)
99 if (retained as i64)>0{sys_munmap(retained,am[0]+1)}
100 retained=wfj_read(artifact,0,am)
101 gv_check("failed repeat preserves original snapshot",(retained as i64)>0&&wfj_digest(retained,am[0],bh2)==0&&cd_equal(bh,bh2)==1,ctr)
102 if (retained as i64)>0{sys_munmap(retained,am[0]+1)}
103 let wr:*NxFileWriteResult=sys_mmap_shared(__size_of(NxFileWriteResult)) as *NxFileWriteResult
104 let readonly:i64=sys_openat_rd(artifact)
105 gv_check("valid readonly descriptor actual write error preserved",readonly>=0&&fio_write_sync_fd(readonly,"x",1,wr)!=0&&wr.written==0,ctr)
106 gv_check("invalid snapshot directory refuses",wfj_retain_bindings("/proc/nishi-binding-fixture/snapshot",plane,pm[0])!=0,ctr)
107 gv_check("empty snapshot hash has independently known identity",wfj_digest("",0,bh2)==0&&cd_equal(bh2,"e3b0c44298fc1c149afbf4c8996fb92427ae41e4649b934ca495991b7852b855")==1,ctr)
108 gv_check("snapshot test workspace released",sys_munmap(bh,CD_HASH_CHARS+1)==0&&sys_munmap(bh2,CD_HASH_CHARS+1)==0&&sys_munmap(artifact,CH_AH_PATHCELL)==0&&sys_munmap(am as *u8,16)==0&&sys_munmap(wr as *u8,__size_of(NxFileWriteResult))==0,ctr)
109 gv_check("plane allocation released",sys_munmap(plane,pm[4])==0,ctr)
110 }
111 let empty_prefix:*u8=sys_mmap_shared(CH_AH_PATHCELL);po=sj_cat(empty_prefix,0,argv[1] as *u8);po=sj_cat(empty_prefix,po,"/empty-")
112 gv_check("empty plane explicitly seeded",sts_seed(empty_prefix,"",0)==0,ctr)
113 plane=wfj_plane(empty_prefix,WFJ_COLS,pm)
114 gv_check("known empty plane distinct from absent",(plane as i64)>0&&pm[1]==0&&pm[2]==0&&pm[3]==0&&pm[0]==0,ctr)
115 if (plane as i64)>0{sys_munmap(plane,pm[4])}
116 let missing_prefix:*u8=sys_mmap_shared(CH_AH_PATHCELL);po=sj_cat(missing_prefix,0,argv[1] as *u8);po=sj_cat(missing_prefix,po,"/absent-")
117 plane=wfj_plane(missing_prefix,WFJ_COLS,pm)
118 gv_check("absent plane refuses rather than reporting empty",(plane as i64)==0&&pm[1]!=0,ctr)
119 let w:*i64=ss_begin();ss_add(w,1,"q:n","2",1)
120 gv_check("private overdeclared count evidence appended",ss_commit(prefix,w,ss_next_segid(prefix))==0,ctr)
121 plane=wfj_plane(prefix,WFJ_COLS,pm)
122 gv_check("missing declared row refuses",(plane as i64)==0&&pm[1]!=0,ctr)
123 let w2:*i64=ss_begin();ss_add(w2,1,"q:n","9007199254740991",16)
124 gv_check("private impossible count evidence appended",ss_commit(prefix,w2,ss_next_segid(prefix))==0,ctr)
125 plane=wfj_plane(prefix,WFJ_COLS,pm)
126 gv_check("declared count exceeding physical keys refuses promptly",(plane as i64)==0&&pm[1]!=0,ctr)
127
128 let cfg_prefix:*u8=sys_mmap_shared(CH_AH_PATHCELL);po=sj_cat(cfg_prefix,0,argv[1] as *u8);po=sj_cat(cfg_prefix,po,"/config-")
129 let cfg:*u8=sys_mmap_shared(CH_OUT);var co:i64=sj_cat(cfg,0,"baseline\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t1789076880\t1789077120\t")
130 co=sj_cat(cfg,co,empty_prefix);co=sj_cat(cfg,co,"\tenabled\npaused\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t1789076880\t1789077120\t-\tpaused\n")
131
132 let bound_prefix:*u8=sys_mmap_shared(CH_AH_PATHCELL);po=sj_cat(bound_prefix,0,argv[1] as *u8);po=sj_cat(bound_prefix,po,"/retained-bindings-")
133 let bound_snapshot:*u8=sys_mmap_shared(CH_AH_PATHCELL);po=sj_cat(bound_snapshot,0,argv[1] as *u8);po=sj_cat(bound_snapshot,po,"/configured-bindings.tsv")
134 gv_check("configured retained binding plane seeded",sts_seed(bound_prefix,b,cd_len(b))==1,ctr)
135 co=sj_cat(cfg,co,"retained\t/tmp/usage-t76-actual.jsonl\tac4acae4edaa15818166b7d0755cefd74bb71410e01e6c5bde94264d13c245f4\t1789076880\t1789077120\t")
136 co=sj_cat(cfg,co,bound_prefix);co=sj_cat(cfg,co,"\tenabled\t");co=sj_cat(cfg,co,bound_snapshot);co=sj_cat(cfg,co,"\n")
137 gv_check("existing plane codec seeds compatible seven/eight column configs",sts_seed(cfg_prefix,cfg,co)==3,ctr)
138 let ca:*i64=sys_mmap_shared(5*8) as *i64;ca[0]="nx_wfcost" as *u8 as i64;ca[1]="evaluate-config" as *u8 as i64;ca[2]="baseline" as *u8 as i64;ca[3]=cfg_prefix as i64;ca[4]=0
139 gv_check("configured real44 request evaluation executes",wfj_config_command(4,ca)==0,ctr)
140 ca[2]="retained" as *u8 as i64
141 gv_check("configured real request attribution retains exact consumed snapshot",wfj_config_command(4,ca)==0,ctr)
142 let retained_meta:*i64=sys_mmap_shared(16) as *i64;let retained_rows:*u8=wfj_read(bound_snapshot,0,retained_meta)
143 gv_check("configured snapshot reconstructs actual consumed binding row",(retained_rows as i64)>0&&retained_meta[0]==cd_len(b)&&wfj_span_eq(retained_rows,0,retained_meta[0],b,0,cd_len(b))==1,ctr)
144 if (retained_rows as i64)>0{sys_munmap(retained_rows,retained_meta[0]+1)}
145 gv_check("configured retained artifact collision refuses safely",wfj_config_command(4,ca)==3,ctr)
146 gv_check("configured snapshot workspace released",sys_munmap(retained_meta as *u8,16)==0&&sys_munmap(bound_prefix,CH_AH_PATHCELL)==0&&sys_munmap(bound_snapshot,CH_AH_PATHCELL)==0,ctr)
147 ca[2]="paused" as *u8 as i64;gv_check("paused config never executes evaluation",wfj_config_command(4,ca)==4,ctr)
148 ca[2]="absent" as *u8 as i64;gv_check("missing configuration is nonzero not help success",wfj_config_command(4,ca)==3,ctr)
149 ca[2]="baseline" as *u8 as i64;ca[3]=missing_prefix as i64;gv_check("unreadable configuration plane refuses",wfj_config_command(4,ca)==3,ctr)
150 gv_check("configuration workspace released",sys_munmap(ca as *u8,5*8)==0&&sys_munmap(cfg,CH_OUT)==0&&sys_munmap(cfg_prefix,CH_AH_PATHCELL)==0,ctr)
151
152 gv_check("plane gate workspace released",sys_munmap(pm as *u8,40)==0&&sys_munmap(prefix,CH_AH_PATHCELL)==0&&sys_munmap(empty_prefix,CH_AH_PATHCELL)==0&&sys_munmap(missing_prefix,CH_AH_PATHCELL)==0,ctr)
153
154 gv_check("raw snapshot released",sys_munmap(q,meta[0]+1)==0,ctr)
155 gv_check("request workspace released",sys_munmap(table as *u8,CH_AH_MAXPATHS*CHU_ROW*8)==0&&sys_munmap(r as *u8,CHU_ROW*8)==0&&sys_munmap(c as *u8,80)==0&&sys_munmap(t as *u8,NX_JSONTOK_BYTES)==0,ctr)
156 gv_check("join workspace released",sys_munmap(h,CD_HASH_CHARS+1)==0&&sys_munmap(stats as *u8,WFJ_STATS*8)==0&&sys_munmap(usage as *u8,30*8)==0&&sys_munmap(meta as *u8,16)==0,ctr)
157 return gv_verdict("WORKFLOW-ATTRIBUTION-PRIVATE",ctr,"explicit request joins; assertion and retained identity remain distinct")
158}