summaryrefslogtreecommitdiff
path: root/cli/ops.rs
diff options
context:
space:
mode:
authorRyan Dahl <ry@tinyclouds.org>2019-05-01 18:22:32 -0400
committerGitHub <noreply@github.com>2019-05-01 18:22:32 -0400
commitc171813e894f0759abb1b80413aa2a24dbad079b (patch)
tree25ab50f1d9a37f827f8cf063c181512f3d961edb /cli/ops.rs
parent2f4fefd0f6a5c43724ee8d19b008018c28c7c323 (diff)
core: express op as enum (#2255)
Diffstat (limited to 'cli/ops.rs')
-rw-r--r--cli/ops.rs11
1 files changed, 8 insertions, 3 deletions
diff --git a/cli/ops.rs b/cli/ops.rs
index 5463bac4d..c49ce517c 100644
--- a/cli/ops.rs
+++ b/cli/ops.rs
@@ -83,7 +83,7 @@ pub fn dispatch_all(
control: &[u8],
zero_copy: Option<PinnedBuf>,
op_selector: OpSelector,
-) -> (bool, Box<Op>) {
+) -> Op {
let bytes_sent_control = control.len();
let bytes_sent_zero_copy = zero_copy.as_ref().map(|b| b.len()).unwrap_or(0);
let base = msg::get_root_as_base(&control);
@@ -101,7 +101,7 @@ pub fn dispatch_all(
let state = state.clone();
state.metrics_op_dispatched(bytes_sent_control, bytes_sent_zero_copy);
- let boxed_op = Box::new(
+ let fut = Box::new(
op.or_else(move |err: DenoError| -> Result<Buf, ()> {
debug!("op err {}", err);
// No matter whether we got an Err or Ok, we want a serialized message to
@@ -143,7 +143,12 @@ pub fn dispatch_all(
msg::enum_name_any(inner_type),
base.sync()
);
- (base.sync(), boxed_op)
+
+ if base.sync() {
+ Op::Sync(fut.wait().unwrap())
+ } else {
+ Op::Async(fut)
+ }
}
pub fn op_selector_compiler(inner_type: msg::Any) -> Option<OpCreator> {