code wiki / (root) / nx_mcp_pending_candidate_t230.nx

nx_mcp_pending_candidate_t230.nx

buildroot/runtime/nx_mcp_pending_candidate_t230.nx

27923 B567 linesdepth 7pulls 17 transitivereach 3 importersview sourcekind librarytopic mcp
docsdependenciesstructsconstsfunctions

about

MCP-specific identity ownership over the generic process pool.

dependencies 5 imports · 2 importers

nx_mcp_control.nx nx_request_pool_candidate_t230.nx nx_http_response_parse.nx nx_mcp_route.nx nx_sha256.nx nx_mcp_pending_candidate_t230. nx_mcp_queue_stdio_gate_t230.nx nx_mcp_stdio_candidate_t230.nx

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

imported by: nx_mcp_queue_stdio_gate_t230.nxnx_mcp_stdio_candidate_t230.nx

structs

5struct NxMcpPending
401struct NxMcpQueued
406struct NxMcpQueue

consts

17const MP_SPAWN_DUP: i64 = 0 - 2
21const MP_CODE_DEADLINE: i64 = 0 - 32012
22const MP_CODE_WORKER: i64 = 0 - 32603
23const MP_SIG_ALARM: i64 = 14
410const MQ_CODE_CANCEL:i64=0-32800
411const MQ_CODE_CAPACITY:i64=0-32000
412const MQ_CODE_DUP:i64=0-32013
413const MQ_DECIMAL_I64_BYTES:i64=20

functions

26func mp_admit(p: *NxRequestPool, body: *u8, control: *NxMcpControl, output: i64) -> i64
calls 2: rp_writemr_len
39func mp_at(rows: *u8, slot: i64) -> *NxMcpPending
called by 5: mp_sweepmp_findmp_spawnmp_cancelmp_recover_pump_timeout
42func mp_clear(row: *NxMcpPending) -> i64
called by 4: mp_sweepmp_spawnmp_cancelmp_recover_pump_timeout
47func mp_sweep(p: *NxRequestPool, rows: *u8) -> i64
called by 2: mp_findmp_recover_pump_timeout calls 3: mp_atrp_workermp_clear
56func mp_normalize(kind: i64, src: *u8, n: i64, dst: *u8) -> i64
called by 4: mp_spawnmp_cancelmq_enqueuemq_cancel
65func mp_find(p: *NxRequestPool, rows: *u8, kind: i64, data: *u8, n: i64) -> i64
called by 3: mp_spawnmp_cancelmq_enqueue calls 2: mp_sweepmp_at
80func mp_spawn(p: *NxRequestPool, rows: *u8, body: *u8, control: *NxMcpControl) -> i64
called by 1: ms_request calls 6: rp_forkmp_normalizemp_findrp_workermp_atmp_clear
106func mp_cancel(p: *NxRequestPool, rows: *u8, body: *u8, control: *NxMcpControl) -> i64
called by 1: main calls 5: mp_normalizemp_findmp_atrp_cancel_ownedmp_clear
126func mo_prefix_id(src: *u8, n: i64, kind: *i64, off: *i64, len: *i64) -> i64
called by 1: main calls 1: nx_ascii_is_digit
194func mpe_slen(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } return n }
called by 3: mpe_write_error_detailmpe_http_headermq_event
195func 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 5: mpe_write_error_detailmpe_http_fieldmpe_http_evidencemq_eventmain
196func 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 2: mpe_write_error_detailmq_event
197func mpe_catn(d: *u8, o: i64, v: i64) -> i64
called by 3: mpe_write_error_detailmpe_http_evidencemq_event
213func mpe_cat_esc(d: *u8, o: i64, s: *u8, n: i64) -> i64
called by 2: mpe_write_error_detailmpe_http_field
240func 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 2: mpe_write_errorms_request calls 6: mpe_slenmpe_catmpe_catbmpe_cat_escmpe_catnrp_write
279func mp_recover_pump_timeout(p: *NxRequestPool, rows: *u8, accept_input: i64, protocol_fd: i64, timeout_secs: i64, wait_ms:i64) -> i64
called by 2: mp_recover_pumpmain calls 7: rp_pump_timeoutmp_sweeprp_workerrp_cancel_ownedmp_atmpe_write_error+1
318func 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_linenx_http_resp_cieqmpe_slen
331func 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_headermpe_catmpe_cat_esc
341func mpe_http_evidence(src:*u8,n:i64,p:*i64,out_len:*i64)->*u8
called by 1: ms_exchange calls 7: mpe_catmpe_catnmpe_http_fieldsha256_digest_checked_nativenx_value_parse_jsonmr_member+1
391func 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_timeoutmq_errorms_requestmain calls 1: mpe_write_error_detail
395func mp_recover_pump(p:*NxRequestPool,rows:*u8,accept_input:i64,protocol_fd:i64,timeout_secs:i64)->i64 {return mp_recover_pump_timeout(p,rows,accept_input,protocol_fd,timeout_secs,-1)}
called by 1: ms_drain calls 1: mp_recover_pump_timeout
414func mq_new(budget:i64,wait_ms:i64)->*NxMcpQueue
called by 1: main
421func mq_event(q:*NxMcpQueue,node:*NxMcpQueued,state:*u8,dispatched:i64)->i64
called by 4: mq_enqueuemq_cancelmq_expirems_dispatch_queue calls 5: mpe_slenmpe_catmpe_catbmpe_catnrp_write
446func mq_same(node:*NxMcpQueued,kind:i64,id:*u8,n:i64)->i64
called by 2: mq_enqueuemq_cancel
450func mq_error(node:*NxMcpQueued,fd:i64,code:i64,cause:*u8,measured:i64)->i64
called by 4: mq_enqueuemq_cancelmq_expirems_dispatch_queue calls 1: mpe_write_error
459func mq_free(node:*NxMcpQueued)->i64 {return sys_munmap_direct(node as *u8,node.bytes)}
called by 4: mq_enqueuemq_cancelmq_expirems_dispatch_queue
460func mq_enqueue(q:*NxMcpQueue,p:*NxRequestPool,rows:*u8,body:*u8,n:i64,control:*NxMcpControl,now:i64,fd:i64)->i64
called by 1: main calls 6: mq_eventmq_errormp_normalizemp_findmq_samemq_free
505func mq_cancel(q:*NxMcpQueue,body:*u8,control:*NxMcpControl,fd:i64)->i64
called by 1: main calls 6: mp_normalizemq_samemq_unlinkmq_errormq_eventmq_free
523func mq_expire(q:*NxMcpQueue,now:i64,fd:i64)->i64
called by 1: ms_dispatch_queue calls 4: mq_unlinkmq_errormq_eventmq_free
536func mq_wait(q:*NxMcpQueue,now:i64)->i64
called by 1: main
545func mq_ready(q:*NxMcpQueue,p:*NxRequestPool)->i64
called by 1: ms_dispatch_queue calls 1: rp_worker
558func mq_default_budget(workers:i64,request_cap:i64)->i64
called by 1: main