Function withDaemonRegistryMutationLock

src/daemon/daemon-registry.ts:167–191

(
  workspaceKey: string,
  callback: () => T,
  existingLock?: DaemonRegistryMutationLock,
)

}

function withDaemonRegistryMutationLock<T>(
  workspaceKey: string,
  callback: () => T,
  existingLock?: DaemonRegistryMutationLock,
): T | null {
  if (existingLock) {
    if (existingLock.workspaceKey !== workspaceKey) {
      throw new Error(
        `Daemon registry lock for ${existingLock.workspaceKey} cannot guard ${workspaceKey}`,
      );
    }
    return callback();
  }

  const lock = acquireDaemonRegistryMutationLock(workspaceKey);
  if (!lock) {
    return null;
  }

  try {
    return callback();
  } finally {
    lock.release();
  }
}

function entryMatchesCleanupTarget(
  entry: DaemonRegistryEntry,