nx_actor.nx

buildroot/runtime/nx_actor.nx

12036 B341 linesdepth 2pulls 2 transitivereach 39 importersview sourcekind librarytopic actor

docs dependencies structs consts functions

about

nx_actor.nx -- cooperative green-thread driver for differentiated cells. Per CARDINAL [[feedback-parallel-companion-multimodal-dnd-real-time]]: LLM streaming + image gen + video + audio TTS + game actions all need to RUN CONCURRENT. This primitive is the cooperative scheduler -- each actor is a runnable unit with state (READY/RUNNING/WAITING) and a current step. V1 ships pure cooperative scheduling (call ac_step to drive); preemptive scheduling layers on top via [[nx_interrupt_ broker]] checkpoint-yield gates. Composes [[nx_meristem]] (cells differentiate into roles; actors wrap roles into runnable units) + [[nx_resource_arbiter]] (actors compete for cycles via the arbiter's CPU_MICROSECONDS resource) + [[nx_stream_ multiplexer]] (actor output enters the mux as chunks).

dependencies 2 imports · 34 importers

diagram shows first 10 each side; +0 more imports, +24 more importers in the complete lists below.

imports: nx_syscalls.nxnx_tier.nx

imported by: nx_actor_role_audio_grader.nxnx_actor_role_audio_grader_test.nxnx_actor_role_game_logic.nxnx_actor_role_game_logic_test.nxnx_actor_role_image_grader.nxnx_actor_role_image_grader_test.nxnx_actor_role_llm.nxnx_actor_role_llm_test.nxnx_actor_role_llm_v2.nxnx_actor_role_llm_v2_autoreg_test.nxnx_actor_role_llm_v2_real_autoreg_test.nxnx_actor_role_llm_v2_real_test.nxnx_actor_role_llm_v2_test.nxnx_actor_test.nxnx_bench_companion.nxnx_bench_companion_test.nxnx_bench_companion_timed_test.nxnx_bench_dist_emit_test.nxnx_bench_dist_persist_test.nxnx_bench_scale_dist_emit_test.nxnx_bench_scale_test.nxnx_bench_stress_autoreg_test.nxnx_bench_stress_emit_test.nxnx_bench_v1_vs_v2_test.nxnx_companion_compose_test.nxnx_dual_companion_compose_test.nxnx_dual_real_llm_compose_test.nxnx_dual_real_llm_emit_test.nxnx_quad_companion_compose_test.nxnx_quad_real_emit_test.nxnx_session.nxnx_session_real_llm_compose_test.nxnx_session_test.nxnx_triple_companion_compose_test.nx

structs

52	struct NxActor
67	struct NxActorScheduler

consts

21	const NX_AC_STATE_READY: nx_int = 0 // can run on next step
22	const NX_AC_STATE_RUNNING: nx_int = 1 // currently executing
23	const NX_AC_STATE_WAITING: nx_int = 2 // blocked on dependency
24	const NX_AC_STATE_COMPLETED: nx_int = 3 // finished normally
25	const NX_AC_STATE_FAILED: nx_int = 4 // unrecoverable error
26	const NX_AC_STATE_PAUSED: nx_int = 5 // operator-initiated pause
27	const NX_AC_STATE_N: nx_int = 6
31	const NX_AC_WAIT_NONE: nx_int = 0
32	const NX_AC_WAIT_RESOURCE: nx_int = 1 // arbiter denied
33	const NX_AC_WAIT_MESSAGE: nx_int = 2 // peer actor input
34	const NX_AC_WAIT_IO: nx_int = 3 // file / network
35	const NX_AC_WAIT_TIMER: nx_int = 4
36	const NX_AC_WAIT_OPERATOR: nx_int = 5 // human input
37	const NX_AC_WAIT_N: nx_int = 6
41	const NX_AC_V_STEPPED: nx_int = 0
42	const NX_AC_V_YIELDED: nx_int = 1
43	const NX_AC_V_BLOCKED: nx_int = 2
44	const NX_AC_V_COMPLETED: nx_int = 3
45	const NX_AC_V_FAILED: nx_int = 4
46	const NX_AC_V_INVALID: nx_int = 5
47	const NX_AC_V_NULL: nx_int = 6
48	const NX_AC_V_N: nx_int = 7
65	const NX_AC_BYTES: nx_int = 80
78	const NX_AC_S_BYTES: nx_int = 56

functions

82	func nx_ac_state_is_valid(s: nx_int) -> nx_int called by 1: main
88	func nx_ac_wait_is_valid(w: nx_int) -> nx_int called by 2: nx_ac_set_waiting main
94	func nx_ac_v_is_valid(v: nx_int) -> nx_int called by 1: main
100	func nx_ac_state_is_runnable(s: nx_int) -> nx_int called by 3: nx_ac_step nx_ac_pick_next main
106	func nx_ac_state_is_terminal(s: nx_int) -> nx_int called by 3: nx_ac_set_waiting nx_ac_pause main
114	func nx_ac_sched_new(capacity: nx_int, called by 14: main main main main main main+8 calls 1: sys_mmap
133	func _ac_at(s: NxActorScheduler, idx: nx_int) -> NxActor called by 5: nx_ac_find nx_ac_pick_next nx_ac_epoch_tick nx_ac_count_by_state nx_ac_total_runtime_us
142	func nx_ac_spawn(s: *NxActorScheduler, called by 13: main main main main main main+7
167	func nx_ac_find(s: NxActorScheduler, actor_id: nx_int) -> NxActor called by 23: nx_ac_set_waiting nx_ac_wake nx_ac_pause nx_ac_resume nx_ac_complete nx_ac_fail+17 calls 1: _ac_at
180	func nx_ac_set_waiting(s: *NxActorScheduler, called by 1: main calls 3: nx_ac_wait_is_valid nx_ac_find nx_ac_state_is_terminal
193	func nx_ac_wake(s: *NxActorScheduler, actor_id: nx_int) -> nx_int called by 1: main calls 1: nx_ac_find
203	func nx_ac_pause(s: *NxActorScheduler, actor_id: nx_int) -> nx_int called by 1: main calls 2: nx_ac_find nx_ac_state_is_terminal
212	func nx_ac_resume(s: *NxActorScheduler, actor_id: nx_int) -> nx_int called by 1: main calls 1: nx_ac_find
221	func nx_ac_complete(s: *NxActorScheduler, actor_id: nx_int) -> nx_int called by 7: nx_ag_actor_step nx_gl_actor_step nx_im_actor_step nx_lr_actor_step nx_lv_actor_step main+1 calls 1: nx_ac_find
229	func nx_ac_fail(s: *NxActorScheduler, actor_id: nx_int) -> nx_int called by 6: nx_ag_actor_step nx_im_actor_step nx_lr_actor_step nx_lv_actor_step main main calls 1: nx_ac_find
243	func nx_ac_step(s: *NxActorScheduler, called by 9: nx_ag_actor_step nx_gl_actor_step nx_im_actor_step nx_lr_actor_step nx_lv_actor_step main+3 calls 2: nx_ac_find nx_ac_state_is_runnable
277	func nx_ac_pick_next(s: NxActorScheduler) -> NxActor called by 4: main main main main calls 2: _ac_at nx_ac_state_is_runnable
299	func nx_ac_epoch_tick(s: *NxActorScheduler, now_us: nx_size) -> nx_int called by 2: main main calls 1: _ac_at
314	func nx_ac_count_by_state(s: *NxActorScheduler, state: nx_int) -> nx_int called by 2: main nx_bc_capture calls 1: _ac_at
326	func nx_ac_total_runtime_us(s: *NxActorScheduler) -> nx_size called by 3: main nx_bc_capture main calls 1: _ac_at
338	func nx_ac_actor_count(s: *NxActorScheduler) -> nx_int called by 5: main nx_bc_capture main main nx_session_actor_count