ach-util 0.2.5

Atomic Channel
Documentation 
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39

use ach_util::{AtomicMemoryRing, MemoryRing, MemoryState};

#[test]
fn test() {
    assert!(AtomicMemoryRing::is_lock_free());

    let mut cycle = MemoryRing::new(0, MemoryState::Uninitialized);
    assert_eq!(cycle.cycle(), 0);
    assert!(cycle.state().is_uninitialized());

    cycle.set_cycle(1);
    assert_eq!(cycle.cycle(), 1);
    cycle.set_cycle(MemoryRing::max_cycle());
    assert_eq!(cycle.cycle(), 0);
    cycle.set_state(MemoryState::Initialized);
    assert!(cycle.state().is_initialized());

    cycle.set_cycle(MemoryRing::max_cycle() - 1);
    cycle.set_state(MemoryState::Erasing);
    let cycle_next = cycle.next();
    assert_eq!(cycle_next.cycle(), 0);
    assert!(cycle_next.state().is_uninitialized());
    assert!(cycle_next > cycle);

    assert!(
        MemoryRing::new(0, MemoryState::Uninitialized)
            < MemoryRing::new(0, MemoryState::Initializing)
    );
    assert!(
        MemoryRing::new(0, MemoryState::Initializing)
            < MemoryRing::new(0, MemoryState::Initialized)
    );
    assert!(
        MemoryRing::new(0, MemoryState::Initialized) < MemoryRing::new(0, MemoryState::Erasing)
    );
    assert!(
        MemoryRing::new(0, MemoryState::Erasing) < MemoryRing::new(1, MemoryState::Uninitialized)
    );
}