test: support higher vitest shard parallelism · openclaw/...

Recent Commits to openclaw:main

steipete · 2026-05-06 · via Recent Commits to openclaw:main

Original file line number	Diff line number	Diff line change
`@@ -34,6 +34,26 @@ export function forwardSignalToVitestProcessGroup(params) {`
`34`	`34`	`}`
`35`	`35`	`}`
`36`	`36`
	`37`	`+function ensureProcessListenerCapacity(processObject, eventName, additionalListeners = 1) {`
	`38`	`+if (`
	`39`	`+typeof processObject.getMaxListeners !== "function" \|\|`
	`40`	`+typeof processObject.setMaxListeners !== "function" \|\|`
	`41`	`+typeof processObject.listenerCount !== "function"`
	`42`	`+) {`
	`43`	`+return;`
	`44`	`+}`
	`45`	`+`
	`46`	`+const currentLimit = processObject.getMaxListeners();`
	`47`	`+if (currentLimit === 0) {`
	`48`	`+return;`
	`49`	`+}`
	`50`	`+`
	`51`	`+const neededLimit = processObject.listenerCount(eventName) + additionalListeners + 1;`
	`52`	`+if (neededLimit > currentLimit) {`
	`53`	`+processObject.setMaxListeners(neededLimit);`
	`54`	`+}`
	`55`	`+}`
	`56`	`+`
`37`	`57`	`export function installVitestProcessGroupCleanup(params) {`
`38`	`58`	`const processObject = params.processObject ?? process;`
`39`	`59`	`const platform = params.platform ?? process.platform;`
`@@ -62,12 +82,14 @@ export function installVitestProcessGroupCleanup(params) {`
`62`	`82`	`forward(signal);`
`63`	`83`	`};`
`64`	`84`	`signalHandlers.set(signal, handler);`
	`85`	`+ensureProcessListenerCapacity(processObject, signal);`
`65`	`86`	`processObject.on(signal, handler);`
`66`	`87`	`}`
`67`	`88`
`68`	`89`	`const exitHandler = () => {`
`69`	`90`	`forward(cleanupSignal);`
`70`	`91`	`};`
	`92`	`+ensureProcessListenerCapacity(processObject, "exit");`
`71`	`93`	`processObject.on("exit", exitHandler);`
`72`	`94`
`73`	`95`	`return () => {`

Original file line number	Diff line number	Diff line change
`@@ -96,4 +96,46 @@ describe("vitest process group helpers", () => {`
`96`	`96`	`expect(listeners.get("SIGTERM")?.size ?? 0).toBe(0);`
`97`	`97`	`expect(listeners.get("exit")?.size ?? 0).toBe(0);`
`98`	`98`	`});`
	`99`	`+`
	`100`	`+it("raises process listener limits for highly parallel cleanup handlers", () => {`
	`101`	`+const listeners = new Map<string, Set<() => void>>();`
	`102`	`+let maxListeners = 10;`
	`103`	`+const fakeProcess = {`
	`104`	`+getMaxListeners: () => maxListeners,`
	`105`	`+setMaxListeners: vi.fn((value: number) => {`
	`106`	`+maxListeners = value;`
	`107`	`+return fakeProcess;`
	`108`	`+}),`
	`109`	`+listenerCount(event: string) {`
	`110`	`+return listeners.get(event)?.size ?? 0;`
	`111`	`+},`
	`112`	`+on(event: string, handler: () => void) {`
	`113`	`+const set = listeners.get(event) ?? new Set();`
	`114`	`+set.add(handler);`
	`115`	`+listeners.set(event, set);`
	`116`	`+},`
	`117`	`+off(event: string, handler: () => void) {`
	`118`	`+listeners.get(event)?.delete(handler);`
	`119`	`+},`
	`120`	`+};`
	`121`	`+`
	`122`	`+const teardowns = Array.from({ length: 12 }, (_, index) =>`
	`123`	`+installVitestProcessGroupCleanup({`
	`124`	`+child: { pid: 4200 + index },`
	`125`	`+processObject: fakeProcess as unknown as NodeJS.Process,`
	`126`	`+platform: "darwin",`
	`127`	`+kill: vi.fn(),`
	`128`	`+}),`
	`129`	`+);`
	`130`	`+`
	`131`	`+expect(maxListeners).toBeGreaterThan(10);`
	`132`	`+expect(fakeProcess.setMaxListeners).toHaveBeenCalled();`
	`133`	`+`
	`134`	`+for (const teardown of teardowns) {`
	`135`	`+teardown();`
	`136`	`+}`
	`137`	`+expect(listeners.get("SIGINT")?.size ?? 0).toBe(0);`
	`138`	`+expect(listeners.get("SIGTERM")?.size ?? 0).toBe(0);`
	`139`	`+expect(listeners.get("exit")?.size ?? 0).toBe(0);`
	`140`	`+});`
`99`	`141`	`});`

此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。原文来自 — 版权归原作者所有。

推荐订阅源

Recent Commits to openclaw:main