summaryrefslogtreecommitdiff
path: root/cli/ops/dispatch_minimal.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/ops/dispatch_minimal.rs')
-rw-r--r--cli/ops/dispatch_minimal.rs11
1 files changed, 3 insertions, 8 deletions
diff --git a/cli/ops/dispatch_minimal.rs b/cli/ops/dispatch_minimal.rs
index 37ad56813..22d0a92f8 100644
--- a/cli/ops/dispatch_minimal.rs
+++ b/cli/ops/dispatch_minimal.rs
@@ -74,19 +74,15 @@ fn test_parse_min_record() {
pub fn dispatch(
d: Dispatcher,
- state: &ThreadSafeState,
+ _state: &ThreadSafeState,
control: &[u8],
zero_copy: Option<PinnedBuf>,
) -> CoreOp {
let mut record = parse_min_record(control).unwrap();
let is_sync = record.promise_id == 0;
-
// TODO(ry) Currently there aren't any sync minimal ops. This is just a sanity
// check. Remove later.
assert!(!is_sync);
-
- let state = state.clone();
-
let rid = record.arg;
let min_op = d(rid, zero_copy);
@@ -102,10 +98,9 @@ pub fn dispatch(
record.result = -1;
}
}
- let buf: Buf = record.into();
- state.metrics_op_completed(buf.len());
- Ok(buf)
+ Ok(record.into())
}));
+
if is_sync {
Op::Sync(fut.wait().unwrap())
} else {