Skip to content

Commit

Permalink
summarize: Make incr-cache-loading and query-blocking contribute to s…
Browse files Browse the repository at this point in the history
…elf-time of query.
  • Loading branch information
michaelwoerister committed Jan 13, 2020
1 parent e6f55c7 commit 232db90
Showing 1 changed file with 6 additions and 3 deletions.
9 changes: 6 additions & 3 deletions summarize/src/analysis.rs
Original file line number Diff line number Diff line change
Expand Up @@ -175,6 +175,7 @@ pub fn perform_analysis(data: ProfilingData) -> Results {
data.self_time -= current_event_duration;
}
INCREMENTAL_LOAD_RESULT_EVENT_KIND => {
data.self_time -= current_event_duration;
data.incremental_load_time -= current_event_duration;
}
_ => {
Expand All @@ -200,12 +201,14 @@ pub fn perform_analysis(data: ProfilingData) -> Results {

QUERY_BLOCKED_EVENT_KIND => {
record_event_data(&current_event.label, &|data| {
data.self_time += current_event_duration;
data.blocked_time += current_event_duration;
});
}

INCREMENTAL_LOAD_RESULT_EVENT_KIND => {
record_event_data(&current_event.label, &|data| {
data.self_time += current_event_duration;
data.incremental_load_time += current_event_duration;
});
}
Expand Down Expand Up @@ -509,13 +512,13 @@ mod tests {

assert_eq!(results.total_time, Duration::from_nanos(230));

assert_eq!(results.query_data_by_label("q1").self_time, Duration::from_nanos(100));
assert_eq!(results.query_data_by_label("q1").self_time, Duration::from_nanos(230));
assert_eq!(results.query_data_by_label("q1").blocked_time, Duration::from_nanos(130));
}

#[test]
fn query_incr_loading_time() {
// T1: <---------------q1--------------->
// T1: <---------------q1 (loading)----->
// T2: <------q1 (loading)------>
// T3: <----q1 (loading)---->
// 0 30 40 100
Expand All @@ -530,7 +533,7 @@ mod tests {

assert_eq!(results.total_time, Duration::from_nanos(230));

assert_eq!(results.query_data_by_label("q1").self_time, Duration::from_nanos(0));
assert_eq!(results.query_data_by_label("q1").self_time, Duration::from_nanos(230));
assert_eq!(results.query_data_by_label("q1").incremental_load_time, Duration::from_nanos(230));
}
}

0 comments on commit 232db90

Please sign in to comment.