Function ghost_edge_convergence

nodedb-cluster/tests/distributed_validation.rs:84–106

()

/// Gate 3: Ghost edge count converges to zero after rebalance.
#[test]
fn ghost_edge_convergence() {
    let mut ghost_table = GhostTable::new();

    // Create 10 ghost stubs with refcount=1 (simulating migration).
    for i in 0..10 {
        ghost_table.insert(GhostStub::new(format!("edge_{i}"), i + 10, 1));
    }
    assert_eq!(ghost_table.len(), 10);

    // Path A: refcount-based fast purge.
    // Decrement refcount to 0 → stub is immediately purged.
    for i in 0..5 {
        let purged = ghost_table.decrement_ref(&format!("edge_{i}"));
        assert!(purged, "edge_{i} should be purged on decrement");
    }
    assert_eq!(ghost_table.len(), 5, "5 stubs remain after fast purge");

    // Path B: sweep-based purge for remaining stubs.
    // Sweep calls verify_fn for each remaining stub.
    let report = ghost_table.sweep(|_node_id, _target_shard| SweepVerdict::Purge);
    assert_eq!(report.purged, 5, "sweep should purge remaining 5");
    assert_eq!(ghost_table.len(), 0, "ghost count should converge to zero");
}