code wiki / _hdl_build / nx_connect_transport.nx
nx_connect_transport.nx
buildroot/runtime/_hdl_build/nx_connect_transport.nx
about
nx_connect_transport.nx -- VIDEO ROOM receive: LIVE TRANSPORT substrate (RTP/UDP-class).
Packetization + reassembly (offset-addressed -> reorder-immune by construction), loss detection,
NACK within a retransmit window, AIMD congestion control whose target rate feeds SVC layer
selection, and CONTENT-BLIND routing (transport routes encrypted payloads by cleartext header --
never inspects media). Pure integer. The audio codec (Opus-class) remains a separate substrate.
7 checks incl. negative controls. 100% sovereign. license_tier: ORIGINAL expect_exit: 0
dependencies 1 imports · 0 importers
imports: nx_syscalls.nx
imported by: nobody (leaf or entry point)
call flow from main pre-order; caps 40 nodes / depth 6 declared; ↻ = already shown
structs
| none |
consts
| 9 | const MTU: i64 = 2 // tiny MTU for the test (payload bytes per packet) |
| 10 | const RATE0: i64 = 100 |
| 11 | const CC_INC: i64 = 10 // additive increase on success |
| 12 | const CC_DN: i64 = 3 // multiplicative decrease 3/4 on loss |
| 13 | const CC_DD: i64 = 4 |
| 14 | const L0: i64 = 10 // base layer cost |
| 15 | const L2: i64 = 100 // full layer cost |
functions
| 17 | func sw(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 } |
| 18 | func sn(v: i64) -> i64 { let bb: *u8=sys_mmap(28); var m: i64=v; if m<0{m=0-m;sys_write(1,"-" as *u8,1)} 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} var i: i64=0; while i<k{bb[i]=t[k-1-i];i=i+1} sys_write(1,bb,k); return 0 } |
| 20 | func num_packets(n: i64, mtu: i64) -> i64 { return (n + mtu - 1)/mtu } |
| 21 | func frames_equal(a: *i64, b: *i64, n: i64) -> i64 { var i: i64=0; while i<n { if a[i]!=b[i] { return 0 } i=i+1 } return 1 } called by 1: main |
| 24 | func reassemble(frame: *i64, n: i64, recv: *i64, buf: *i64) -> i64 |
| 34 | func count_holes(buf: *i64, n: i64) -> i64 { var c: i64=0; var i: i64=0; while i<n { if buf[i]<0 { c=c+1 } i=i+1 } return c } called by 1: main |
| 36 | func cc_on_success(rate: i64) -> i64 { return rate + CC_INC } called by 1: main |
| 37 | func cc_on_loss(rate: i64) -> i64 { return (rate*CC_DN)/CC_DD } called by 1: main |
| 38 | func in_window(seq: i64, cur: i64, win: i64) -> i64 { if seq>(cur-win) { return 1 } return 0 } // recent enough to NACK called by 1: main |
| 40 | func fit_rate(rate: i64) -> i64 { if rate>=(L2+L0) { return L2+L0 } if rate>=L2 { return L2 } return L0 } called by 1: main |
| 42 | func tcheck(pass: i64, label: *u8, fails: *i64) -> i64 |
| 48 | func main() -> i64 |