tycho-collator 0.3.9

A collator node.
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

use tycho_types::cell::HashBytes;
use tycho_types::models::{BlockId, ShardIdent};

use super::MasterBlocksCacheData;

#[test]
fn test_applied_range_update() {
    let mut cache = MasterBlocksCacheData::default();

    // first we collated block 3405
    let block_id = BlockId {
        shard: ShardIdent::MASTERCHAIN,
        seqno: 3405,
        root_hash: HashBytes::default(),
        file_hash: HashBytes::default(),
    };
    cache.insert_last_collated_block_id(&block_id);
    println!();
    println!("update_last_collated_block_id(3405)");
    println!(
        "last collated mc seqno: {:?}, applied_mc_queue_range: {:?}",
        cache
            .get_last_collated_block_id()
            .map(|id| id.as_short_id()),
        cache.applied_mc_queue_range
    );

    assert_eq!(cache.get_last_collated_block_id(), Some(&block_id));
    assert_eq!(cache.applied_mc_queue_range, None);

    // then we received block 3405 from bc
    cache.move_range_end(3405);
    println!();
    println!("move_range_end(3405)");
    println!(
        "last collated mc seqno: {:?}, applied_mc_queue_range: {:?}",
        cache
            .get_last_collated_block_id()
            .map(|id| id.as_short_id()),
        cache.applied_mc_queue_range
    );

    assert_eq!(cache.get_last_collated_block_id(), Some(&block_id));
    assert_eq!(cache.applied_mc_queue_range, Some((3405, 3405)));

    // then we extracted block 3405 from cache and committed
    cache.move_range_start(3405);
    println!();
    println!("move_range_start(3405)");
    println!(
        "last collated mc seqno: {:?}, applied_mc_queue_range: {:?}",
        cache
            .get_last_collated_block_id()
            .map(|id| id.as_short_id()),
        cache.applied_mc_queue_range
    );

    assert_eq!(cache.get_last_collated_block_id(), Some(&block_id));
    assert_eq!(cache.applied_mc_queue_range, None);

    // then we received block 3406 from bc
    cache.move_range_end(3406);
    println!();
    println!("move_range_end(3406)");
    println!(
        "last collated mc seqno: {:?}, applied_mc_queue_range: {:?}",
        cache
            .get_last_collated_block_id()
            .map(|id| id.as_short_id()),
        cache.applied_mc_queue_range
    );

    assert_eq!(cache.get_last_collated_block_id(), Some(&block_id));
    assert_eq!(cache.applied_mc_queue_range, Some((3406, 3406)));

    // then we received block 3407 from bc
    cache.move_range_end(3407);
    println!();
    println!("move_range_end(3407)");
    println!(
        "last collated mc seqno: {:?}, applied_mc_queue_range: {:?}",
        cache
            .get_last_collated_block_id()
            .map(|id| id.as_short_id()),
        cache.applied_mc_queue_range
    );

    assert_eq!(cache.get_last_collated_block_id(), Some(&block_id));
    assert_eq!(cache.applied_mc_queue_range, Some((3406, 3407)));

    // then we received block 3408 from bc
    cache.move_range_end(3408);
    println!();
    println!("move_range_end(3408)");
    println!(
        "last collated mc seqno: {:?}, applied_mc_queue_range: {:?}",
        cache
            .get_last_collated_block_id()
            .map(|id| id.as_short_id()),
        cache.applied_mc_queue_range
    );

    assert_eq!(cache.get_last_collated_block_id(), Some(&block_id));
    assert_eq!(cache.applied_mc_queue_range, Some((3406, 3408)));
}