canic-core 0.93.22

Canic — a canister orchestration and management toolkit for the Internet Computer
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
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117

// Category A - Internal runtime-configured tests (ConfigTestBuilder when needed).

use crate::{
    cdk::types::Cycles,
    ops::storage::pool::PoolOps,
    storage::stable::pool::{PoolStatus, PoolStore},
    test::seams::{lock, p},
    workflow::pool::PoolWorkflow,
};

#[test]
fn pool_selection_uses_workflow_ordering() {
    let _guard = lock();

    for entry in PoolOps::data().entries {
        PoolOps::remove(&entry.pid);
    }

    let pid_a = p(20);
    let pid_b = p(21);
    let pid_c = p(22);

    PoolStore::register(
        pid_a,
        Cycles::new(1),
        PoolStatus::Ready,
        None,
        None,
        None,
        5,
    );
    PoolStore::register(
        pid_b,
        Cycles::new(1),
        PoolStatus::Ready,
        None,
        None,
        None,
        5,
    );
    PoolStore::register(
        pid_c,
        Cycles::new(1),
        PoolStatus::Ready,
        None,
        None,
        None,
        9,
    );

    let selected = PoolWorkflow::pop_oldest_ready().expect("expected a ready entry");
    assert_eq!(selected, pid_a);
    assert!(!PoolOps::contains(&pid_a));

    let next = PoolWorkflow::pop_oldest_ready().expect("expected a second ready entry");
    assert_eq!(next, pid_b);
    assert!(!PoolOps::contains(&pid_b));
    assert!(PoolOps::contains(&pid_c));
}

#[test]
fn pending_reset_selection_is_ordered_bounded_and_non_destructive() {
    let _guard = lock();

    for entry in PoolOps::data().entries {
        PoolOps::remove(&entry.pid);
    }

    let pid_a = p(23);
    let pid_b = p(24);
    let pid_c = p(25);

    PoolStore::register(
        pid_a,
        Cycles::default(),
        PoolStatus::PendingReset,
        None,
        None,
        None,
        5,
    );
    PoolStore::register(
        pid_b,
        Cycles::default(),
        PoolStatus::PendingReset,
        None,
        None,
        None,
        5,
    );
    PoolStore::register(
        pid_c,
        Cycles::default(),
        PoolStatus::PendingReset,
        None,
        None,
        None,
        9,
    );

    let first = PoolOps::pending_reset_page(None, 1);
    assert_eq!(first.pids, vec![pid_a]);

    let second = PoolOps::pending_reset_page(first.next_cursor.as_ref(), 1);
    assert_eq!(second.pids, vec![pid_b]);

    let third = PoolOps::pending_reset_page(second.next_cursor.as_ref(), 1);
    assert_eq!(third.pids, vec![pid_c]);
    assert!(third.next_cursor.is_none());

    let empty = PoolOps::pending_reset_page(None, 0);
    assert!(empty.pids.is_empty());
    assert!(empty.next_cursor.is_none());
    assert!(PoolOps::contains(&pid_a));
    assert!(PoolOps::contains(&pid_b));
    assert!(PoolOps::contains(&pid_c));
}