itsscb/tracing
1
0
Fork 0
mirror of https://github.com/tokio-rs/tracing.git synced 2025-09-28 13:31:52 +00:00
Code Issues Packages Projects Releases Wiki Activity

tracing-subscriber: count numbers of enters in Timings (#2944)

Browse Source
This commit is contained in:
David Mládek 2025-06-03 15:33:35 +02:00 committed by Hayden Stainsby
parent c01d4fd9de
commit 6e70c571d3
1 changed files with 16 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

22
tracing-subscriber/src/fmt/fmt_layer.rs
View File

@ -890,9 +890,12 @@ where
let span = ctx.span(id).expect("Span not found, this is a bug");
let mut extensions = span.extensions_mut();
if let Some(timings) = extensions.get_mut::<Timings>() {
let now = Instant::now();
timings.idle += (now - timings.last).as_nanos() as u64;
timings.last = now;
if timings.entered_count == 0 {
let now = Instant::now();
timings.idle += (now - timings.last).as_nanos() as u64;
timings.last = now;
}
timings.entered_count += 1;
}
if self.fmt_span.trace_enter() {
@ -910,9 +913,12 @@ where
let span = ctx.span(id).expect("Span not found, this is a bug");
let mut extensions = span.extensions_mut();
if let Some(timings) = extensions.get_mut::<Timings>() {
let now = Instant::now();
timings.busy += (now - timings.last).as_nanos() as u64;
timings.last = now;
timings.entered_count -= 1;
if timings.entered_count == 0 {
let now = Instant::now();
timings.busy += (now - timings.last).as_nanos() as u64;
timings.last = now;
}
}
if self.fmt_span.trace_exit() {
@ -934,7 +940,9 @@ where
busy,
mut idle,
last,
entered_count,
} = *timing;
debug_assert_eq!(entered_count, 0);
idle += (Instant::now() - last).as_nanos() as u64;
let t_idle = field::display(TimingDisplay(idle));
@ -1224,6 +1232,7 @@ struct Timings {
idle: u64,
busy: u64,
last: Instant,
entered_count: u64,
}
impl Timings {
@ -1232,6 +1241,7 @@ impl Timings {
idle: 0,
busy: 0,
last: Instant::now(),
entered_count: 0,
}
}
}