casper-node 2.0.3

The Casper blockchain 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
106
107
108
109

use config::{Config, ACCELERATION_PARAMETER, MAX_FAILED_ROUNDS, NUM_ROUNDS_TO_CONSIDER};

use casper_types::{TimeDiff, Timestamp};

use crate::components::consensus::{
    cl_context::ClContext,
    protocols::highway::round_success_meter::{config, round_index},
};

const TEST_ROUND_LEN: TimeDiff = TimeDiff::from_millis(1 << 13);
const TEST_MIN_ROUND_LEN: TimeDiff = TimeDiff::from_millis(1 << 8);
const TEST_MAX_ROUND_LEN: TimeDiff = TimeDiff::from_millis(1 << 19);

#[test]
fn new_length_steady() {
    let round_success_meter: super::RoundSuccessMeter<ClContext> = super::RoundSuccessMeter::new(
        TEST_ROUND_LEN,
        TEST_MIN_ROUND_LEN,
        TEST_MAX_ROUND_LEN,
        Timestamp::now(),
        Config::default(),
    );
    assert_eq!(round_success_meter.new_length(), TEST_ROUND_LEN);
}

#[test]
fn new_length_slow_down() {
    let mut round_success_meter: super::RoundSuccessMeter<ClContext> =
        super::RoundSuccessMeter::new(
            TEST_ROUND_LEN,
            TEST_MIN_ROUND_LEN,
            TEST_MAX_ROUND_LEN,
            Timestamp::now(),
            Config::default(),
        );
    // If there have been more rounds of failure than MAX_FAILED_ROUNDS, slow down
    round_success_meter.rounds = vec![false; MAX_FAILED_ROUNDS + 1].into();
    assert_eq!(round_success_meter.new_length(), TEST_ROUND_LEN * 2);
}

#[test]
fn new_length_can_not_slow_down_because_max_round_len() {
    // If the round length is the same as the maximum round length, can't go up
    let mut round_success_meter: super::RoundSuccessMeter<ClContext> =
        super::RoundSuccessMeter::new(
            TEST_MAX_ROUND_LEN,
            TEST_MIN_ROUND_LEN,
            TEST_MAX_ROUND_LEN,
            Timestamp::now(),
            Config::default(),
        );
    // If there have been more rounds of failure than MAX_FAILED_ROUNDS, slow down -- but can't
    // slow down because of ceiling
    round_success_meter.rounds = vec![false; MAX_FAILED_ROUNDS + 1].into();
    assert_eq!(round_success_meter.new_length(), TEST_MAX_ROUND_LEN);
}

#[test]
fn new_length_speed_up() {
    // If there's been enough successful rounds and it's an acceleration round, speed up
    let mut round_success_meter: super::RoundSuccessMeter<ClContext> =
        super::RoundSuccessMeter::new(
            TEST_ROUND_LEN,
            TEST_MIN_ROUND_LEN,
            TEST_MAX_ROUND_LEN,
            Timestamp::now(),
            Config::default(),
        );
    round_success_meter.rounds = vec![true; NUM_ROUNDS_TO_CONSIDER].into();
    // Increase our round index until we are at an acceleration round
    loop {
        let current_round_index = round_index(
            round_success_meter.current_round_id,
            round_success_meter.current_round_len,
        );
        if current_round_index % ACCELERATION_PARAMETER == 0 {
            break;
        };
        round_success_meter.current_round_id += TimeDiff::from_millis(1);
    }
    assert_eq!(round_success_meter.new_length(), TEST_ROUND_LEN / 2);
}

#[test]
fn new_length_can_not_speed_up_because_min_round_len() {
    // If there's been enough successful rounds and it's an acceleration round, but we are
    // already at the smallest round length possible, stay at the current round length
    let mut round_success_meter: super::RoundSuccessMeter<ClContext> =
        super::RoundSuccessMeter::new(
            TEST_MIN_ROUND_LEN,
            TEST_MIN_ROUND_LEN,
            TEST_MAX_ROUND_LEN,
            Timestamp::now(),
            Config::default(),
        );
    round_success_meter.rounds = vec![true; NUM_ROUNDS_TO_CONSIDER].into();
    // Increase our round index until we are at an acceleration round
    loop {
        let current_round_index = round_index(
            round_success_meter.current_round_id,
            round_success_meter.current_round_len,
        );
        if current_round_index % ACCELERATION_PARAMETER == 0 {
            break;
        };
        round_success_meter.current_round_id += TimeDiff::from_millis(1);
    }
    assert_eq!(round_success_meter.new_length(), TEST_MIN_ROUND_LEN);
}