Files
scriptc/packages/runtime/src/scr_shared.test.ts
T
Chris Tate 095b619330 Add native workers and shared memory
- Add native worker execution with isolated module state, structured messages, and lifecycle controls.
- Support shared buffers and integer atomics with coordinated runtime ownership and cancellation.
- Extend compiler, runtime-pack, differential, and compatibility coverage for native concurrency.
2026-10-07 19:07:02 -05:00

46 lines
1.5 KiB
TypeScript

import { execFile } from "node:child_process";
import { mkdtemp, rm } from "node:fs/promises";
import { tmpdir } from "node:os";
import { join } from "node:path";
import { promisify } from "node:util";
import { expect, test } from "vitest";
import { EXECUTABLE_RUNTIME_SOURCES } from "../../compiler/src/backend/native-toolchain.js";
const exec = promisify(execFile);
test.skipIf(process.platform === "win32")(
"shared views serialize concurrent accesses and cancel parked waiters",
async () => {
const dir = await mkdtemp(join(tmpdir(), "scriptc-shared-"));
try {
const bin = join(dir, "shared");
await exec("clang", [
"-std=c11",
"-O1",
"-pthread",
"-DSCR_WORKERS",
"-DSCR_RC_AUDIT",
"-fsanitize=address,undefined",
"-Wno-deprecated-declarations",
...(process.platform === "linux" ? ["-D_GNU_SOURCE"] : []),
...["scr_shared.test.c", ...EXECUTABLE_RUNTIME_SOURCES].map((name) =>
join(import.meta.dirname, name),
),
...(process.platform === "linux" ? ["-lm"] : []),
"-o",
bin,
]);
const result = await exec(bin, [], {
timeout: 10000,
env: { ...process.env, UBSAN_OPTIONS: "halt_on_error=1" },
});
expect(result.stdout).toBe(
"shared views preserve atomic updates, wait queues and cancellation ownership\n",
);
expect(result.stderr).toBe("");
} finally {
await rm(dir, { recursive: true, force: true });
}
},
);