blob: b026dabbf64202a09e1b20e73fdf42e76d7bcc56 (
plain)
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
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));
});
|
