summaryrefslogtreecommitdiff
path: root/cli/metrics.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/metrics.rs')
-rw-r--r--cli/metrics.rs32
1 files changed, 18 insertions, 14 deletions
diff --git a/cli/metrics.rs b/cli/metrics.rs
index ea3f90164..43f11cd36 100644
--- a/cli/metrics.rs
+++ b/cli/metrics.rs
@@ -16,22 +16,26 @@ pub struct Metrics {
}
impl Metrics {
- fn op_dispatched(&mut self, bytes_sent_control: u64, bytes_sent_data: u64) {
+ fn op_dispatched(
+ &mut self,
+ bytes_sent_control: usize,
+ bytes_sent_data: usize,
+ ) {
self.ops_dispatched += 1;
- self.bytes_sent_control += bytes_sent_control;
- self.bytes_sent_data += bytes_sent_data;
+ self.bytes_sent_control += bytes_sent_control as u64;
+ self.bytes_sent_data += bytes_sent_data as u64;
}
- fn op_completed(&mut self, bytes_received: u64) {
+ fn op_completed(&mut self, bytes_received: usize) {
self.ops_completed += 1;
- self.bytes_received += bytes_received;
+ self.bytes_received += bytes_received as u64;
}
pub fn op_sync(
&mut self,
- bytes_sent_control: u64,
- bytes_sent_data: u64,
- bytes_received: u64,
+ bytes_sent_control: usize,
+ bytes_sent_data: usize,
+ bytes_received: usize,
) {
self.ops_dispatched_sync += 1;
self.op_dispatched(bytes_sent_control, bytes_sent_data);
@@ -41,8 +45,8 @@ impl Metrics {
pub fn op_dispatched_async(
&mut self,
- bytes_sent_control: u64,
- bytes_sent_data: u64,
+ bytes_sent_control: usize,
+ bytes_sent_data: usize,
) {
self.ops_dispatched_async += 1;
self.op_dispatched(bytes_sent_control, bytes_sent_data)
@@ -50,19 +54,19 @@ impl Metrics {
pub fn op_dispatched_async_unref(
&mut self,
- bytes_sent_control: u64,
- bytes_sent_data: u64,
+ bytes_sent_control: usize,
+ bytes_sent_data: usize,
) {
self.ops_dispatched_async_unref += 1;
self.op_dispatched(bytes_sent_control, bytes_sent_data)
}
- pub fn op_completed_async(&mut self, bytes_received: u64) {
+ pub fn op_completed_async(&mut self, bytes_received: usize) {
self.ops_completed_async += 1;
self.op_completed(bytes_received);
}
- pub fn op_completed_async_unref(&mut self, bytes_received: u64) {
+ pub fn op_completed_async_unref(&mut self, bytes_received: usize) {
self.ops_completed_async_unref += 1;
self.op_completed(bytes_received);
}