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

use tycho_consensus::prelude::InitPeers;

use crate::mempool::StateUpdateContext;

pub struct VSetAdapter;

// TODO keep track of last applied v_set hash and round

impl VSetAdapter {
    pub fn init_peers(new_cx: &StateUpdateContext) -> anyhow::Result<InitPeers> {
        let peers = InitPeers {
            prev_start_round: new_cx.consensus_info.prev_vset_switch_round,
            prev_v_set: new_cx.prev_v_set(),
            prev_v_subset: new_cx.prev_v_subset()?,
            curr_start_round: new_cx.consensus_info.vset_switch_round,
            curr_v_set: new_cx.curr_v_set(),
            curr_v_subset: new_cx.curr_v_subset()?,
            next_v_set: new_cx.next_v_set(),
        };

        anyhow::ensure!(
            peers.prev_v_set.is_empty() == peers.prev_v_subset.is_empty(),
            "Prev validator subset is empty after shuffle, vset len={}, start_round={}",
            peers.prev_v_set.len(),
            peers.prev_start_round,
        );

        anyhow::ensure!(
            !peers.curr_v_set.is_empty(),
            "Curr validator set is empty, start_round={}",
            peers.curr_start_round,
        );

        anyhow::ensure!(
            !peers.curr_v_subset.is_empty(),
            "Curr validator subset is empty after shuffle, vset len={}, start_round={}",
            peers.curr_v_set.len(),
            peers.curr_start_round,
        );

        Ok(peers)
    }
}