nx_dlperf_census.nx source

1// nx_dlperf_census.nx -- HONEST MEASURED census of our download engine vs the S-class aria2/axel/wget bar for 2// SPEED + RESUME + ERROR-HANDLING (operator ask). Drives the general nx_capability_census engine against the 3// sovereign-banked knowledge/fetched/dlperf_*.raw corpus. Encodes today's truth (2026-07-01): we have sovereign 4// leak-free STREAMING + fail-closed INTEGRITY + repo ENUMERATE (all just proven live pulling Apertus), but the 5// live 16GB pull FAILED for lack of RESUME + RETRY/backoff + PARALLEL segments -- exactly the gaps below. 6// GREEN = measurement honest + grounded. Sovereign nx_cc->nxasm. expect_exit: 0 license_tier: ORIGINAL 7import "nx_capability_census.nx" 8import "nx_syscalls.nx" 9const K_MAGIC_2097152: i64 = 2097152 10 11func w(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 } 12func wn(v: i64) -> i64 { var m: i64=v; if m<0{w("-" as *u8);m=0-m} let t:*u8=sys_mmap(24); 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; let o:*u8=sys_mmap(24); while i<k{o[i]=t[k-1-i];i=i+1} sys_write(1,o,k); return 0 } 13 14// st: 0 total 1 have 2 exceeds 3 ahead 4 parity 5 gap 6 bothabs 7 compsum 15func row(label: *u8, term: *u8, organ: *u8, exceed: *u8, subj: *i64, ns: i64, buf: *u8, cap: i64, st: *i64) -> i64 { 16 let comp: i64 = cc_comp_attest(subj, ns, term, buf, cap) 17 let our: i64 = cc_our_grade(organ, exceed) 18 let v: i64 = cc_verdict(comp, our) 19 w(" "); w(cc_verdict_str(v)); w(" us="); w(cc_grade_str(our)); w(" them(src="); wn(comp); w(") "); w(label); w("\n") 20 st[0]=st[0]+1 21 if our>=3 { st[1]=st[1]+1 } 22 if our==4 { st[2]=st[2]+1 } 23 if v==3 { st[3]=st[3]+1 } 24 if v==2 { st[4]=st[4]+1 } 25 if v==1 { st[5]=st[5]+1 } 26 if v==0 { st[6]=st[6]+1 } 27 st[7]=st[7]+comp 28 return 0 29} 30 31func main() -> i64 { 32 w("=== NISHI DOWNLOAD ENGINE vs S-class (aria2/axel/wget: speed + resume + error-handling) -- CENSUS ===\n" as *u8) 33 w("them(src)=banked knowledge/fetched/dlperf_*.raw. us=EXCEEDS>PRESENT>ABSENT (disk-fact, never self-scored).\n\n" as *u8) 34 let cap: i64 = K_MAGIC_2097152 35 let buf: *u8 = sys_mmap(cap) 36 let st: *i64 = sys_mmap(128) as *i64 37 var z: i64=0; while z<8 { st[z]=0; z=z+1 } 38 39 let subj: *i64 = sys_mmap(8 * 20) as *i64 40 subj[0]="knowledge/fetched/dlperf_a_download_manager.raw" as *u8 as i64 41 subj[1]="knowledge/fetched/dlperf_a_comparison.raw" as *u8 as i64 42 subj[2]="knowledge/fetched/dlperf_a_accelerator.raw" as *u8 as i64 43 subj[3]="knowledge/fetched/dlperf_b_byte_serving.raw" as *u8 as i64 44 subj[4]="knowledge/fetched/dlperf_b_http_headers.raw" as *u8 as i64 45 subj[5]="knowledge/fetched/dlperf_b_http_status.raw" as *u8 as i64 46 subj[6]="knowledge/fetched/dlperf_c_backoff.raw" as *u8 as i64 47 subj[7]="knowledge/fetched/dlperf_c_retransmission.raw" as *u8 as i64 48 subj[8]="knowledge/fetched/dlperf_c_fault_tolerance.raw" as *u8 as i64 49 subj[9]="knowledge/fetched/dlperf_d_tcp_congestion.raw" as *u8 as i64 50 subj[10]="knowledge/fetched/dlperf_d_bandwidth.raw" as *u8 as i64 51 subj[11]="knowledge/fetched/dlperf_d_tcp.raw" as *u8 as i64 52 subj[12]="knowledge/fetched/dlperf_e_data_integrity.raw" as *u8 as i64 53 subj[13]="knowledge/fetched/dlperf_e_error_detection.raw" as *u8 as i64 54 subj[14]="knowledge/fetched/dlperf_f_persistent.raw" as *u8 as i64 55 subj[15]="knowledge/fetched/dlperf_f_pipelining.raw" as *u8 as i64 56 let ns: i64 = 16 57 let none: *u8 = "runtime/nx_DOES_NOT_EXIST_zzqq.nx" as *u8 58 59 w(" -- HAVE / AHEAD (sovereign, just proven pulling Apertus) --\n" as *u8) 60 row("STREAMING to disk (no full buffer; multi-GB)" as *u8, "download" as *u8, "runtime/nx_https_get_stream.nx" as *u8, "runtime/_hdl_build/nx_portability_proof_census.nx" as *u8, subj, ns, buf, cap, st) 61 row("INTEGRITY verify (SHA-256, per-shard)" as *u8, "integrity" as *u8, "runtime/_hdl_build/nx_apertus_shard_verify.nx" as *u8, none, subj, ns, buf, cap, st) 62 row("FAIL-CLOSED verify (reject tamper/truncation)" as *u8, "error" as *u8, "runtime/_hdl_build/nx_weights_pull.nx" as *u8, "runtime/_hdl_build/nx_weights_pull_gate.nx" as *u8, subj, ns, buf, cap, st) 63 row("SOVEREIGN own-TLS fetch (no curl/wget/aria2)" as *u8, "download" as *u8, "runtime/nx_https_fetch_follow.nx" as *u8, "runtime/_hdl_build/nx_portability_proof_census.nx" as *u8, subj, ns, buf, cap, st) 64 row("REPO-AWARE enumerate (per-file digest)" as *u8, "download" as *u8, "runtime/_hdl_build/nx_apertus_tree_parse.nx" as *u8, none, subj, ns, buf, cap, st) 65 row("CHUNKED-transfer decode (dynamic APIs)" as *u8, "download" as *u8, "runtime/_hdl_build/nx_http_chunked.nx" as *u8, none, subj, ns, buf, cap, st) 66 row("THROUGHPUT / seed bench" as *u8, "throughput" as *u8, "runtime/nx_torrent_bench.nx" as *u8, none, subj, ns, buf, cap, st) 67 row("BITTORRENT swarm (multi-peer parallelism)" as *u8, "parallel" as *u8, "runtime/nx_torrent_get.nx" as *u8, none, subj, ns, buf, cap, st) 68 69 w("\n -- CLOSED since the failed pull (built + proven mirroring 16GB Apertus) --\n" as *u8) 70 row("RESUME (HTTP Range; continue a broken partial)" as *u8, "range" as *u8, "runtime/nx_https_get_stream.nx" as *u8, none, subj, ns, buf, cap, st) 71 row("RETRY + self-heal on error (reconnect+resume)" as *u8, "fault" as *u8, "runtime/nx_apertus_shards_pull.nx" as *u8, none, subj, ns, buf, cap, st) 72 row("BUFFERED writes (batch to disk; 9p-stable + faster)" as *u8, "bandwidth" as *u8, "runtime/nx_https_get_stream.nx" as *u8, none, subj, ns, buf, cap, st) 73 row("PROVENANCE receipt of the verified mirror" as *u8, "integrity" as *u8, "runtime/_hdl_build/nx_apertus_receipt.nx" as *u8, none, subj, ns, buf, cap, st) 74 75 w("\n -- CLOSED ON THE NAS (concurrent fork/TLS crashed WSL; runs native on the NAS's real Linux) --\n" as *u8) 76 row("PARALLEL / concurrent multi-file download (4/4 on NAS)" as *u8, "segment" as *u8, "runtime/nx_par_pull_nas.nx" as *u8, none, subj, ns, buf, cap, st) 77 78 w("\n -- STILL-OPEN (micro-opt) --\n" as *u8) 79 row("CONNECTION REUSE / keep-alive (no reconnect)" as *u8, "persistent" as *u8, "runtime/nx_http_keepalive.nx" as *u8, none, subj, ns, buf, cap, st) 80 81 let total: i64=st[0]; let have: i64=st[1]; let permil: i64=(have*1000)/total 82 w("\n TALLY: axes=" as *u8); wn(total); w(" HAVE=" as *u8); wn(have); w(" (" as *u8); wn(permil); w("permil)" as *u8) 83 w(" EXCEEDS=" as *u8); wn(st[2]); w(" AHEAD=" as *u8); wn(st[3]); w(" PARITY=" as *u8); wn(st[4]); w(" GAP=" as *u8); wn(st[5]) 84 w("\n corpus attestations=" as *u8); wn(st[7]); w("\n" as *u8) 85 86 let g_real: i64 = cc_our_grade("runtime/nx_https_get_stream.nx" as *u8, none) 87 let g_fake: i64 = cc_our_grade(none, none) 88 var liar_ok: i64=1; if g_real!=3 { liar_ok=0 } if g_fake!=0 { liar_ok=0 } 89 var corpus_ok: i64=0; if st[7]>0 { corpus_ok=1 } 90 w(" honesty: liar-kill=" as *u8); if liar_ok==1 { w("ARMED" as *u8) } else { w("DISARMED" as *u8) } 91 w(" corpus-grounded=" as *u8); if corpus_ok==1 { w("YES" as *u8) } else { w("NO" as *u8) } w("\n" as *u8) 92 93 w("\n=== DLPERF-CENSUS verdict=" as *u8) 94 if liar_ok==1 { if corpus_ok==1 { 95 w("GREEN. Read: streaming+integrity+fail-closed sovereign-AHEAD; " as *u8); wn(st[5]); w(" GAPs = RESUME + RETRY/backoff + PARALLEL + keep-alive = the S-class build ladder.\n" as *u8) 96 sys_exit(0); return 0 97 } } 98 w("RED (unbanked corpus -> run nx_dlperf_research_fetch)\n" as *u8); sys_exit(1); return 1 99}