1 files changed, 45 insertions, 0 deletions
diff --git a/tests/specs/test/sanitizer_with_top_level_ops/main.js b/tests/specs/test/sanitizer_with_top_level_ops/main.js
new file mode 100644
index 000000000..b026dabbf
--- /dev/null
+++ b/tests/specs/test/sanitizer_with_top_level_ops/main.js
@@ -0,0 +1,45 @@
+// The sanitizers must ignore any ops, resources or timers that are
+// "replaced" at the top level with a thing of the same kind.
+
+// An async IIFE that throws off timers every 10ms
+(async () => {
+  while (true) {
+    await new Promise((r) => setTimeout(r, 10));
+  }
+})();
+
+// An HTTP server that resolves an op for every request
+const { promise, resolve } = Promise.withResolvers();
+const server = Deno.serve({
+  port: 0,
+  onListen: ({ port }) => resolve(port),
+  handler: () => new Response("ok"),
+});
+const port = await promise;
+
+// A TCP listener loop
+const listener = Deno.listen({ port: 0 });
+const conn1 = await Deno.connect({ port: listener.addr.port });
+const conn2 = await listener.accept();
+
+// Note: we need to ensure that these read/write ops are balanced at the top-level to avoid triggering
+// the sanitizer, so we use two async IIFEs.
+(async () => {
+  // This will write without blocking for a bit but eventually will start writing async
+  // once the tokio coop kicks in or the buffers fill up.
+  while (true) {
+    await conn1.write(new Uint8Array(1024));
+  }
+})();
+(async () => {
+  while (true) {
+    await conn2.read(new Uint8Array(10 * 1024));
+  }
+})();
+
+Deno.test(async function waits() {
+  // Trigger the server to restart its op
+  await (await fetch(`http://127.0.0.1:${port}/`)).text();
+  // Let the IIFEs run for a bit
+  await new Promise((r) => setTimeout(r, 100));
+});