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

// Copyright (C) Parity Technologies (UK) Ltd.
// This file is part of Polkadot.

// Polkadot is free software: you can redistribute it and/or modify
// it under the terms of the GNU General Public License as published by
// the Free Software Foundation, either version 3 of the License, or
// (at your option) any later version.

// Polkadot is distributed in the hope that it will be useful,
// but WITHOUT ANY WARRANTY; without even the implied warranty of
// MERCHANTABILITY or FITNESS FOR A PARTICULAR PURPOSE.  See the
// GNU General Public License for more details.

// You should have received a copy of the GNU General Public License
// along with Polkadot.  If not, see <http://www.gnu.org/licenses/>.

//! Runtime declaration of the parachain metrics.

use polkadot_primitives::metric_definitions::{
	PARACHAIN_CREATE_INHERENT_BITFIELDS_SIGNATURE_CHECKS,
	PARACHAIN_INHERENT_DATA_BITFIELDS_PROCESSED, PARACHAIN_INHERENT_DATA_CANDIDATES_PROCESSED,
	PARACHAIN_INHERENT_DATA_DISPUTE_SETS_PROCESSED, PARACHAIN_INHERENT_DATA_WEIGHT,
	PARACHAIN_VERIFY_DISPUTE_SIGNATURE,
};
use polkadot_runtime_metrics::{Counter, CounterVec, Histogram};

pub struct Metrics {
	/// Samples inherent data weight.
	inherent_data_weight: CounterVec,
	/// Counts how many inherent bitfields processed in `process_inherent_data`.
	bitfields_processed: Counter,
	/// Counts how many parachain candidates processed in `process_inherent_data`.
	candidates_processed: CounterVec,
	/// Counts dispute statements sets processed in `process_inherent_data`.
	dispute_sets_processed: CounterVec,
	/// Counts bitfield signature checks in `process_inherent_data`.
	bitfields_signature_checks: CounterVec,

	/// Histogram with the time spent checking a validator signature of a dispute statement
	signature_timings: Histogram,
}

impl Metrics {
	/// Sample the inherent data weight metric before filtering.
	pub fn on_before_filter(&self, value: u64) {
		self.inherent_data_weight.with_label_values(&["before-filter"]).inc_by(value);
	}

	/// Sample the inherent data weight metric after filtering.
	pub fn on_after_filter(&self, value: u64) {
		self.inherent_data_weight.with_label_values(&["after-filter"]).inc_by(value);
	}

	/// Increment the number of bitfields processed.
	pub fn on_bitfields_processed(&self, value: u64) {
		self.bitfields_processed.inc_by(value);
	}

	/// Increment the number of parachain candidates included.
	pub fn on_candidates_included(&self, value: u64) {
		self.candidates_processed.with_label_values(&["included"]).inc_by(value);
	}

	/// Increment the number of parachain candidates sanitized.
	pub fn on_candidates_sanitized(&self, value: u64) {
		self.candidates_processed.with_label_values(&["sanitized"]).inc_by(value);
	}

	/// Increment the total number of parachain candidates received in `process_inherent_data`.
	pub fn on_candidates_processed_total(&self, value: u64) {
		self.candidates_processed.with_label_values(&["total"]).inc_by(value);
	}

	/// Sample the relay chain freeze events causing runtime to not process candidates in
	/// `process_inherent_data`.
	pub fn on_relay_chain_freeze(&self) {
		self.dispute_sets_processed.with_label_values(&["frozen"]).inc();
	}

	/// Increment the number of disputes that have concluded as invalid.
	pub fn on_disputes_concluded_invalid(&self, value: u64) {
		self.dispute_sets_processed
			.with_label_values(&["concluded_invalid"])
			.inc_by(value);
	}

	/// Increment the number of disputes imported.
	pub fn on_disputes_imported(&self, value: u64) {
		self.dispute_sets_processed.with_label_values(&["imported"]).inc_by(value);
	}

	pub fn on_valid_bitfield_signature(&self) {
		self.bitfields_signature_checks.with_label_values(&["valid"]).inc_by(1);
	}

	pub fn on_invalid_bitfield_signature(&self) {
		self.bitfields_signature_checks.with_label_values(&["invalid"]).inc_by(1);
	}

	pub fn on_signature_check_complete(&self, val: u128) {
		self.signature_timings.observe(val);
	}
}

pub const METRICS: Metrics = Metrics {
	inherent_data_weight: CounterVec::new(PARACHAIN_INHERENT_DATA_WEIGHT),
	bitfields_processed: Counter::new(PARACHAIN_INHERENT_DATA_BITFIELDS_PROCESSED),
	candidates_processed: CounterVec::new(PARACHAIN_INHERENT_DATA_CANDIDATES_PROCESSED),
	dispute_sets_processed: CounterVec::new(PARACHAIN_INHERENT_DATA_DISPUTE_SETS_PROCESSED),
	bitfields_signature_checks: CounterVec::new(
		PARACHAIN_CREATE_INHERENT_BITFIELDS_SIGNATURE_CHECKS,
	),
	signature_timings: Histogram::new(PARACHAIN_VERIFY_DISPUTE_SIGNATURE),
};