code wiki / (root) / nx_store_seed_lib.nx

nx_store_seed_lib.nx

buildroot/runtime/nx_store_seed_lib.nx

40982 B696 linesdepth 4pulls 5 transitivereach 750 importersview sourcekind librarytopic store
docsdependenciesstructsconstsfunctions

about

nx_store_seed_lib.nx -- THE canonical GENERIC store-seed codec (operator 2026-07-17: unify the ~30 bespoke per-plane seeders). Migrates ANY flat staging buffer (# and blank lines skipped) into ANY sovereign seg-store prefix as records key "q:<seq>"=row + "q:n"=count, and reconstructs a newline-joined buffer byte-identical to the flat body. Prefix is a PARAMETER (gates isolate). This is nx_frontier_store's frs_* promoted to the shared home; frontier + commontask delegate here. license_tier: ORIGINAL No hw writes (Rule 26).

dependencies 3 imports · 160 importers

nx_seg_store.nx nx_syscalls.nx nx_record_tsv.nx nx_store_seed_lib.nx nx_accept_gate.nx nx_accept_lib.nx nx_archcensus.nx nx_asset_page.nx nx_atlas_discover.nx nx_atlas_discover_gate.nx nx_atlas_gapscan.nx nx_atlas_gapscan_gate.nx nx_atlas_graphrec.nx nx_atlas_graphrec_lib.nx

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

imports: nx_seg_store.nxnx_syscalls.nxnx_record_tsv.nx

imported by: nx_accept_gate.nxnx_accept_lib.nxnx_archcensus.nxnx_asset_page.nxnx_atlas_discover.nxnx_atlas_discover_gate.nxnx_atlas_gapscan.nxnx_atlas_gapscan_gate.nxnx_atlas_graphrec.nxnx_atlas_graphrec_lib.nxnx_backlog_feeder.nxnx_battery_grade.nxnx_bench_ingest.nxnx_browser_census.nxnx_cap_harvest.nxnx_capsearch.nxnx_capture_append_lib.nxnx_carflip_deal.nxnx_chat_demo_api.nxnx_chat_demo_unicode_t59.nxnx_chat_store.nxnx_chat_unicode_store_t60.nxnx_clawf_route.nxnx_clock_sched.nxnx_clock_sched_reserved_fault_v2_ar.nxnx_clock_sched_reserved_v2_ar.nxnx_clockjob.nxnx_clockjobs.nxnx_clockjobs_gate.nxnx_commons_ledger_e2e_gate.nxnx_commons_store_probe_gate.nxnx_consolidate.nxnx_consolidate_gate.nxnx_cron_watch.nxnx_cronwatch_put.nxnx_ctxcost.nxnx_cwe_scan.nxnx_cwe_scan_gate.nxnx_dbtc_ppmi_probe2.nxnx_dbthyg.nxnx_debt.nxnx_debt_hygiene.nxnx_debt_plane_check.nxnx_debt_plane_gate.nxnx_debt_triple.nxnx_debtcluster.nxnx_debtlive.nxnx_dedup_candidates.nxnx_dedup_migrate.nxnx_dmkt_ideator.nxnx_dora.nxnx_dora_evidence_t138.nxnx_eco_scorecard.nxnx_eco_scorecard_gate.nxnx_editor_board.nxnx_eff_board_lib.nxnx_favela_census.nxnx_favela_census_gate.nxnx_feed.nxnx_fetchprobec.nxnx_flip_lib.nxnx_formatlaw.nxnx_frame_pacing_lib.nxnx_frontier_put.nxnx_frontier_store.nxnx_game_chat.nxnx_gen_orchestrator.nxnx_gen_rank.nxnx_gendiff.nxnx_gmmlu_ingest.nxnx_goalmap_gate.nxnx_goalmap_lib.nxnx_hw_envelope.nxnx_info_registry.nxnx_ingest_base.nxnx_input_scan.nxnx_ivvbeat.nxnx_ivvcensus.nxnx_jobhealth_gate.nxnx_k3_arch_census.nxnx_k3_arch_census_gate.nxnx_kind.nxnx_landed_cost.nxnx_langintel_axismap.nxnx_langintel_router.nxnx_law_warden.nxnx_libdata.nxnx_libindex_lib.nxnx_mediaflow.nxnx_model_card.nxnx_msg_sync.nxnx_netobs.nxnx_orchestrate_raci_canonical_gate_t161.nxnx_orchestrate_raci_evaluate_gate_t144.nxnx_outlink_harvest.nxnx_ownlib.nxnx_patch_guard.nxnx_plan_run.nxnx_plan_run_gate.nxnx_plane_append.nx +60 more (shown cap 100 declared)

structs

none

consts

11const STS_WCAP: i64 = 8388608 // RETIRED as the writer cap (see sts_seed); kept only for callers that still name it
12const STS_ROWOVH: i64 = 32 // per-entry seg-store header: kind + u32 klen + u32 vlen, with margin
13const STS_WSLACK: i64 = 65536 // count row + commit slack
46const STS_HASH: i64 = 35 // '#'
47const STS_NL: i64 = 10 // '\n'
48const STS_Q: i64 = 113 // 'q'
49const STS_COLON: i64 = 58 // ':'
50const STS_ZERO: i64 = 48 // '0'
51const STS_NINE: i64 = 57 // '9'
52const STS_KIND_LIVE: i64 = 1 // seg-store live-record kind (2 = tombstone)
53const STS_KEYCAP: i64 = 64
54const STS_NUMCAP: i64 = 28
55const STS_OUTCAP: i64 = 16
56const STS_BASE10: i64 = 10
57const STS_KPFX: i64 = 2 // "q:" prefix length
58const STS_EXIT_MMAP: i64 = 9
59const STS_MMAP_ERRMAX: i64 = 4096
60const STS_PROBE_WINDOW: i64 = 4096 // detect-only probe span past the declared q:n
61const STS_PROBE_MISS_RUN: i64 = 64 // consecutive misses that end the probe (sparse-tail guard)
62const STS_ERRFD: i64 = 2
81const STS_NXR_HDR: i64 = 6
82const STS_NXR_N: i64 = 78
83const STS_NXR_X: i64 = 88
84const STS_NXR_R: i64 = 82
85const STS_NXR_1: i64 = 49
154const STS_HASHMUL: i64 = 131
155const STS_ERR_STALE: i64 = 0 - 5
432const STS_FIT_START: i64 = 8388608 // 8 MiB: ~1.9x the largest plane measured 2026-08-06
433const STS_FIT_MAXTRIES: i64 = 8 // 8 MiB .. 1 GiB, then REFUSE
535const STS_LOCK_EX: i64 = 2
536const STS_LOCK_UN: i64 = 8
537const STS_LOCKMODE: i64 = 420
538const STS_LOCKPATHCAP: i64 = 256
539const STS_ERR_LOCK: i64 = 0 - 3
540const STS_ERR_CAP: i64 = 0 - 4
634const STS_ROWTAB: i64 = 9
635const STS_FINDCAP: i64 = 65536 // one decoded row; the largest plane row measured is far below this, and a longer row

functions

70func sts_werr(s: *u8) -> i64 { var n: i64 = 0; while s[n] != (0 as u8) { n = n + 1 } sys_write(STS_ERRFD, s, n); return 0 }
called by 14: clk_merge_storeclk_split_argvclk_merge_storeclk_run_edf_coreclk_split_argvclk_dispatch_reserved+8 calls 1: sys_write
71func sts_mm(n: i64) -> *u8
called by 81: cda_confscda_confncsa_appendcsa_fetchcda_postcda_list+75 calls 3: sys_mmapsts_werrsys_exit
96func sts_emit_row(src: *u8, vl: i64, out: *u8, off: i64, cap: i64) -> i64
called by 5: sid_row_eqsts_loadsts_load_honeststs_load_slowsts_find_seq calls 2: nxr_countrtv_to_tsv
112func sts_atoi(b: *u8, n: i64) -> i64
called by 36: cda_confncsa_appendcsa_fetchcda_confncsa_appendcsa_fetch+30
161func sts_pfxhash(prefix: *u8) -> i64
called by 2: sts_gen_notests_seed
172func sts_gen_note(prefix: *u8) -> i64
called by 3: sts_seedsts_loadsts_load_honest calls 2: sts_pfxhashss_max_segid
178func sts_rowkey(seq: i64, out: *u8) -> i64
called by 28: ca_append_bodycsa_appendcsa_fetchcsa_appendcsa_fetchcs_store_forward+22 calls 1: ss_catn
186func sts_seed(prefix: *u8, buf: *u8, n: i64) -> i64
called by 81: mainmainmainmainmainmain+75 calls 9: sts_pfxhashss_begin_capsts_mmsts_rowkeyss_addss_catn+3
279func sts_append_fast(prefix: *u8, row: *u8, rowlen: i64) -> i64
called by 7: mainmainmainmainsts_append_fast_lockedg_worker_fast+1 calls 10: sts_mmss_max_segidss_getsts_atoists_rowkeyss_catn+4
343func sts_load(prefix: *u8, out: *u8, cap: i64) -> i64
called by 107: mainmainmainmainbf_sweepbf_selftest+101 calls 8: sts_gen_notess_open_cachedsts_mmss_hgetsts_atoists_rowkey+2
434func sts_load_fit(prefix: *u8, out_len: *i64) -> *u8
called by 24: al_rows_openmainmaincj_dump2cj_dupescj_get+18 calls 4: sts_mmsts_loadsys_munmapsts_werr
468func sts_load_honest(prefix: *u8, out: *u8, cap: i64, flags: *i64) -> i64
called by 32: mainmainmainmaindb_load_guardedmain+26 calls 7: sts_gen_notess_open_cachedsts_mmss_hgetsts_atoists_rowkey+1
544func sts_lock(prefix: *u8) -> i64
called by 26: ca_append_oncecsa_appendcsa_appendcs_opencs_store_forwardcs_ack+20 calls 5: sts_mmss_catsys_openat_appendsts_werrsys_flock
560func sts_unlock(fd: i64) -> i64
called by 24: ca_append_oncecsa_appendcsa_appendcs_opencs_store_forwardcs_ack+18 calls 2: sys_flocksys_close
572func sts_append_row(prefix: *u8, row: *u8, rowlen: i64, cap: i64) -> i64
called by 5: mainmainol_addol_offerol_handler_add calls 5: sts_locksts_mmsts_loadsts_unlocksts_seed
592func sts_append_fast_locked(prefix: *u8, row: *u8, rowlen: i64) -> i64
called by 10: mainmainmainflc_reportfpc_plane_appendol_add+4 calls 3: sts_locksts_append_faststs_unlock
602func sts_load_slow(prefix: *u8, out: *u8, cap: i64) -> i64
called by 1: main calls 5: sts_mmss_getsts_atoists_rowkeysts_emit_row
637func sts_find_seq(prefix: *u8, id: *u8) -> i64
called by 4: mainmainmainmain calls 7: ss_open_cachedsts_mmss_hgetsts_atoists_rowkeysts_emit_row+1
679func sts_replace_fast(prefix: *u8, seq: i64, row: *u8, rowlen: i64) -> i64
called by 3: mainmainmain calls 9: sts_mmss_max_segidss_getsts_atoists_rowkeyss_begin_cap+3