nx_checkpoint.nx

buildroot/runtime/nx_checkpoint.nx

4498 B149 linesdepth 5pulls 6 transitivereach 20 importersview sourcekind library

docs dependencies structs consts functions

about

nx_checkpoint.nx -- atomic high-water-mark file for resumable jobs. Persists a single "last completed id" via .tmp + renameat. genealogy_id: chandy_lamport_1985_snapshots + spark_checkpointing lineage_id: resumable_state

dependencies 4 imports · 3 importers

imports: nx_syscalls.nxnx_tier.nxnx_str.nxnx_strconv.nx

imported by: nx_checkpoint_test.nxnx_ingest_runner.nxnx_ingest_runner_test.nx

structs

30	struct NxCheckpoint

consts

19	const NX_CHECKPOINT_FRESH: nx_int = -1
20	const NX_CHECKPOINT_WRITE_FAIL: nx_int = -2
21	const NX_CHECKPOINT_RENAME_FAIL: nx_int = -3
28	const SYS_RENAMEAT_LOCAL: nx_int = 276 // renameat2 (RV64)
38	const NX_CHECKPOINT_STRUCT_BYTES: nx_size = 48
39	const NX_CHECKPOINT_PATH_CAP: nx_size = 512

functions

41	func nx_ckpt_make_tmp(orig: u8, out: u8) -> nx_size called by 1: nx_checkpoint_open calls 2: nx_str_cpy nx_str_len
54	func nx_ckpt_parse_i64(buf: *u8, n: nx_int) -> nx_int called by 1: nx_checkpoint_open
74	func nx_checkpoint_open(path: u8) -> NxCheckpoint called by 8: main main main nx_ingest_run_new main main+2 calls 5: sys_mmap nx_str_cpy nx_ckpt_make_tmp sys_read_file nx_ckpt_parse_i64
100	func nx_checkpoint_close(cp: *NxCheckpoint) -> nx_int called by 2: main nx_ingest_run_close
105	func nx_checkpoint_get(cp: *NxCheckpoint) -> nx_int called by 8: main main main nx_ingest_run_resume_from main main+2
109	func nx_checkpoint_set(cp: *NxCheckpoint, id: nx_int) -> nx_int called by 3: main nx_ingest_run_offer nx_ingest_run_close calls 4: sys_mmap nx_strconv_format_i64 sys_write sys_close
144	func nx_checkpoint_n_writes(cp: *NxCheckpoint) -> nx_int { return cp.n_writes } called by 1: main
145	func nx_checkpoint_n_write_fail(cp: *NxCheckpoint) -> nx_int { return cp.n_write_fail } called by 1: main
146	func nx_checkpoint_is_fresh(cp: *NxCheckpoint) -> nx_int called by 1: main