components

2.8 KB

1. // ws-event-order-load.mjs — 039_http1_ws_client's events must arrive in the order they
2. // happened under load, too (2026-10-02). Two orderings were measured broken there only
3. // when threads get preempted: the client's `open` before the server's `connect` (fixed by
4. // the loop's stamp order, plugin_api.zig `head_stamp_fn`), and the client's `close`
5. // before the server's (the server queued its `close` after writing the echo: 18-25 of
6. // 100 runs, 10 copies on 3 CPUs under HL_GC_STRESS=1). No in-process trick stalls a
7. // plugin thread between a write and a queue, so this is the loaded repeat: the fixture
8. // compiled --native, LANES copies at once pinned to 2 CPUs, RUNS rounds (master before the
9. // close fix: 2-6 of the 192 out of order, 5 tries of 5; ~8 s).
10. import { spawn, spawnSync } from 'node:child_process';
11. import { mkdtempSync, readFileSync, rmSync } from 'node:fs';
12. import { tmpdir } from 'node:os';
13. import { fileURLToPath } from 'node:url';
14. import { dirname, join, resolve } from 'node:path';
16. const ROOT = resolve(dirname(fileURLToPath(import.meta.url)), '../../..');
17. const BIN = resolve(ROOT, 'native/zig-out/bin/hybriel');
18. const DIR = resolve(ROOT, 'tests/pass/plugins');
19. const NAME = '039_http1_ws_client';
20. const EXP = readFileSync(resolve(ROOT, `tests/expected/pass/plugins/${NAME}.txt`), 'utf8').trimEnd();
21. const BASE = Number(process.env.HL_TEST_PORT || 14980);
22. const LANES = Number(process.env.LANES || 16), RUNS = Number(process.env.RUNS || 12), CPUS = process.env.CPUS || '0-1';
24. const work = mkdtempSync(join(tmpdir(), 'hl-ws-order-'));
25. const exe = join(work, NAME);
26. const c = spawnSync(BIN, ['--native', `${NAME}.hl`, '-o', exe, '--quiet'], { cwd: DIR, encoding: 'utf8' });
27. if (c.status !== 0) { console.log('FAIL compile: ' + (c.stderr || c.stdout)); process.exit(1); }
29. const once = (port) => new Promise((res) => {
30. // one pipe for both streams, as the runner reads them: the banner is stderr
31. const p = spawn('sh', ['-c', 'exec taskset -c "$1" "$0" 2>&1', exe, CPUS], {
32. cwd: DIR, env: { ...process.env, HL_TEST_PORT: String(port), HL_GC_STRESS: '1', HOME: work },
33. });
34. let out = '';
35. p.stdout.on('data', (d) => { out += d; });
36. const t = setTimeout(() => p.kill('SIGKILL'), 60000);
37. p.on('close', (code) => {
38. clearTimeout(t);
39. const got = out.replace(/\0/g, '').replace(new RegExp(`:${port}(?!\\d)`, 'g'), ':PORT').trimEnd();
40. res(code === 0 && got === EXP ? null : `exit ${code}\n${got}`);
41. });
42. });
44. const bad = [];
45. for (let r = 0; r < RUNS; r++) {
46. const outs = await Promise.all(Array.from({ length: LANES }, (_, k) => once(BASE + k)));
47. outs.forEach((o) => { if (o) bad.push(o); });
48. }
49. rmSync(work, { recursive: true, force: true });
50. if (bad.length) {
51. console.log(`FAIL ${bad.length} of ${LANES * RUNS} runs out of order; first:\n${bad[0]}`);
52. process.exit(1);
53. }
54. console.log(`ok ws-event-order-load: ${LANES * RUNS} loaded runs of ${NAME} in order`);