code wiki / _hdl_build / nx_ha_replication_gate.nx
`nx_ha_replication_gate.nx` source

1import "nx_gate_gn.nx"
2// nx_ha_replication_gate.nx -- hermetic gate for CAP-HA-REPLICATION. Proves append advances position, ship catches
3// the replica up byte-exact, lag tracks the gap, incremental ship works, and a diverged replica is detected.
4// Sovereign: nx_syscalls + nx_ha_replication. expect_exit: 0
5import "nx_syscalls.nx"
6import "nx_ha_replication.nx"
7
8func gp(s: *u8) -> i64 { var n: i64=0; while s[n]!=(0 as u8){n=n+1} sys_write(1,s,n); return 0 }
9func g_trunc(path: *u8) -> i64 { let fd: i64=sys_openat_wr(path, 0x1a4); if fd>=0 { sys_close(fd) } return 0 }
10
11func main(argc: i64, argv: *i64) -> i64 {
12    gp("=== nx_ha_replication_gate (log-shipping replication -- kill the DATA SPOF) ===\n" as *u8)
13    let P: *u8 = "/tmp/rep_primary.log" as *u8
14    let S: *u8 = "/tmp/rep_standby.log" as *u8
15    g_trunc(P); g_trunc(S)
16    var pass: i64 = 0; var fail: i64 = 0
17
18    rep_append(P, "rec1\n" as *u8, 5)
19    let p2: i64 = rep_append(P, "rec2\n" as *u8, 5)
20
21    // T1 lag = full primary (standby empty)
22    if rep_lag(P, S) == 10 { if p2 == 10 { pass=pass+1; gp("  T1 append advances pos; lag=10 (standby empty) PASS\n" as *u8) } else { fail=fail+1; gp("  T1 FAIL pos\n" as *u8) } } else { fail=fail+1; gp("  T1 FAIL lag=" as *u8); gn(rep_lag(P,S)); gp("\n" as *u8) }
23
24    // T2 ship from 0 -> caught up byte-exact
25    let sh: i64 = rep_ship(P, S, 0)
26    if sh == 10 { if rep_lag(P, S) == 0 { if rep_in_sync(P, S) == 1 { pass=pass+1; gp("  T2 ship 10 -> lag 0, byte-exact in-sync PASS\n" as *u8) } else { fail=fail+1; gp("  T2 FAIL not in sync\n" as *u8) } } else { fail=fail+1; gp("  T2 FAIL lag\n" as *u8) } } else { fail=fail+1; gp("  T2 FAIL shipped=" as *u8); gn(sh); gp("\n" as *u8) }
27
28    // T3 incremental: append rec3, ship only the delta
29    rep_append(P, "rec3\n" as *u8, 5)
30    if rep_lag(P, S) == 5 { let sh2: i64 = rep_ship(P, S, 10); if sh2 == 5 { if rep_lag(P, S) == 0 { if rep_in_sync(P, S) == 1 { pass=pass+1; gp("  T3 incremental ship (delta 5) -> in-sync PASS\n" as *u8) } else { fail=fail+1; gp("  T3 FAIL sync\n" as *u8) } } else { fail=fail+1; gp("  T3 FAIL lag\n" as *u8) } } else { fail=fail+1; gp("  T3 FAIL delta=" as *u8); gn(sh2); gp("\n" as *u8) } } else { fail=fail+1; gp("  T3 FAIL pre-lag\n" as *u8) }
31
32    // T4 (NEG) a diverged replica (standby ahead / tampered) is detected
33    let jfd: i64 = sys_openat_append(S, 0x1a4); if jfd >= 0 { sys_write(jfd, "JUNK" as *u8, 4); sys_close(jfd) }
34    if rep_in_sync(P, S) == 0 { pass=pass+1; gp("  T4 diverged replica -> NOT in-sync (detected) PASS\n" as *u8) } else { fail=fail+1; gp("  T4 FAIL undetected\n" as *u8) }
35
36    gp("RESULT pass=" as *u8); gn(pass); gp(" fail=" as *u8); gn(fail)
37    if fail == 0 { gp(" verdict=GREEN\n" as *u8); sys_exit(0); return 0 }
38    gp(" verdict=RED\n" as *u8); sys_exit(1); return 1
39}
nx_ha_replication_gate.nx source

`nx_ha_replication_gate.nx` source
