github/openclaw
1
0
Fork 0
mirror of https://github.com/openclaw/openclaw.git synced 2026-05-08 18:28:26 +00:00
Code Issues Packages Projects Releases Wiki Activity

test: remove low-value cross-storepath lock parallelism case

Browse Source
This commit is contained in:
Peter Steinberger
2026-02-16 08:56:23 +00:00
parent 314f193030
commit eb7b5c02c3
1 changed files with 0 additions and 55 deletions
Download Patch File Download Diff File Expand all files Collapse all files

55
src/config/sessions/sessions.test.ts
View File

@@ -246,61 +246,6 @@ describe("session store lock (Promise chain mutex)", () => {
const store = loadSessionStore(storePath); const store = loadSessionStore(storePath);
expect(store[key]?.modelOverride).toBe("recovered"); expect(store[key]?.modelOverride).toBe("recovered");
}); });
it("operations on different storePaths execute concurrently", async () => {
const { storePath: pathA } = await makeTmpStore({
a: { sessionId: "a", updatedAt: 100 },
});
const { storePath: pathB } = await makeTmpStore({
b: { sessionId: "b", updatedAt: 100 },
});
const order: string[] = [];
let started = 0;
let releaseBoth: (() => void) | undefined;
const gate = new Promise<void>((resolve) => {
releaseBoth = resolve;
});
const markStarted = () => {
started += 1;
if (started === 2) {
releaseBoth?.();
}
};
const opA = updateSessionStore(pathA, async (store) => {
order.push("a-start");
markStarted();
await gate;
store.a = { ...store.a, modelOverride: "done-a" } as unknown as SessionEntry;
order.push("a-end");
});
const opB = updateSessionStore(pathB, async (store) => {
order.push("b-start");
markStarted();
await gate;
store.b = { ...store.b, modelOverride: "done-b" } as unknown as SessionEntry;
order.push("b-end");
});
await Promise.all([opA, opB]);
const aStart = order.indexOf("a-start");
const bStart = order.indexOf("b-start");
const aEnd = order.indexOf("a-end");
const bEnd = order.indexOf("b-end");
const firstEnd = Math.min(aEnd, bEnd);
expect(aStart).toBeGreaterThanOrEqual(0);
expect(bStart).toBeGreaterThanOrEqual(0);
expect(aEnd).toBeGreaterThanOrEqual(0);
expect(bEnd).toBeGreaterThanOrEqual(0);
expect(aStart).toBeLessThan(firstEnd);
expect(bStart).toBeLessThan(firstEnd);
expect(loadSessionStore(pathA).a?.modelOverride).toBe("done-a");
expect(loadSessionStore(pathB).b?.modelOverride).toBe("done-b");
});
}); });
describe("resolveMirroredTranscriptText", () => { describe("resolveMirroredTranscriptText", () => {