code wiki / (root) / nx_request_pool.nx

nx_request_pool.nx

buildroot/runtime/nx_request_pool.nx

8902 B243 linesdepth 3pulls 3 transitivereach 18 importersview sourcekind library
docsdependenciesstructsconstsfunctions

about

Single-owner IPC pool. Admission policy supplies capacity; this layer owns response-buffer reservations, message framing and child reaping.

dependencies 1 imports · 5 importers

nx_resource_arbiter.nx nx_request_pool.nx nx_mcp_pending.nx nx_mcp_pending_http_t174.nx nx_mcp_stdio.nx nx_mcp_stdio_http_t174.nx nx_mcp_stdio_sse_t316.nx

imports: nx_resource_arbiter.nx

imported by: nx_mcp_pending.nxnx_mcp_pending_http_t174.nxnx_mcp_stdio.nxnx_mcp_stdio_http_t174.nxnx_mcp_stdio_sse_t316.nx

structs

11struct NxRequestWorker
19struct NxRequestPool

consts

5const RP_CELL: i64 = 8 // current native ABI
6const RP_FD_MASK: i64 = 4294967295
7const RP_POLLIN: i64 = 1
8const RP_EINTR: i64 = -4
9const RP_SIGKILL: i64 = 9

functions

38func rp_worker(p: *NxRequestPool, slot: i64) -> *NxRequestWorker
called by 13: mp_sweepmp_spawnmp_recover_pump_timeoutmq_readymp_sweepmp_spawn+7
42func rp_new(capacity: i64, response_bytes: i64) -> *NxRequestPool
called by 3: mainmainmain calls 3: nx_ra_newnx_ra_set_budgetnx_ra_set_max_share
65func rp_fork(p: *NxRequestPool) -> i64
called by 2: mp_spawnmp_spawn calls 3: rp_workernx_ra_requestnx_ra_release
111func rp_write(fd: i64, data: *u8, n: i64) -> i64
called by 6: mp_admitmpe_write_error_detailmq_eventmp_admitmpe_write_error_detailrp_pump_timeout
122func rp_release(p: *NxRequestPool, slot: i64) -> i64
called by 2: rp_pump_timeoutrp_reap_stopped calls 2: rp_workernx_ra_release
137func rp_pump_timeout(p: *NxRequestPool, accept_input: i64, output_fd: i64, wait_ms: i64) -> i64
called by 2: mp_recover_pump_timeoutrp_pump calls 3: rp_workerrp_writerp_release
189func rp_stop_worker(p: *NxRequestPool, slot: i64) -> i64
called by 2: rp_cancel_ownedrp_cancel_all calls 1: rp_worker
196func rp_reap_stopped(p: *NxRequestPool, slot: i64) -> i64
called by 2: rp_cancel_ownedrp_cancel_all calls 2: rp_workerrp_release
209func rp_cancel_owned(p: *NxRequestPool, slot: i64, expected_pid: i64) -> i64
called by 4: mp_cancelmp_recover_pump_timeoutmp_cancelmp_recover_pump calls 3: rp_workerrp_stop_workerrp_reap_stopped
224func rp_cancel_all(p: *NxRequestPool) -> i64
called by 3: mainmainmain calls 2: rp_stop_workerrp_reap_stopped
243func rp_pump(p:*NxRequestPool,accept_input:i64,output_fd:i64)->i64 { return rp_pump_timeout(p,accept_input,output_fd,-1) }
called by 1: mp_recover_pump calls 1: rp_pump_timeout