code wiki / (root) / nx_remote_worker_test.nx

nx_remote_worker_test.nx

buildroot/runtime/nx_remote_worker_test.nx

1963 B57 linesdepth 6pulls 14 transitivereach 0 importersview sourcekind gate/proof
docsdependenciesstructsconstsfunctions

about

nx_remote_worker_test.nx -- prove distributed-MIMD dispatch via nx_remote_worker. Orchestrator dispatches 50 tasks of the form `f(id, arg) = arg*arg + id` to a worker thread; verifies all results.

dependencies 5 imports · 0 importers

nx_kernel_v2.nx nx_log.nx nx_atom.nx nx_net_chan.nx nx_remote_worker.nx nx_remote_worker_test.nx

imports: nx_kernel_v2.nxnx_log.nxnx_atom.nxnx_net_chan.nxnx_remote_worker.nx

imported by: nobody (leaf or entry point)

call flow from main pre-order; caps 40 nodes / depth 6 declared; ↻ = already shown

main nx_remote_worker_start sys_mmap nx_thread_spawn_fn sys_mmap ↻ nx_atom_load_i64 nx_thread_yield nx_atom_load_i64 ↻ nx_remote_orchestrator_con nx_sock_socket sys_mmap ↻ nx_sock_sin_init nx_sock_htons nx_sock_connect sys_close nx_net_chan_from_fd sys_mmap ↻ nx_remote_dispatch nx_net_chan_send sys_mmap ↻ _nx_net_pack_be64 nx_net_chan_recv sys_mmap ↻ _nx_net_unpack_be64 nx_remote_shutdown nx_net_chan_send ↻ nx_net_chan_close nx_sock_shutdown sys_close ↻

structs

none

consts

12const NX_PORT: i64 = 38921
13const N_TASKS: i64 = 50

functions

15func task_handler(id: i64, arg: i64) -> i64
19func main() -> nx_exit
calls 5: nx_remote_worker_startnx_atom_load_i64nx_remote_orchestrator_connectnx_remote_dispatchnx_remote_shutdown