nx_swarm_queue_gate.nx
buildroot/runtime/nx_swarm_queue_gate.nx
about
nx_swarm_queue_gate.nx -- gate for the intelligent queue scheduler.
T1 sq_should_admit table (PURE, the anti-oversubscribe + coordination core):
rank0/hold0/cap1/ok->admit · rank0/hold1/cap1/ok->wait(at-cap) · rank1/hold0/cap1/ok->wait
(someone ahead) · rank1/hold0/cap2/ok->admit · rank0/hold0/cap1/!ok->wait(telemetry).
T2 sq_rank fairness (PURE): higher-prio ahead->rank1 · lower-prio->rank0 · same-prio-earlier->rank1
· same-prio-later->rank0 · self excluded.
T3 sq_scan replay: crafted log with a LIVE holder (pid 1=init) + a DEAD-pid waiter (reaped) +
a HOLD tombstoned by DONE -> holders counts only the live untombstoned one; dead waiter absent.
T4 live: empty queue -> sq_wait_admit(self, huge cap) GRANTs immediately; release tombstones it.
license_tier: ORIGINAL expect_exit: 0
dependencies 2 imports · 0 importers
imports: nx_swarm_queue.nxnx_gate_verdict.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
| none |
functions
| 14 | func gq_write(path: *u8, s: *u8) -> i64 |
| 22 | func main(argc: i64, argv: *i64) -> i64 |