solana-core 4.1.2

Blockchain, Rebuilt for Scale
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

#[derive(Default)]
pub(super) struct BlockIdRepairResponsesStats {
    /// Total # of received response packets
    pub total_packets: usize,

    /// Response packets that were valid and processed
    pub processed: usize,

    /// Dropped due to throttling responses
    pub dropped_packets: usize,

    /// Invalid response (failed deserialization or nonce)
    pub invalid_packets: usize,

    /// Ping challenges
    pub ping_responses: usize,
    /// Ping challenges from peers we have not recently requested metadata from.
    pub unexpected_ping_responses: usize,
    /// Pong responses dropped because the send failed.
    pub dropped_pong_responses: usize,
    /// Pong responses sent for ping challenges.
    pub sent_pong_responses: usize,

    /// Responses to ParentAndFecSetCount requests
    pub parent_fec_set_count_responses: usize,
    /// Responses to FecSetRoot requests
    pub fec_set_root_responses: usize,
}

impl BlockIdRepairResponsesStats {
    pub fn report(&mut self) {
        datapoint_info!(
            "block_id_repair_responses",
            ("total_packets", self.total_packets, i64),
            ("processed", self.processed, i64),
            ("dropped_packets", self.dropped_packets, i64),
            ("invalid_packets", self.invalid_packets, i64),
            ("ping_responses", self.ping_responses, i64),
            (
                "unexpected_ping_responses",
                self.unexpected_ping_responses,
                i64
            ),
            ("dropped_pong_responses", self.dropped_pong_responses, i64),
            ("sent_pong_responses", self.sent_pong_responses, i64),
            (
                "parent_fec_set_count_responses",
                self.parent_fec_set_count_responses,
                i64
            ),
            ("fec_set_root_responses", self.fec_set_root_responses, i64),
        );
        *self = Self::default();
    }
}

#[derive(Default)]
pub(super) struct BlockIdRepairRequestsStats {
    /// Total requests we sent
    pub total_requests: usize,

    pub parent_fec_set_count_requests: usize,
    pub fec_set_root_requests: usize,
    pub shred_for_block_id_requests: usize,
}

impl BlockIdRepairRequestsStats {
    pub fn report(&mut self) {
        datapoint_info!(
            "block_id_repair_requests",
            ("total_requests", self.total_requests, i64),
            (
                "parent_fec_set_count_requests",
                self.parent_fec_set_count_requests,
                i64
            ),
            ("fec_set_root_requests", self.fec_set_root_requests, i64),
            (
                "shred_for_block_id_requests",
                self.shred_for_block_id_requests,
                i64
            ),
        );
        *self = Self::default();
    }
}