Function tryAcquireFsLockSync

src/utils/fs-lock-sync.ts:159–199

(
  options: TryAcquireFsLockSyncOptions,
)

}

export function tryAcquireFsLockSync(
  options: TryAcquireFsLockSyncOptions,
): AcquiredFsLockSync | null {
  const now = options.now ?? Date.now();
  const owner: FsLockOwner = {
    token: randomUUID(),
    pid: options.pid ?? process.pid,
    purpose: options.purpose,
    acquiredAtMs: now,
    expiresAtMs: now + options.leaseMs,
  };

  try {
    mkdirSync(dirname(options.lockDir), { recursive: true, mode: 0o700 });
    const guard = tryAcquireGuard(options.lockDir, options.purpose, options.leaseMs, now);
    if (!guard) {
      return null;
    }

    try {
      for (let attempt = 0; attempt < 2; attempt += 1) {
        try {
          return createLock(options.lockDir, owner);
        } catch (error) {
          if ((error as NodeJS.ErrnoException).code !== 'EEXIST') {
            return null;
          }
          if (!tryRecoverExpiredLockDir(options.lockDir, options.purpose, now, options.leaseMs)) {
            return null;
          }
        }
      }
    } finally {
      guard.release();
    }
  } catch {
    return null;
  }

  return null;
}