Function tryAcquireGuard

src/utils/fs-lock.ts:152–183

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

}

async function tryAcquireGuard(
  lockDir: string,
  purpose: string,
  leaseMs: number,
  now: number,
): Promise<AcquiredFsLock | null> {
  const guardDir = guardDirForLockDir(lockDir);
  const guardOwner: FsLockOwner = {
    token: randomUUID(),
    pid: process.pid,
    purpose: `${purpose}:guard`,
    acquiredAtMs: now,
    expiresAtMs: now + leaseMs,
  };

  try {
    return await createLock(guardDir, guardOwner);
  } catch (error) {
    if ((error as NodeJS.ErrnoException).code !== 'EEXIST') {
      return null;
    }
    const recovered = await tryRecoverExpiredLockDir(guardDir, guardOwner.purpose, now, leaseMs);
    if (!recovered) {
      return null;
    }
    try {
      return await createLock(guardDir, guardOwner);
    } catch {
      return null;
    }
  }
}

export async function tryAcquireFsLock(
  options: TryAcquireFsLockOptions,