code wiki / (root) / nx_torrent_daemon.nx

nx_torrent_daemon.nx

buildroot/runtime/nx_torrent_daemon.nx

88825 B1473 linesdepth 5pulls 10 transitivereach 2 importersview sourcekind servicetopic torrent
docsdependenciesstructsconstsfunctions

about

nx_torrent_daemon.nx -- the UI enabler (X-TORRENT-UI-001): an HTTP daemon that serves the operator's torrent page and wires it to the LIVE download worker. GET /torrent -> sites/nishifamily/torrent/index.html GET /torrent/app.js -> the page's last-mile JS (renders REAL state only) GET /torrent/api/me -> {"user":"local"} (local single-operator) POST /torrent/api/login -> {"ok":true} POST /torrent/api/add {magnet} -> fork+execve the worker elf -> {"id":"1"} GET /torrent/api/status -> reads outdir/download.status -> {downloads:[...]} POST /torrent/api/<id>/<action> -> {"ok":true} (pause/resume/remove noop) Sovereign: composes nx_http_server (bind/listen/accept) + the worker elf the team already built. NO mocked numbers -- /status emits exactly what the worker wrote to disk; before any download the worker file is absent -> {downloads:[]} (honest empty). license_tier: ORIGINAL kind: last-mile-ui-bridge layer: L6 (over L4 http + L5 worker) module: nishi-core.torrent.daemon depends: nishi-core.http_server, nishi-core.syscalls

dependencies 6 imports · 2 importers

nx_http_server.nx nx_syscalls.nx nx_itoa_lib.nx nx_bencode.nx nx_torrent_access.nx nx_ioadmit_lib.nx nx_torrent_daemon.nx nx_torrent_area_gate.nx nx_torrent_stream_gate.nx

imports: nx_http_server.nxnx_syscalls.nxnx_itoa_lib.nxnx_bencode.nxnx_torrent_access.nxnx_ioadmit_lib.nx

imported by: nx_torrent_area_gate.nxnx_torrent_stream_gate.nx

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

main d_path d_puts sys_mmap nxa_die sys_write sys_exit nxa_lock_take nxa_lock_addr sys_write ↻ nxa_lock_give nxa_lock_addr ↻ nxa_report_overrun sys_write ↻ nxa_dump_printable sys_write ↻ nxa_dump_sizes sys_write ↻ sys_mkdir nx_http_server_addr_any nx_http_server_make_sockad d_streq sys_write ↻ d_strlen nx_http_server_listen sys_ignore_sigpipe sys_mmap ↻ sys_socket sys_mmap ↻ sys_setsockopt sys_bind sys_close sys_listen sys_exit ↻

structs

none

consts

25const TORRENT_MAGIC_131072: i64 = 131072
26const TORRENT_MAGIC_1024: i64 = 1024
27const TORRENT_MAGIC_8192: i64 = 8192
28const TORRENT_MAGIC_262144: i64 = 262144
29const TORRENT_MAGIC_4000: i64 = 4000
30const TORRENT_MAGIC_2000: i64 = 2000
31const TORRENT_MAGIC_1048576: i64 = 1048576
32const TORRENT_MAGIC_4096: i64 = 4096
33const TORRENT_MAGIC_4095: i64 = 4095
34const TORRENT_MAGIC_16384: i64 = 16384
35const TORRENT_MAGIC_4200: i64 = 4200
36const TORRENT_MAGIC_8097: i64 = 8097
37const TORRENT_MAGIC_1000000000: i64 = 1000000000
44const TORRENT_LOCAL_MARKER: *u8 = "/mnt/c/Users/elder/Downloads/nishi-torrents/.local_operator"
49const D_RETRY_INTERVAL_MS: i64 = 600000
67const D_ADMIT_CONF: *u8 = "/torrent_admit.conf"
68const D_ADMIT_CONF_CAP: i64 = 4096 // a few `key value` rows; rm_read reports a full cap as its length
69const D_ADMIT_KEY_MAXW: *u8 = "max_workers"
70const D_WORKER_COMM: *u8 = "nx_torrent_get.sov.elf" // matched on its first IOA_COMM_MAX bytes, as the kernel truncates comm
71const D_UNOBS_SPAWNS: i64 = 1
72const D_QUEUED_STATUS: *u8 = "state=queued-io\n" // written ONLY when no status file exists yet (a first add that was deferred)
75const D_BUD_LEFT: i64 = 0
76const D_BUD_NCPU: i64 = 1
77const D_BUD_BLK: i64 = 2
78const D_BUD_LIVE: i64 = 3
79const D_BUD_MAXW: i64 = 4
80const D_BUD_SPAWNED: i64 = 5
81const D_BUD_DEFERRED: i64 = 6
82const D_BUD_CELLS: i64 = 8
83const D_BUD_BYTES: i64 = 64 // D_BUD_CELLS x 8
126const D_STAT_SIZE_OFF: i64 = 48

functions

86func d_strlen(s: *u8) -> i64 { var i: i64=0; while s[i]!=(0 as u8){i=i+1} return i }
called by 12: d_send_strd_spawn_workerd_find_vald_discover_resultd_endsd_idx_has+6
88func d_puts(dst: *u8, off: i64, s: *u8) -> i64
called by 15: d_pathd_sendd_has_progressd_admit_logd_statusd_hls_outname+9
98func d_putn(dst: *u8, off: i64, v: i64) -> i64 { return nxi_buf(dst, off, v) }
called by 6: d_sendd_admit_logd_statusd_discover_resultd_status_oned_stream calls 1: nxi_buf
101func d_read_file(path: *u8, buf: *u8, cap: i64) -> i64
called by 11: d_serve_filed_statusd_discover_resultd_status_oned_contig_bytesd_have_npc+5 calls 3: sys_openat_rdsys_readsys_close
127func d_idx_load(idxpath: *u8, lenout: *i64) -> *u8
called by 7: d_idx_addd_idx_removed_status_alld_find_by_btihd_autoresumed_resolve_dir+1 calls 3: sys_mmapsys_fstatatsys_read_file
137func d_idx_free(b: *u8, n: i64) -> i64 { if (b as i64) != 0 { sys_free_file(b, n) } return 0 }
called by 2: d_idx_addd_autoresume calls 1: sys_free_file
140func d_path(outdir: *u8, suf: *u8, out: *u8) -> *u8
called by 14: d_admit_budgetd_spawn_workerd_spawn_discoverd_spawn_videod_spawn_hlsd_status_one+8 calls 1: d_puts
147func d_write_file(path: *u8, s: *u8, n: i64) -> i64
called by 5: maind_spawn_workerd_idx_removed_streamd_route calls 3: sys_openat_wrsys_writesys_close
156func d_send(cfd: i64, status: *u8, ctype: *u8, body: *u8, blen: i64) -> i64
called by 6: d_send_strd_serve_filed_statusd_discover_resultd_status_alld_status_two calls 5: sys_mmapd_putsd_putnsys_writesys_close
168func d_send_str(cfd: i64, status: *u8, ctype: *u8, s: *u8) -> i64
called by 3: d_serve_filed_streamd_route calls 2: d_sendd_strlen
171func d_serve_file(cfd: i64, path: *u8, ctype: *u8) -> i64
called by 1: d_route calls 4: sys_mmapd_read_filed_send_strd_send
180func d_streq(buf: *u8, off: i64, len: i64, s: *u8) -> i64
called by 2: d_routemain
190func d_starts(buf: *u8, off: i64, len: i64, s: *u8) -> i64
called by 1: d_route
203func d_extract_magnet(body: *u8, blen: i64, out: *u8, ocap: i64) -> i64
called by 1: d_route
227func d_has_progress(outdir: *u8) -> i64
called by 1: d_route calls 5: sys_mmapd_putssys_openat_rdsys_readsys_close
240func d_close_inherited() -> i64
called by 4: d_spawn_workerd_spawn_discoverd_spawn_videod_spawn_hls calls 1: sys_close
249func d_self_dir() -> *u8
called by 5: d_spawn_workerd_spawn_discoverd_spawn_videod_spawn_hlsd_stream calls 4: sys_mmapsys_openat_rdsys_readsys_close
263func d_admit_budget(owner_root: *u8, bud: *i64) -> i64
called by 1: d_spawn_admitted calls 6: sys_mmapioa_measureioa_spawn_budgetd_pathrm_confioa_count_comm_roots
289func d_admit_log(tag: *u8, bud: *i64) -> i64
called by 1: d_spawn_admitted calls 4: sys_mmapd_putsd_putnsys_write
306func d_spawn_worker(magnet: *u8, outdir: *u8, resume: i64, bud: *i64) -> i64
called by 2: d_spawn_admittedd_autoresume calls 12: d_pathsys_mmapsys_openat_rdd_write_filed_strlensys_close+6
332func d_spawn_admitted(magnet: *u8, outdir: *u8, resume: i64, owner_root: *u8, tag: *u8) -> i64
called by 1: d_route calls 4: sys_mmapd_admit_budgetd_spawn_workerd_admit_log
341func d_find_val(buf: *u8, n: i64, key: *u8) -> i64
called by 3: d_statusd_discover_resultd_status_one calls 1: d_strlen
352func d_int_at(buf: *u8, n: i64, pos: i64) -> i64
called by 3: d_statusd_discover_resultd_status_one
363func d_copy_line(buf: *u8, n: i64, pos: i64, out: *u8, ocap: i64) -> i64
called by 3: d_statusd_discover_resultd_status_one
378func d_status(cfd: i64, statpath: *u8, ctlpath: *u8) -> i64
calls 8: sys_mmapd_read_filed_putsd_sendd_int_atd_find_val+2
420func d_extract_url(body: *u8, blen: i64, out: *u8, ocap: i64) -> i64
called by 1: d_route
444func d_spawn_discover(url: *u8, dpath: *u8) -> i64
called by 1: d_route calls 8: d_pathd_self_dirsys_mmapsys_forkd_close_inheritedsys_execve+2
463func d_url_referer(url: *u8, out: *u8) -> *u8
called by 1: d_route
478func d_spawn_video(url: *u8, outpath: *u8, referer: *u8) -> i64
called by 1: d_route calls 8: d_pathd_self_dirsys_mmapsys_forkd_close_inheritedsys_execve+2
489func d_spawn_hls(url: *u8, outpath: *u8, referer: *u8) -> i64
called by 1: d_route calls 8: d_pathd_self_dirsys_mmapsys_forkd_close_inheritedsys_execve+2
500func d_is_hls(url: *u8) -> i64
called by 1: d_route
518func d_hls_outname(url: *u8, outdir: *u8, out: *u8) -> *u8
called by 1: d_route calls 1: d_puts
534func d_vidname(url: *u8, outdir: *u8, out: *u8) -> *u8
called by 1: d_route calls 1: d_puts
546func d_scan_to(buf: *u8, n: i64, from: i64, delim: i64) -> i64
called by 7: d_discover_resultd_idx_hasd_idx_removed_status_alld_find_by_btihd_autoresume+1
551func d_json_buf(dst: *u8, off: i64, src: *u8, from: i64, to: i64) -> i64
called by 2: d_discover_resultd_status_one
562func d_raw_buf(dst: *u8, off: i64, src: *u8, from: i64, to: i64) -> i64
called by 1: d_discover_result
568func d_discover_result(cfd: i64, dpath: *u8) -> i64
called by 1: d_route calls 12: sys_mmapd_read_filed_copy_lined_find_vald_int_atd_puts+6
616func d_extract_btih(mag: *u8, n: i64, out: *u8, ocap: i64) -> i64
called by 2: d_find_by_btihd_route
636func d_hexv(c: i64) -> i64
called by 2: d_extract_named_form_magnet
645func d_extract_name(mag: *u8, n: i64, out: *u8, ocap: i64) -> i64
called by 1: d_route calls 1: d_hexv
676func d_subdir(outdir: *u8, id: *u8, dir: *u8) -> *u8
called by 6: d_status_alld_find_by_btihd_autoresumed_resolve_dird_status_rootd_route calls 1: d_puts
680func d_ends(buf: *u8, off: i64, len: i64, suf: *u8) -> i64
called by 1: d_route calls 1: d_strlen
688func d_idx_has(buf: *u8, n: i64, id: *u8) -> i64
called by 4: d_idx_addd_status_alld_resolve_dird_status_root calls 2: d_strlend_scan_to
699func d_idx_add(idxpath: *u8, id: *u8) -> i64
called by 1: d_route calls 6: sys_mmapd_idx_loadd_idx_hasd_idx_freesys_writesys_close
713func d_idx_remove(idxpath: *u8, id: *u8) -> i64
called by 1: d_route calls 5: sys_mmapd_idx_loadd_strlend_scan_tod_write_file
730func d_status_one(out: *u8, o0: i64, id: *u8, dir: *u8) -> i64
called by 2: d_status_alld_status_root calls 10: d_pathsys_mmapd_read_filed_int_atd_find_vald_copy_line+4
761func d_status_all(cfd: i64, outdir: *u8, idxpath: *u8) -> i64
calls 8: sys_mmapd_idx_loadd_putsd_scan_tod_idx_hasd_subdir+2
796func d_video_extent(meta: *u8, msize: i64, out: *i64) -> i64
called by 2: d_streammain calls 4: nx_bc_dict_getsys_mmapnx_bc_intnx_bc_skip
815func d_contig_bytes(dir: *u8) -> i64
called by 2: d_streammain calls 3: d_pathsys_mmapd_read_file
833func d_form_magnet(body: *u8, blen: i64, out: *u8, ocap: i64) -> i64
called by 1: d_route calls 1: d_hexv
862func d_filesize(path: *u8) -> i64
called by 1: d_stream calls 2: sys_mmapsys_fstatat
869func d_have_npc(dir: *u8, out: *i64) -> i64
called by 2: d_streamd_autoresume calls 3: d_pathsys_mmapd_read_file
883func d_parse_range(req: *u8, rn: i64, out: *i64) -> i64
called by 2: d_streammain
900func d_stream(cfd: i64, req: *u8, rn: i64, dir: *u8) -> i64
called by 1: d_route calls 22: d_write_filed_pathsys_mmapd_read_filed_send_strd_video_extent+16
992func d_find_by_btih(outdir: *u8, idxpath: *u8, btih: *u8, btn: i64, out_id: *u8, ocap: i64) -> i64
called by 1: d_route calls 7: sys_mmapd_idx_loadd_scan_tod_subdird_pathd_read_file+1
1031func d_autoresume(outdir: *u8, idxpath: *u8, bud: *i64, rot: i64) -> i64
calls 11: sys_mmapd_idx_loadsys_clock_gettime_reald_scan_tod_idx_freed_subdir+5
1098func d_buf_find(buf: *u8, n: i64, pat: *u8) -> i64
called by 1: d_parse_area calls 1: d_strlen
1112func d_parse_area(req: *u8, n: i64) -> i64
called by 2: maind_route calls 1: d_buf_find
1118func d_marker_present(path: *u8) -> i64 { let fd: i64 = sys_openat_rd(path); if fd < 0 { return 0 } sys_close(fd); return 1 }
called by 1: d_viewer_level calls 2: sys_openat_rdsys_close
1120func d_trusted_level(req: *u8, n: i64) -> i64
called by 1: d_viewer_level
1137func d_viewer_level(req: *u8, n: i64) -> i64
called by 1: d_route calls 2: d_marker_presentd_trusted_level
1146func d_resolve_dir(id: *u8, level: i64, sfw_root: *u8, sfw_idx: *u8, nsfw_root: *u8, nsfw_idx: *u8, out_dir: *u8, out_area: *i64) -> i64
called by 2: maind_route calls 4: sys_mmapd_idx_loadd_idx_hasd_subdir
1156func d_status_root(out: *u8, o0: i64, first_p: *i64, root: *u8, idxpath: *u8) -> i64
called by 1: d_status_two calls 7: sys_mmapd_idx_loadd_scan_tod_idx_hasd_subdird_puts+1
1182func d_status_two(cfd: i64, level: i64, sfw_root: *u8, sfw_idx: *u8, nsfw_root: *u8, nsfw_idx: *u8) -> i64
called by 1: d_route calls 4: sys_mmapd_putsd_status_rootd_send
1194func d_route(cfd: i64, req: *u8, method: i64, po: i64, pl: i64, cl_: i64, bo: i64, rn: i64,
calls 38: d_viewer_leveld_streqd_serve_filed_send_strd_status_twod_starts+32
1354func main(argc: i64, argv: *i64) -> i64
calls 9: d_pathsys_mmapsys_mkdirnx_http_server_addr_anyd_streqsys_write+3