code wiki / (root) / nx_mcp_pending_http_t174.nx

nx_mcp_pending_http_t174.nx

buildroot/runtime/nx_mcp_pending_http_t174.nx

19566 B393 linesdepth 7pulls 17 transitivereach 4 importersview sourcekind librarytopic mcp

docs dependencies structs consts functions

about

MCP-specific identity ownership over the generic process pool.

dependencies 5 imports · 4 importers

imports: nx_mcp_control.nxnx_request_pool.nxnx_http_response_parse.nxnx_mcp_route.nxnx_sha256.nx

imported by: nx_mcp_http_gate_t174.nxnx_mcp_https_gate_t175.nxnx_mcp_stdio_gate_t174.nxnx_mcp_stdio_http_t174.nx

structs

5	struct NxMcpPending

consts

17	const MP_SPAWN_DUP: i64 = 0 - 2
21	const MP_CODE_DEADLINE: i64 = 0 - 32012
22	const MP_CODE_WORKER: i64 = 0 - 32603
23	const MP_SIG_ALARM: i64 = 14

functions

26	func mp_admit(p: NxRequestPool, body: u8, control: *NxMcpControl, output: i64) -> i64 called by 1: main calls 2: rp_write mr_len
39	func mp_at(rows: u8, slot: i64) -> NxMcpPending called by 5: mp_sweep mp_find mp_spawn mp_cancel mp_recover_pump
42	func mp_clear(row: *NxMcpPending) -> i64 called by 4: mp_sweep mp_spawn mp_cancel mp_recover_pump
47	func mp_sweep(p: NxRequestPool, rows: u8) -> i64 called by 2: mp_find mp_recover_pump calls 3: mp_at rp_worker mp_clear
56	func mp_normalize(kind: i64, src: u8, n: i64, dst: u8) -> i64 called by 2: mp_spawn mp_cancel
65	func mp_find(p: NxRequestPool, rows: u8, kind: i64, data: *u8, n: i64) -> i64 called by 2: mp_spawn mp_cancel calls 2: mp_sweep mp_at
80	func mp_spawn(p: NxRequestPool, rows: u8, body: u8, control: NxMcpControl) -> i64 called by 2: g_run_planted ms_request calls 6: rp_fork mp_normalize mp_find rp_worker mp_at mp_clear
106	func mp_cancel(p: NxRequestPool, rows: u8, body: u8, control: NxMcpControl) -> i64 called by 1: main calls 5: mp_normalize mp_find mp_at rp_cancel_owned mp_clear
126	func mo_prefix_id(src: u8, n: i64, kind: i64, off: i64, len: i64) -> i64 called by 2: main main calls 1: nx_ascii_is_digit
194	func mpe_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n } called by 7: h174_has h174_response main ht175_has ht175_file mpe_write_error_detail+1
195	func mpe_cat(d: u8, o: i64, s: u8) -> i64 { var i: i64 = 0; var p: i64 = o; while s[i] != (0 as u8) { d[p] = s[i]; p = p + 1; i = i + 1 } return p } called by 6: h174_response ht175_path main mpe_write_error_detail mpe_http_field mpe_http_evidence
196	func mpe_catb(d: u8, o: i64, s: u8, n: i64) -> i64 { var i: i64 = 0; while i < n { d[o+i] = s[i]; i = i + 1 } return o + i } called by 1: mpe_write_error_detail
197	func mpe_catn(d: *u8, o: i64, v: i64) -> i64 called by 4: h174_response main mpe_write_error_detail mpe_http_evidence
213	func mpe_cat_esc(d: u8, o: i64, s: u8, n: i64) -> i64 called by 2: mpe_write_error_detail mpe_http_field
240	func mpe_write_error_detail(fd: i64, id_kind: i64, id_ptr: u8, id_len: i64, escape: i64, code: i64, stage: u8, cause: u8, measured: i64, next: u8, detail:*u8, detail_n:i64) -> i64 called by 3: main mpe_write_error ms_request calls 6: mpe_slen mpe_cat mpe_catb mpe_cat_esc mpe_catn rp_write
279	func mp_recover_pump(p: NxRequestPool, rows: u8, accept_input: i64, protocol_fd: i64, timeout_secs: i64) -> i64 called by 3: g_run_planted ms_drain main calls 7: rp_pump mp_sweep rp_worker rp_cancel_owned mp_at mpe_write_error+1
318	func mpe_http_header(src:u8,n:i64,p:i64,key:u8,offset:i64,length:*i64)->i64 called by 1: mpe_http_field calls 3: nx_http_resp_parse_header_line nx_http_resp_cieq mpe_slen
331	func mpe_http_field(d:u8,o0:i64,src:u8,n:i64,p:i64,name:u8,label:*u8)->i64 called by 1: mpe_http_evidence calls 3: mpe_http_header mpe_cat mpe_cat_esc
341	func mpe_http_evidence(src:u8,n:i64,p:i64,out_len:i64)->u8 called by 3: h174_response main ms_exchange calls 7: mpe_cat mpe_catn mpe_http_field sha256_digest_checked_native nx_value_parse_json mr_member+1
391	func mpe_write_error(fd:i64,id_kind:i64,id_ptr:u8,id_len:i64,escape:i64,code:i64,stage:u8,cause:u8,measured:i64,next:u8)->i64 called by 4: mp_recover_pump main ms_request main calls 1: mpe_write_error_detail