Function tryRecoverExpiredLockDir

src/utils/fs-lock-sync.ts:66–101

(
  lockDir: string,
  purpose: string,
  now: number,
  leaseMs: number,
)

}

function tryRecoverExpiredLockDir(
  lockDir: string,
  purpose: string,
  now: number,
  leaseMs: number,
): boolean {
  const recovery = shouldRecoverLockDir(lockDir, purpose, now, leaseMs);
  if (!recovery.recover) {
    return false;
  }

  const quarantineDir = join(
    dirname(lockDir),
    `.${basename(lockDir)}.stale.${process.pid}.${randomUUID()}`,
  );
  try {
    renameSync(lockDir, quarantineDir);
  } catch {
    return false;
  }

  if (recovery.owner) {
    const quarantinedOwner = readLockOwnerSync(quarantineDir);
    if (!fsLockOwnersEqual(quarantinedOwner, recovery.owner)) {
      try {
        renameSync(quarantineDir, lockDir);
      } catch {
        // Leave quarantined dir intact rather than deleting a lock we could not validate.
      }
      return false;
    }
  }

  rmSync(quarantineDir, { recursive: true, force: true });
  return true;
}

function createLock(lockDir: string, owner: FsLockOwner): AcquiredFsLockSync {
  mkdirSync(lockDir, { mode: 0o700 });