summaryrefslogtreecommitdiff
path: root/cli/ops.rs
diff options
context:
space:
mode:
Diffstat (limited to 'cli/ops.rs')
-rw-r--r--cli/ops.rs17
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)
};