prisma-risk / tsoracle / 26373165176

95%

Build Type

push

github

Committed by web-flow

Commit Message

test(driver-paxos): convert the blocking-driver harness tests to deterministic stepping (#318)

* test(driver-paxos): convert restart_barrier_seq to the deterministic step-driver

restart_barrier_seq was the last paxos harness flake (~2/5 locally) and the one
blocking-driver case the step-driver couldn't take directly: it `.await`s
`current_high_water`, which appends a Barrier and blocks until the apply path
folds it — needing the cluster to progress while the call is parked. The async
version forced the interleaving with yield-point parking + real-time sleeps,
which is what flaked.

Convert it by interleaving the blocking read with stepping on one thread:
- take the reader's host out of the cluster (step() then skips it) and route its
  messages by hand through the shared MemNetwork;
- hold its apply "parked" (tick_only advances consensus; apply_once is withheld)
  so Advance(500) and the read's own Barrier(seq 8) decide but do not fold;
- poll the read future manually (noop waker) and assert it stays Pending while
  its barrier is decided-but-unfolded — proving the recovered ledger (reader->7)
  does not short-circuit the fresh seq 8;
- release with apply_once; drain_decided_into notifies the apply waiter, the read
  wakes, observes 8 >= 8, and returns the linearized 500.

Adds two additive helpers: StandaloneHost::tick_only() (tick without apply) and
Cluster::drain_inbox(node_id). No yield-points, no sleeps; 8/8 deterministic.

* test(driver-paxos): convert three_node fence-check to the deterministic step-driver

The last async paxos harness test. Its FollowerProxyHost.submit_advance polled
decided_idx with real-time tokio::time::sleep while persist_high_water blocked —
the same blocking-driver pattern restart_barrier_seq used.

Convert with the same hand-poll technique, simpler here because the proxy shares
the follower's OmniPaxos by Arc (no take-host-out needed, no borrow conflict with
stepping):
- Path A (stale epoch) is rejected by the fence b... (continued)

Coverage Stats

3 of 3 new or added lines in 1 file covered. (100.0%)

2 existing lines in 1 file now uncovered.

11304 of 11903 relevant lines covered (94.97%)

469712.19 hits per line