fix(parallels): keep fresh malformed package locks · openclaw/openclaw@60159b9
vincentkoc
·
2026-06-21
·
via Recent Commits to openclaw:main
| Original file line number | Diff line number | Diff line change |
|---|
@@ -248,7 +248,7 @@ async function removeStalePackageLock(lockDir: string, staleMs: number): Promise
|
248 | 248 | return; |
249 | 249 | } |
250 | 250 | const ageMs = Date.now() - ((await stat(lockDir).catch(() => undefined))?.mtimeMs ?? Date.now()); |
251 | | -if (owner || ageMs >= staleMs) { |
| 251 | +if (owner?.pid !== undefined || staleMs <= 0 || ageMs >= staleMs) { |
252 | 252 | await rm(lockDir, { force: true, recursive: true }).catch(() => undefined); |
253 | 253 | } |
254 | 254 | } |
|
| Original file line number | Diff line number | Diff line change |
|---|
@@ -445,7 +445,7 @@ describe("Parallels smoke model selection", () => {
|
445 | 445 | expect(retained).toBe(`${"a".repeat(2)}${"b".repeat(10)}`); |
446 | 446 | }); |
447 | 447 | |
448 | | -it("reclaims package locks with malformed owner pids", async () => { |
| 448 | +it("keeps fresh package locks with malformed owner pids", async () => { |
449 | 449 | const lockDir = makeTempDir(tempDirs, "openclaw-parallels-package-lock-"); |
450 | 450 | mkdirSync(lockDir, { recursive: true }); |
451 | 451 | writeFileSync(join(lockDir, "owner.json"), '{"pid":-1,"token":"stale"}\n'); |
@@ -457,6 +457,16 @@ describe("Parallels smoke model selection", () => {
|
457 | 457 | |
458 | 458 | await packageArtifactTesting.removeStalePackageLock(lockDir, 2 * 60 * 60_000); |
459 | 459 | |
| 460 | +expect(existsSync(lockDir)).toBe(true); |
| 461 | +}); |
| 462 | + |
| 463 | +it("reclaims stale package locks with malformed owner pids", async () => { |
| 464 | +const lockDir = makeTempDir(tempDirs, "openclaw-parallels-package-lock-"); |
| 465 | +mkdirSync(lockDir, { recursive: true }); |
| 466 | +writeFileSync(join(lockDir, "owner.json"), '{"pid":-1,"token":"stale"}\n'); |
| 467 | + |
| 468 | +await packageArtifactTesting.removeStalePackageLock(lockDir, 0); |
| 469 | + |
460 | 470 | expect(existsSync(lockDir)).toBe(false); |
461 | 471 | }); |
462 | 472 | |
|
此内容由惯性聚合(RSS阅读器)自动聚合整理，仅供阅读参考。 原文来自 — 版权归原作者所有。
