summaryrefslogtreecommitdiff
path: root/tests/testdata/workers
diff options
context:
space:
mode:
authorSatya Rohith <me@satyarohith.com>2024-05-03 11:22:47 +0530
committerGitHub <noreply@github.com>2024-05-03 05:52:47 +0000
commit02d0ff58d2bab24ebbd1e61afe6b571ff4c415af (patch)
tree78b7fa4e7cf0265d688e34ddaa422ec344273e06 /tests/testdata/workers
parent3e98ea4e69732d8a659ca0ca61747fe3887ab673 (diff)
refactor(tests): move worker_threads itests to spec tests (#23648)
Diffstat (limited to 'tests/testdata/workers')
-rw-r--r--tests/testdata/workers/node_worker_auto_exits.mjs19
-rw-r--r--tests/testdata/workers/node_worker_auto_exits.mjs.out3
-rw-r--r--tests/testdata/workers/node_worker_message_port.mjs41
-rw-r--r--tests/testdata/workers/node_worker_message_port.mjs.out6
-rw-r--r--tests/testdata/workers/node_worker_message_port_1.cjs9
-rw-r--r--tests/testdata/workers/node_worker_message_port_unref.mjs40
-rw-r--r--tests/testdata/workers/node_worker_message_port_unref.mjs.out2
-rw-r--r--tests/testdata/workers/node_worker_transfer_port.mjs14
-rw-r--r--tests/testdata/workers/node_worker_transfer_port.mjs.out3
-rw-r--r--tests/testdata/workers/node_worker_transfer_port_1.mjs10
10 files changed, 0 insertions, 147 deletions
diff --git a/tests/testdata/workers/node_worker_auto_exits.mjs b/tests/testdata/workers/node_worker_auto_exits.mjs
deleted file mode 100644
index e434f59f7..000000000
--- a/tests/testdata/workers/node_worker_auto_exits.mjs
+++ /dev/null
@@ -1,19 +0,0 @@
-import { isMainThread, parentPort, Worker } from "node:worker_threads";
-
-function onMessageOneshot() {
- console.log("Got message from main thread!");
- parentPort.off("message", onMessageOneshot);
-}
-
-if (isMainThread) {
- // This re-loads the current file inside a Worker instance.
- const w = new Worker(import.meta.filename);
-
- setTimeout(() => {
- w.postMessage("Hello! I am from the main thread.");
- }, 500);
-} else {
- console.log("Inside Worker!");
- console.log(isMainThread); // Prints 'false'.
- parentPort.on("message", onMessageOneshot);
-}
diff --git a/tests/testdata/workers/node_worker_auto_exits.mjs.out b/tests/testdata/workers/node_worker_auto_exits.mjs.out
deleted file mode 100644
index a160931db..000000000
--- a/tests/testdata/workers/node_worker_auto_exits.mjs.out
+++ /dev/null
@@ -1,3 +0,0 @@
-Inside Worker!
-false
-Got message from main thread!
diff --git a/tests/testdata/workers/node_worker_message_port.mjs b/tests/testdata/workers/node_worker_message_port.mjs
deleted file mode 100644
index 91c7e062d..000000000
--- a/tests/testdata/workers/node_worker_message_port.mjs
+++ /dev/null
@@ -1,41 +0,0 @@
-import workerThreads from "node:worker_threads";
-
-const { port1: mainPort, port2: workerPort } = new workerThreads
- .MessageChannel();
-
-// Note: not using Promise.withResolver() because it's not available in Node.js
-const deferred = createDeferred();
-
-const worker = new workerThreads.Worker(
- import.meta.resolve("./node_worker_message_port_1.cjs"),
- {
- workerData: workerPort,
- transferList: [workerPort],
- },
-);
-
-worker.on("message", (data) => {
- console.log("worker:", data);
- mainPort.on("message", (msg) => {
- console.log("mainPort:", msg);
- deferred.resolve();
- });
- mainPort.on("close", (_msg) => {
- console.log("mainPort closed");
- });
-});
-
-worker.postMessage("Hello from parent");
-await deferred.promise;
-await worker.terminate();
-mainPort.close();
-
-function createDeferred() {
- let resolveCallback;
- let rejectCallback;
- const promise = new Promise((resolve, reject) => {
- resolveCallback = resolve;
- rejectCallback = reject;
- });
- return { promise, resolve: resolveCallback, reject: rejectCallback };
-}
diff --git a/tests/testdata/workers/node_worker_message_port.mjs.out b/tests/testdata/workers/node_worker_message_port.mjs.out
deleted file mode 100644
index 95b4fbc96..000000000
--- a/tests/testdata/workers/node_worker_message_port.mjs.out
+++ /dev/null
@@ -1,6 +0,0 @@
-[UNORDERED_START]
-worker port closed
-worker: Hello from worker on parentPort!
-mainPort: Hello from worker on workerPort!
-mainPort closed
-[UNORDERED_END]
diff --git a/tests/testdata/workers/node_worker_message_port_1.cjs b/tests/testdata/workers/node_worker_message_port_1.cjs
deleted file mode 100644
index 3f78cd539..000000000
--- a/tests/testdata/workers/node_worker_message_port_1.cjs
+++ /dev/null
@@ -1,9 +0,0 @@
-const { parentPort, workerData } = require("worker_threads");
-
-parentPort.on("message", (msg) => {
- const workerPort = workerData;
- parentPort.postMessage("Hello from worker on parentPort!");
- workerPort.postMessage("Hello from worker on workerPort!");
- workerPort.on("close", () => console.log("worker port closed"));
- workerPort.close();
-});
diff --git a/tests/testdata/workers/node_worker_message_port_unref.mjs b/tests/testdata/workers/node_worker_message_port_unref.mjs
deleted file mode 100644
index a12be1ec8..000000000
--- a/tests/testdata/workers/node_worker_message_port_unref.mjs
+++ /dev/null
@@ -1,40 +0,0 @@
-import {
- isMainThread,
- MessageChannel,
- parentPort,
- Worker,
- workerData,
-} from "node:worker_threads";
-
-const useParentPort = Deno.env.get("PARENT_PORT") === "1";
-
-if (useParentPort) {
- if (isMainThread) {
- const worker = new Worker(import.meta.filename);
- worker.postMessage("main says hi!");
- worker.on("message", (msg) => console.log(msg));
- } else {
- parentPort.on("message", (msg) => {
- console.log(msg);
- parentPort.postMessage("worker says hi!");
- parentPort.unref();
- });
- }
-} else {
- if (isMainThread) {
- const { port1, port2 } = new MessageChannel();
- const worker = new Worker(import.meta.filename, {
- workerData: port2,
- transferList: [port2],
- });
- port1.postMessage("main says hi!");
- port1.on("message", (msg) => console.log(msg));
- } else {
- const port = workerData;
- port.on("message", (msg) => {
- console.log(msg);
- port.postMessage("worker says hi!");
- port.unref();
- });
- }
-}
diff --git a/tests/testdata/workers/node_worker_message_port_unref.mjs.out b/tests/testdata/workers/node_worker_message_port_unref.mjs.out
deleted file mode 100644
index c9d5325bc..000000000
--- a/tests/testdata/workers/node_worker_message_port_unref.mjs.out
+++ /dev/null
@@ -1,2 +0,0 @@
-main says hi!
-worker says hi!
diff --git a/tests/testdata/workers/node_worker_transfer_port.mjs b/tests/testdata/workers/node_worker_transfer_port.mjs
deleted file mode 100644
index 1b17ed1ab..000000000
--- a/tests/testdata/workers/node_worker_transfer_port.mjs
+++ /dev/null
@@ -1,14 +0,0 @@
-import { MessageChannel, Worker } from "node:worker_threads";
-
-const { port1, port2 } = new MessageChannel();
-const worker = new Worker(
- import.meta.resolve("./node_worker_transfer_port_1.mjs"),
-);
-// Send the port directly after the worker is created
-worker.postMessage(port2, [port2]);
-// Send a message to the worker using the transferred port
-port1.postMessage("Hello from main thread!");
-worker.on("message", (message) => {
- console.log("Received message from worker:", message);
- worker.terminate();
-});
diff --git a/tests/testdata/workers/node_worker_transfer_port.mjs.out b/tests/testdata/workers/node_worker_transfer_port.mjs.out
deleted file mode 100644
index 8e8f11940..000000000
--- a/tests/testdata/workers/node_worker_transfer_port.mjs.out
+++ /dev/null
@@ -1,3 +0,0 @@
-Worker thread started!
-Received message from main thread: Hello from main thread!
-Received message from worker: Reply from worker
diff --git a/tests/testdata/workers/node_worker_transfer_port_1.mjs b/tests/testdata/workers/node_worker_transfer_port_1.mjs
deleted file mode 100644
index 4d0a38bd5..000000000
--- a/tests/testdata/workers/node_worker_transfer_port_1.mjs
+++ /dev/null
@@ -1,10 +0,0 @@
-import { parentPort } from "node:worker_threads";
-
-parentPort.on("message", (message) => {
- const transferredPort = message;
- transferredPort.on("message", (message) => {
- console.log("Received message from main thread:", message);
- parentPort.postMessage("Reply from worker");
- });
- console.log("Worker thread started!");
-});