Function acquireDaemonRegistryMutationLock

src/daemon/daemon-registry.ts:39–60

(
  workspaceKey: string,
)

 * — never from request handlers.
 */
export function acquireDaemonRegistryMutationLock(
  workspaceKey: string,
): DaemonRegistryMutationLock | null {
  const lockDir = join(getWorkspaceFilesystemLayout(workspaceKey).locks, 'daemon-registry.lock');
  const deadline = Date.now() + DAEMON_REGISTRY_LOCK_WAIT_MS;
  do {
    const lock = tryAcquireFsLockSync({
      lockDir,
      purpose: DAEMON_REGISTRY_LOCK_PURPOSE,
      leaseMs: DAEMON_REGISTRY_LOCK_LEASE_MS,
    });
    if (lock) {
      return {
        workspaceKey,
        release: () => lock.release(),
      };
    }
    sleepSync(DAEMON_REGISTRY_LOCK_POLL_MS);
  } while (Date.now() < deadline);

  return null;
}

/**
 * Metadata stored for each running daemon.