solana_metrics/
counter.rs

1use {
2    crate::metrics::submit_counter,
3    log::*,
4    std::{
5        env,
6        sync::atomic::{AtomicU64, AtomicUsize, Ordering},
7        time::SystemTime,
8    },
9};
10
11const DEFAULT_LOG_RATE: usize = 1000;
12// Submit a datapoint every second by default
13const DEFAULT_METRICS_RATE: u64 = 1000;
14
15pub struct Counter {
16    pub name: &'static str,
17    /// total accumulated value
18    pub counts: AtomicUsize,
19    pub times: AtomicUsize,
20    /// last accumulated value logged
21    pub lastlog: AtomicUsize,
22    pub lograte: AtomicUsize,
23    pub metricsrate: AtomicU64,
24}
25
26#[derive(Clone, Debug)]
27pub struct CounterPoint {
28    pub name: &'static str,
29    pub count: i64,
30    pub timestamp: SystemTime,
31}
32
33impl CounterPoint {
34    pub fn new(name: &'static str) -> Self {
35        CounterPoint {
36            name,
37            count: 0,
38            timestamp: std::time::UNIX_EPOCH,
39        }
40    }
41}
42
43#[macro_export]
44macro_rules! create_counter {
45    ($name:expr, $lograte:expr, $metricsrate:expr) => {
46        $crate::counter::Counter {
47            name: $name,
48            counts: std::sync::atomic::AtomicUsize::new(0),
49            times: std::sync::atomic::AtomicUsize::new(0),
50            lastlog: std::sync::atomic::AtomicUsize::new(0),
51            lograte: std::sync::atomic::AtomicUsize::new($lograte),
52            metricsrate: std::sync::atomic::AtomicU64::new($metricsrate),
53        }
54    };
55}
56
57#[macro_export]
58macro_rules! inc_counter {
59    ($name:expr, $level:expr, $count:expr) => {
60        $name.inc($level, $count)
61    };
62}
63
64#[macro_export]
65macro_rules! inc_counter_info {
66    ($name:expr, $count:expr) => {
67        if log_enabled!(log::Level::Info) {
68            $name.inc(log::Level::Info, $count)
69        }
70    };
71}
72
73#[macro_export]
74macro_rules! inc_new_counter {
75    ($name:expr, $count:expr, $level:expr, $lograte:expr, $metricsrate:expr) => {{
76        if log_enabled!($level) {
77            static INC_NEW_COUNTER: std::sync::LazyLock<$crate::counter::Counter> =
78                std::sync::LazyLock::new(|| {
79                    let mut counter = create_counter!($name, $lograte, $metricsrate);
80                    counter.init();
81                    counter
82                });
83
84            INC_NEW_COUNTER.inc($level, $count);
85        }
86    }};
87}
88
89#[macro_export]
90macro_rules! inc_new_counter_error {
91    ($name:expr, $count:expr) => {{
92        inc_new_counter!($name, $count, log::Level::Error, 0, 0);
93    }};
94    ($name:expr, $count:expr, $lograte:expr) => {{
95        inc_new_counter!($name, $count, log::Level::Error, $lograte, 0);
96    }};
97    ($name:expr, $count:expr, $lograte:expr, $metricsrate:expr) => {{
98        inc_new_counter!($name, $count, log::Level::Error, $lograte, $metricsrate);
99    }};
100}
101
102#[macro_export]
103macro_rules! inc_new_counter_warn {
104    ($name:expr, $count:expr) => {{
105        inc_new_counter!($name, $count, log::Level::Warn, 0, 0);
106    }};
107    ($name:expr, $count:expr, $lograte:expr) => {{
108        inc_new_counter!($name, $count, log::Level::Warn, $lograte, 0);
109    }};
110    ($name:expr, $count:expr, $lograte:expr, $metricsrate:expr) => {{
111        inc_new_counter!($name, $count, log::Level::Warn, $lograte, $metricsrate);
112    }};
113}
114
115#[macro_export]
116macro_rules! inc_new_counter_info {
117    ($name:expr, $count:expr) => {{
118        inc_new_counter!($name, $count, log::Level::Info, 0, 0);
119    }};
120    ($name:expr, $count:expr, $lograte:expr) => {{
121        inc_new_counter!($name, $count, log::Level::Info, $lograte, 0);
122    }};
123    ($name:expr, $count:expr, $lograte:expr, $metricsrate:expr) => {{
124        inc_new_counter!($name, $count, log::Level::Info, $lograte, $metricsrate);
125    }};
126}
127
128#[macro_export]
129macro_rules! inc_new_counter_debug {
130    ($name:expr, $count:expr) => {{
131        inc_new_counter!($name, $count, log::Level::Debug, 0, 0);
132    }};
133    ($name:expr, $count:expr, $lograte:expr) => {{
134        inc_new_counter!($name, $count, log::Level::Debug, $lograte, 0);
135    }};
136    ($name:expr, $count:expr, $lograte:expr, $metricsrate:expr) => {{
137        inc_new_counter!($name, $count, log::Level::Debug, $lograte, $metricsrate);
138    }};
139}
140
141impl Counter {
142    fn default_metrics_rate() -> u64 {
143        let v = env::var("SOLANA_DEFAULT_METRICS_RATE")
144            .map(|x| x.parse().unwrap_or(0))
145            .unwrap_or(0);
146        if v == 0 {
147            DEFAULT_METRICS_RATE
148        } else {
149            v
150        }
151    }
152    fn default_log_rate() -> usize {
153        let v = env::var("SOLANA_DEFAULT_LOG_RATE")
154            .map(|x| x.parse().unwrap_or(DEFAULT_LOG_RATE))
155            .unwrap_or(DEFAULT_LOG_RATE);
156        if v == 0 {
157            DEFAULT_LOG_RATE
158        } else {
159            v
160        }
161    }
162    pub fn init(&mut self) {
163        #![allow(deprecated)]
164        self.lograte
165            .compare_and_swap(0, Self::default_log_rate(), Ordering::Relaxed);
166        self.metricsrate
167            .compare_and_swap(0, Self::default_metrics_rate(), Ordering::Relaxed);
168    }
169    pub fn inc(&self, level: log::Level, events: usize) {
170        let now = solana_time_utils::timestamp();
171        let counts = self.counts.fetch_add(events, Ordering::Relaxed);
172        let times = self.times.fetch_add(1, Ordering::Relaxed);
173        let lograte = self.lograte.load(Ordering::Relaxed);
174        let metricsrate = self.metricsrate.load(Ordering::Relaxed);
175
176        if times % lograte == 0 && times > 0 && log_enabled!(level) {
177            log!(level,
178                "COUNTER:{{\"name\": \"{}\", \"counts\": {}, \"samples\": {},  \"now\": {}, \"events\": {}}}",
179                self.name,
180                counts + events,
181                times,
182                now,
183                events,
184            );
185        }
186
187        let lastlog = self.lastlog.load(Ordering::Relaxed);
188        #[allow(deprecated)]
189        let prev = self
190            .lastlog
191            .compare_and_swap(lastlog, counts, Ordering::Relaxed);
192        if prev == lastlog {
193            let bucket = now / metricsrate;
194            let counter = CounterPoint {
195                name: self.name,
196                count: counts as i64 - lastlog as i64,
197                timestamp: SystemTime::now(),
198            };
199            submit_counter(counter, level, bucket);
200        }
201    }
202}
203#[cfg(test)]
204mod tests {
205    use {
206        crate::counter::{Counter, DEFAULT_LOG_RATE, DEFAULT_METRICS_RATE},
207        log::{Level, *},
208        serial_test::serial,
209        std::{
210            env,
211            sync::{atomic::Ordering, RwLock},
212        },
213    };
214
215    fn get_env_lock() -> &'static RwLock<()> {
216        static ENV_LOCK: RwLock<()> = RwLock::new(());
217        &ENV_LOCK
218    }
219
220    /// Try to initialize the logger with a filter level of INFO.
221    ///
222    /// Incrementing a counter only happens if the logger is configured for the
223    /// given log level, so the tests need an INFO logger to pass.
224    fn try_init_logger_at_level_info() -> Result<(), log::SetLoggerError> {
225        // Use ::new() to configure the logger manually, instead of using the
226        // default of reading the RUST_LOG environment variable. Set is_test to
227        // print to stdout captured by the test runner, instead of polluting the
228        // test runner output.
229        let module_limit = None;
230        env_logger::Builder::new()
231            .filter(module_limit, log::LevelFilter::Info)
232            .is_test(true)
233            .try_init()
234    }
235
236    #[test]
237    #[serial]
238    fn test_counter() {
239        try_init_logger_at_level_info().ok();
240        let _readlock = get_env_lock().read();
241        let mut counter = create_counter!("test", 1000, 1);
242        counter.init();
243        counter.inc(Level::Info, 1);
244        assert_eq!(counter.counts.load(Ordering::Relaxed), 1);
245        assert_eq!(counter.times.load(Ordering::Relaxed), 1);
246        assert_eq!(counter.lograte.load(Ordering::Relaxed), 1000);
247        assert_eq!(counter.lastlog.load(Ordering::Relaxed), 0);
248        assert_eq!(counter.name, "test");
249        for _ in 0..199 {
250            counter.inc(Level::Info, 2);
251        }
252        assert_eq!(counter.lastlog.load(Ordering::Relaxed), 397);
253        counter.inc(Level::Info, 2);
254        assert_eq!(counter.lastlog.load(Ordering::Relaxed), 399);
255    }
256
257    #[test]
258    #[serial]
259    fn test_metricsrate() {
260        try_init_logger_at_level_info().ok();
261        let _readlock = get_env_lock().read();
262        env::remove_var("SOLANA_DEFAULT_METRICS_RATE");
263        let mut counter = create_counter!("test", 1000, 0);
264        counter.init();
265        assert_eq!(
266            counter.metricsrate.load(Ordering::Relaxed),
267            DEFAULT_METRICS_RATE
268        );
269    }
270
271    #[test]
272    #[serial]
273    fn test_metricsrate_env() {
274        try_init_logger_at_level_info().ok();
275        let _writelock = get_env_lock().write();
276        env::set_var("SOLANA_DEFAULT_METRICS_RATE", "50");
277        let mut counter = create_counter!("test", 1000, 0);
278        counter.init();
279        assert_eq!(counter.metricsrate.load(Ordering::Relaxed), 50);
280    }
281
282    #[test]
283    #[serial]
284    fn test_inc_new_counter() {
285        let _readlock = get_env_lock().read();
286        //make sure that macros are syntactically correct
287        //the variable is internal to the macro scope so there is no way to introspect it
288        inc_new_counter_info!("1", 1);
289        inc_new_counter_info!("2", 1, 3);
290        inc_new_counter_info!("3", 1, 2, 1);
291    }
292
293    #[test]
294    #[serial]
295    fn test_lograte() {
296        try_init_logger_at_level_info().ok();
297        let _readlock = get_env_lock().read();
298        assert_eq!(
299            Counter::default_log_rate(),
300            DEFAULT_LOG_RATE,
301            "default_log_rate() is {}, expected {}, SOLANA_DEFAULT_LOG_RATE environment variable set?",
302            Counter::default_log_rate(),
303            DEFAULT_LOG_RATE,
304        );
305        let mut counter = create_counter!("test_lograte", 0, 1);
306        counter.init();
307        assert_eq!(counter.lograte.load(Ordering::Relaxed), DEFAULT_LOG_RATE);
308    }
309
310    #[test]
311    #[serial]
312    fn test_lograte_env() {
313        try_init_logger_at_level_info().ok();
314        assert_ne!(DEFAULT_LOG_RATE, 0);
315        let _writelock = get_env_lock().write();
316        let mut counter = create_counter!("test_lograte_env", 0, 1);
317        env::set_var("SOLANA_DEFAULT_LOG_RATE", "50");
318        counter.init();
319        assert_eq!(counter.lograte.load(Ordering::Relaxed), 50);
320
321        let mut counter2 = create_counter!("test_lograte_env", 0, 1);
322        env::set_var("SOLANA_DEFAULT_LOG_RATE", "0");
323        counter2.init();
324        assert_eq!(counter2.lograte.load(Ordering::Relaxed), DEFAULT_LOG_RATE);
325    }
326}
solana_metrics/counter.rs

solana_metrics/
counter.rs
