nx_hf_file_fetch.nx
buildroot/runtime/nx_hf_file_fetch.nx
about
nx_hf_file_fetch.nx -- the STANDARD redirect-following, resumable, self-healing single-file HF downloader (the
model-port driver's fetch stage that actually WORKS for HF LFS). nx_forge_model_fetch's Range fetch does NOT
follow redirects, but HF `resolve/main/<file>` 302-redirects to the CDN -> it fails. This reuses the PROVEN
nx_apertus_shards_pull mechanism (pull_attempt hop-loops connect+TLS+get_stream, following Location on 3xx;
pull_resumable resumes from the on-disk size + self-heals) but is FILE-DRIVEN (url/dest/size from
data/mp_fetch_{url,dest,size}.txt) so it fetches ANY single model file with no code edit and runs under
nx_sov_build_run (no argv). license_tier: ORIGINAL expect_exit: 0
dependencies 5 imports · 0 importers
imports: nx_syscalls.nxnx_csprng.nxnx_trust_store_load_from_certdata.nxnx_https_fetch_follow.nxnx_https_get_stream.nx
imported by: nobody (leaf or entry point)
call flow from main pre-order; caps 40 nodes / depth 6 declared; ↻ = already shown
structs
| none |
consts
| 13 | const K_MAGIC_4096: i64 = 4096 |
| 14 | const K_MAGIC_2048: i64 = 2048 |
| 15 | const K_MAGIC_4194304: i64 = 4194304 |
functions
| 17 | func w(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 } |
| 18 | func wn(v: i64) -> i64 { var m: i64=v; if m<0{w("-" as *u8);m=0-m} let t:*u8=sys_mmap(24); var k:i64=0; if m==0{t[0]=48 as u8;k=1} while m>0{t[k]=(48+(m%10)) as u8;m=m/10;k=k+1} var i:i64=0; let o:*u8=sys_mmap(24); while i<k{o[i]=t[k-1-i];i=i+1} sys_write(1,o,k); return 0 } |
| 20 | func hff_readfile(path: *u8, buf: *u8, cap: i64) -> i64 |
| 39 | func hff_atoi(s: *u8) -> i64 { var v: i64=0; var i: i64=0; while s[i]!=(0 as u8){ let c: i64=s[i] as i64; if c>=48{ if c<=57{ v=v*10+(c-48) } } i=i+1 } return v } called by 1: main |
| 41 | func file_size(path: *u8) -> i64 |
| 51 | func pull_attempt(url0: *u8, store: *TrustStore, dest_path: *u8, have: i64) -> i64 called by 1: pull_resumable calls 13: sys_mmapsys_openat_appendsys_openat_wrnx_url_newnx_https_url_for_fetchsys_close+7 |
| 96 | func pull_resumable(url0: *u8, store: *TrustStore, dest_path: *u8, target: i64) -> i64 |
| 117 | func main() -> i64 |