code wiki / (root) / nx_request_pool_candidate_t230.nx

nx_request_pool_candidate_t230.nx

buildroot/runtime/nx_request_pool_candidate_t230.nx

8902 B243 linesdepth 3pulls 3 transitivereach 4 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 · 2 importers

nx_resource_arbiter.nx nx_request_pool_candidate_t230 nx_mcp_pending_candidate_t230.nx nx_mcp_stdio_candidate_t230.nx

imports: nx_resource_arbiter.nx

imported by: nx_mcp_pending_candidate_t230.nxnx_mcp_stdio_candidate_t230.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 10: mp_sweepmp_spawnmp_recover_pump_timeoutmq_readyrp_forkrp_release+4
42func rp_new(capacity: i64, response_bytes: i64) -> *NxRequestPool
called by 1: main calls 3: nx_ra_newnx_ra_set_budgetnx_ra_set_max_share
65func rp_fork(p: *NxRequestPool) -> i64
called by 1: mp_spawn calls 3: rp_workernx_ra_requestnx_ra_release
111func rp_write(fd: i64, data: *u8, n: i64) -> i64
called by 4: mp_admitmpe_write_error_detailmq_eventrp_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 2: mp_cancelmp_recover_pump_timeout calls 3: rp_workerrp_stop_workerrp_reap_stopped
224func rp_cancel_all(p: *NxRequestPool) -> i64
called by 1: main 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) }
calls 1: rp_pump_timeout