summaryrefslogtreecommitdiff
path: root/ext
diff options
context:
space:
mode:
Diffstat (limited to 'ext')
-rw-r--r--ext/node/polyfills/async_hooks.ts11
-rw-r--r--ext/web/13_message_port.js36
2 files changed, 25 insertions, 22 deletions
diff --git a/ext/node/polyfills/async_hooks.ts b/ext/node/polyfills/async_hooks.ts
index 9240d56c5..f2733e92d 100644
--- a/ext/node/polyfills/async_hooks.ts
+++ b/ext/node/polyfills/async_hooks.ts
@@ -7,11 +7,12 @@
// TODO(petamoriken): enable prefer-primordials for node polyfills
// deno-lint-ignore-file prefer-primordials
+import { core } from "ext:core/mod.js";
+const {
+ op_node_is_promise_rejected,
+} = core.ensureFastOps();
import { validateFunction } from "ext:deno_node/internal/validators.mjs";
-const { core } = globalThis.__bootstrap;
-const { ops } = core;
-
function assert(cond: boolean) {
if (!cond) throw new Error("Assertion failed");
}
@@ -57,7 +58,7 @@ function setPromiseHooks() {
};
const after = (promise: Promise<unknown>) => {
popAsyncFrame();
- if (!ops.op_node_is_promise_rejected(promise)) {
+ if (!op_node_is_promise_rejected(promise)) {
// @ts-ignore promise async context
promise[asyncContext] = undefined;
}
@@ -65,7 +66,7 @@ function setPromiseHooks() {
const resolve = (promise: Promise<unknown>) => {
const currentFrame = AsyncContextFrame.current();
if (
- !currentFrame.isRoot() && ops.op_node_is_promise_rejected(promise) &&
+ !currentFrame.isRoot() && op_node_is_promise_rejected(promise) &&
typeof promise[asyncContext] === "undefined"
) {
AsyncContextFrame.attachContext(promise);
diff --git a/ext/web/13_message_port.js b/ext/web/13_message_port.js
index 0fddfc2e8..e4df3afcb 100644
--- a/ext/web/13_message_port.js
+++ b/ext/web/13_message_port.js
@@ -7,18 +7,11 @@
/// <reference path="./lib.deno_web.d.ts" />
import { core, primordials } from "ext:core/mod.js";
-const { InterruptedPrototype, ops } = core;
-import * as webidl from "ext:deno_webidl/00_webidl.js";
-import { createFilteredInspectProxy } from "ext:deno_console/01_console.js";
-import {
- defineEventHandler,
- EventTarget,
- MessageEvent,
- setEventTargetData,
- setIsTrusted,
-} from "ext:deno_web/02_event.js";
-import { isDetachedBuffer } from "ext:deno_web/06_streams.js";
-import { DOMException } from "ext:deno_web/01_dom_exception.js";
+const {
+ op_message_port_post_message,
+ op_message_port_recv_message,
+ op_message_port_create_entangled,
+} = core.ensureFastOps();
const {
ArrayBufferPrototypeGetByteLength,
ArrayPrototypeFilter,
@@ -31,11 +24,20 @@ const {
TypeError,
} = primordials;
const {
+ InterruptedPrototype,
isArrayBuffer,
} = core;
-const {
- op_message_port_recv_message,
-} = core.ensureFastOps();
+import * as webidl from "ext:deno_webidl/00_webidl.js";
+import { createFilteredInspectProxy } from "ext:deno_console/01_console.js";
+import {
+ defineEventHandler,
+ EventTarget,
+ MessageEvent,
+ setEventTargetData,
+ setIsTrusted,
+} from "ext:deno_web/02_event.js";
+import { isDetachedBuffer } from "ext:deno_web/06_streams.js";
+import { DOMException } from "ext:deno_web/01_dom_exception.js";
class MessageChannel {
/** @type {MessagePort} */
@@ -140,7 +142,7 @@ class MessagePort extends EventTarget {
}
const data = serializeJsMessageData(message, transfer);
if (this[_id] === null) return;
- ops.op_message_port_post_message(this[_id], data);
+ op_message_port_post_message(this[_id], data);
}
start() {
@@ -220,7 +222,7 @@ const MessagePortPrototype = MessagePort.prototype;
* @returns {[number, number]}
*/
function opCreateEntangledMessagePort() {
- return ops.op_message_port_create_entangled();
+ return op_message_port_create_entangled();
}
/**