code wiki / (root) / nx_mcp_queue_gate_t230.nx

nx_mcp_queue_gate_t230.nx

buildroot/runtime/nx_mcp_queue_gate_t230.nx

4663 B75 linesdepth 22pulls 151 transitivereach 0 importersview sourcekind tooltopic mcp
docsdependenciesstructsconstsfunctions

about

nx_mcp_queue_gate_t230.nx -- Manages JSON-RPC request queuing, cancellation, and worker recovery in a distributed system.

dependencies 2 imports · 0 importers

nx_mcp_stdio_candidate_t230.nx nx_gate_verdict.nx nx_mcp_queue_gate_t230.nx

imports: nx_mcp_stdio_candidate_t230.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

main gv_ctr sys_mmap nxa_die sys_write sys_exit nxa_lock_take nxa_lock_addr sys_write ↻ nxa_lock_give nxa_lock_addr ↻ nxa_report_overrun sys_write ↻ nxa_dump_printable sys_write ↻ nxa_dump_sizes sys_write ↻ gv_plan_new sys_mmap ↻ gv_plan_name_eq mct_read nx_json_new sys_mmap ↻ nx_json_next nx_json_skip_ws nx_json_lit nx_ascii_is_digit mct_scan nx_json_next ↻ mct_frame mr_equal nx_ascii_is_digit ↻ qg_add mct_read ↻ gv_plan_check gv_plan_take gv_plan_name_eq ↻ gv_check gv_puts sys_write ↻

structs

none

consts

none

functions

4func qg_add(q:*NxMcpQueue,p:*NxRequestPool,rows:*u8,s:*u8,now:i64,fd:i64)->i64
called by 1: main calls 1: mct_read
9func qg_has(b:*u8,n:i64,s:*u8)->i64
called by 1: main
13func main()->i64
calls 8: gv_ctrgv_plan_newmct_readqg_addgv_plan_checkqg_has+2