Add batch stats (#18096)
This commit is contained in:
@ -63,6 +63,16 @@ impl ReplaySlotStats {
|
|||||||
("load_us", self.execute_timings.load_us, i64),
|
("load_us", self.execute_timings.load_us, i64),
|
||||||
("execute_us", self.execute_timings.execute_us, i64),
|
("execute_us", self.execute_timings.execute_us, i64),
|
||||||
("store_us", self.execute_timings.store_us, i64),
|
("store_us", self.execute_timings.store_us, i64),
|
||||||
|
(
|
||||||
|
"total_batches_len",
|
||||||
|
self.execute_timings.total_batches_len,
|
||||||
|
i64
|
||||||
|
),
|
||||||
|
(
|
||||||
|
"num_execute_batches",
|
||||||
|
self.execute_timings.num_execute_batches,
|
||||||
|
i64
|
||||||
|
),
|
||||||
(
|
(
|
||||||
"serialize_us",
|
"serialize_us",
|
||||||
self.execute_timings.details.serialize_us,
|
self.execute_timings.details.serialize_us,
|
||||||
|
@ -195,6 +195,8 @@ fn execute_batches(
|
|||||||
})
|
})
|
||||||
});
|
});
|
||||||
|
|
||||||
|
timings.total_batches_len += batches.len();
|
||||||
|
timings.num_execute_batches += 1;
|
||||||
for timing in new_timings {
|
for timing in new_timings {
|
||||||
timings.accumulate(&timing);
|
timings.accumulate(&timing);
|
||||||
}
|
}
|
||||||
|
@ -157,6 +157,8 @@ pub struct ExecuteTimings {
|
|||||||
pub load_us: u64,
|
pub load_us: u64,
|
||||||
pub execute_us: u64,
|
pub execute_us: u64,
|
||||||
pub store_us: u64,
|
pub store_us: u64,
|
||||||
|
pub total_batches_len: usize,
|
||||||
|
pub num_execute_batches: u64,
|
||||||
pub details: ExecuteDetailsTimings,
|
pub details: ExecuteDetailsTimings,
|
||||||
}
|
}
|
||||||
|
|
||||||
@ -166,6 +168,8 @@ impl ExecuteTimings {
|
|||||||
self.load_us += other.load_us;
|
self.load_us += other.load_us;
|
||||||
self.execute_us += other.execute_us;
|
self.execute_us += other.execute_us;
|
||||||
self.store_us += other.store_us;
|
self.store_us += other.store_us;
|
||||||
|
self.total_batches_len += other.total_batches_len;
|
||||||
|
self.num_execute_batches += other.num_execute_batches;
|
||||||
self.details.accumulate(&other.details);
|
self.details.accumulate(&other.details);
|
||||||
}
|
}
|
||||||
}
|
}
|
||||||
|
Reference in New Issue
Block a user