Function per_shard_gc_is_independent

nodedb/tests/array_cluster_sync.rs:164–199

()

/// Shard 0 GCs below hlc=50; shard 1 has no acks yet (no-op).
#[test]
fn per_shard_gc_is_independent() {
    let log0 = InMemoryOpLog::new();
    let log1 = InMemoryOpLog::new();

    // 3 ops in shard0, 2 ops in shard1.
    for ms in [10u64, 20, 30] {
        log0.append(&put_op("arr", (ms / 10) as i64, ms))
            .expect("shard0 append");
    }
    for ms in [100u64, 200] {
        log1.append(&put_op("arr", (ms / 10) as i64, ms))
            .expect("shard1 append");
    }

    // Shard 0 receives an ack at frontier=25; shard 1 has no acks.
    let mut acks0 = AckVector::new();
    acks0.record(rep(1), hlc(25, 1));
    let acks1 = AckVector::new(); // empty → no-op GC

    let sink0 = MockSnapshotSink::new();
    let sink1 = MockSnapshotSink::new();

    let report0 = collapse_below(&log0, &acks0, &sink0, |a, f| Ok(Some(dummy_snap(a, f))))
        .expect("shard0 gc");

    let report1 = collapse_below(&log1, &acks1, &sink1, |a, f| Ok(Some(dummy_snap(a, f))))
        .expect("shard1 gc");

    // Shard 0: ops at ms=10 and ms=20 are < 25 → dropped; ms=30 survives.
    assert_eq!(report0.ops_dropped, 2, "shard0 must drop 2 ops");
    assert_eq!(log0.len().expect("len"), 1, "shard0 retains ms=30");

    // Shard 1: no acks → no GC.
    assert_eq!(report1.ops_dropped, 0, "shard1 must drop 0 ops (no acks)");
    assert_eq!(log1.len().expect("len"), 2, "shard1 log unchanged");
}

/// Cross-shard: ops for different arrays on different shards each get
/// their own snapshot on GC, and the snapshots are independent.