summaryrefslogtreecommitdiff
path: root/runtime/js/99_main.js
diff options
context:
space:
mode:
Diffstat (limited to 'runtime/js/99_main.js')
-rw-r--r--runtime/js/99_main.js20
1 files changed, 9 insertions, 11 deletions
diff --git a/runtime/js/99_main.js b/runtime/js/99_main.js
index ad2a373cd..d18527865 100644
--- a/runtime/js/99_main.js
+++ b/runtime/js/99_main.js
@@ -14,6 +14,11 @@ import {
op_ppid,
op_set_format_exception_callback,
op_snapshot_options,
+ op_worker_close,
+ op_worker_get_type,
+ op_worker_post_message,
+ op_worker_recv_message,
+ op_worker_sync_fetch,
} from "ext:core/ops";
const {
ArrayPrototypeFilter,
@@ -223,7 +228,7 @@ function workerClose() {
}
isClosing = true;
- ops.op_worker_close();
+ op_worker_close();
}
function postMessage(message, transferOrOptions = {}) {
@@ -252,15 +257,13 @@ function postMessage(message, transferOrOptions = {}) {
}
const { transfer } = options;
const data = messagePort.serializeJsMessageData(message, transfer);
- ops.op_worker_post_message(data);
+ op_worker_post_message(data);
}
let isClosing = false;
let globalDispatchEvent;
async function pollForMessages() {
- const { op_worker_recv_message } = core.ensureFastOps();
-
if (!globalDispatchEvent) {
globalDispatchEvent = FunctionPrototypeBind(
globalThis.dispatchEvent,
@@ -309,7 +312,7 @@ async function pollForMessages() {
let loadedMainWorkerScript = false;
function importScripts(...urls) {
- if (ops.op_worker_get_type() === "module") {
+ if (op_worker_get_type() === "module") {
throw new TypeError("Can't import scripts in a module worker.");
}
@@ -329,7 +332,7 @@ function importScripts(...urls) {
// imported scripts, so we use `loadedMainWorkerScript` to distinguish them.
// TODO(andreubotella) Refactor worker creation so the main script isn't
// loaded with `importScripts()`.
- const scripts = ops.op_worker_sync_fetch(
+ const scripts = op_worker_sync_fetch(
parsedUrls,
!loadedMainWorkerScript,
);
@@ -595,11 +598,6 @@ const NOT_IMPORTED_OPS = [
"op_test_op_sanitizer_report",
"op_void_async",
"op_void_sync",
- "op_worker_close",
- "op_worker_get_type",
- "op_worker_post_message",
- "op_worker_recv_message",
- "op_worker_sync_fetch",
"op_ws_send_pong",
"op_jupyter_broadcast",
"op_format_file_name",