gaspersic/solana
1
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

Use timing::timestamp for counters

Browse Source
This commit is contained in:
Stephen Akridge
2018-06-08 10:11:07 -07:00
committed by sakridge
parent efb23f7cf9
commit 3bb9d5eb50
1 changed files with 3 additions and 4 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/counter.rs
View File

@ -1,5 +1,6 @@
use std::sync::atomic::{AtomicUsize, Ordering}; use std::sync::atomic::{AtomicUsize, Ordering};
use std::time::{Duration, SystemTime, UNIX_EPOCH}; use std::time::Duration;
use timing;
pub struct Counter { pub struct Counter {
pub name: &'static str, pub name: &'static str,
@ -34,8 +35,6 @@ impl Counter {
let nanos = self.nanos.fetch_add(total as usize, Ordering::Relaxed); let nanos = self.nanos.fetch_add(total as usize, Ordering::Relaxed);
let times = self.times.fetch_add(1, Ordering::Relaxed); let times = self.times.fetch_add(1, Ordering::Relaxed);
if times % self.lograte == 0 && times > 0 { if times % self.lograte == 0 && times > 0 {
let now = SystemTime::now().duration_since(UNIX_EPOCH).unwrap();
let now_ms = now.as_secs() * 1_000 + now.subsec_nanos() as u64 / 1_000_000;
info!( info!(
"COUNTER:{{\"name:\":\"{}\", \"counts\": {}, \"nanos\": {}, \"samples\": {} \"rate\": {}, \"now\": {}}}", "COUNTER:{{\"name:\":\"{}\", \"counts\": {}, \"nanos\": {}, \"samples\": {} \"rate\": {}, \"now\": {}}}",
self.name, self.name,
@ -43,7 +42,7 @@ impl Counter {
nanos, nanos,
times, times,
counts as f64 * 1e9 / nanos as f64, counts as f64 * 1e9 / nanos as f64,
now_ms, timing::timestamp(),
); );
} }
} }