diff options
author | Ryan Dahl <ry@tinyclouds.org> | 2019-05-01 18:22:32 -0400 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-05-01 18:22:32 -0400 |
commit | c171813e894f0759abb1b80413aa2a24dbad079b (patch) | |
tree | 25ab50f1d9a37f827f8cf063c181512f3d961edb /cli/ops.rs | |
parent | 2f4fefd0f6a5c43724ee8d19b008018c28c7c323 (diff) |
core: express op as enum (#2255)
Diffstat (limited to 'cli/ops.rs')
-rw-r--r-- | cli/ops.rs | 11 |
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> { |