minerva 0.2.0

Causal ordering for distributed systems
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23

use proptest::prelude::*;

use super::super::arb_ops;
use super::super::run;

proptest! {
    /// Base change commutes with causal merge on the sequence store.
    #[test]
    fn prop_restrict_commutes_with_merge(
        ops in arb_ops(), roster in prop::collection::vec(1u32..5, 0..5),
    ) {
        let (live, _) = run(&ops);
        let (a, b) = (&live[0], &live[2]);
        let merged_then_restricted = a.merge(b).restrict(roster.iter().copied());
        let restricted_then_merged = a
            .restrict(roster.iter().copied())
            .merge(&b.restrict(roster.iter().copied()));
        prop_assert_eq!(
            merged_then_restricted.store(),
            restricted_then_merged.store()
        );
    }
}