diff options
Diffstat (limited to 'cli/ops.rs')
-rw-r--r-- | cli/ops.rs | 17 |
1 files changed, 7 insertions, 10 deletions
diff --git a/cli/ops.rs b/cli/ops.rs index 98528f979..d75e7bd20 100644 --- a/cli/ops.rs +++ b/cli/ops.rs @@ -27,14 +27,7 @@ use crate::tokio_write; use crate::version; use crate::worker::Worker; use atty; -use deno::Buf; -use deno::CoreOp; -use deno::ErrBox; -use deno::Loader; -use deno::ModuleSpecifier; -use deno::Op; -use deno::OpResult; -use deno::PinnedBuf; +use deno::*; use flatbuffers::FlatBufferBuilder; use futures; use futures::Async; @@ -82,16 +75,20 @@ fn empty_buf() -> Buf { Box::new([]) } +const FLATBUFFER_OP_ID: OpId = 44; + pub fn dispatch_all( state: &ThreadSafeState, + op_id: OpId, control: &[u8], zero_copy: Option<PinnedBuf>, op_selector: OpSelector, ) -> CoreOp { let bytes_sent_control = control.len(); let bytes_sent_zero_copy = zero_copy.as_ref().map(|b| b.len()).unwrap_or(0); - let op = if let Some(min_record) = parse_min_record(control) { - dispatch_minimal(state, min_record, zero_copy) + let op = if op_id != FLATBUFFER_OP_ID { + let min_record = parse_min_record(control).unwrap(); + dispatch_minimal(state, op_id, min_record, zero_copy) } else { dispatch_all_legacy(state, control, zero_copy, op_selector) }; |