Function acquireServeLock

src/cli.ts:719–739

(lockPath: string)

}

async function acquireServeLock(lockPath: string): Promise<ServeLock> {
  await fsp.mkdir(path.dirname(lockPath), { recursive: true });
  try {
    return await createServeLock(lockPath);
  } catch (error) {
    if (!(error && typeof error === 'object' && 'code' in error) || error.code !== 'EEXIST') {
      throw error;
    }
  }

  const existing = readServeLock(lockPath);
  if (existing?.pid && isProcessAlive(existing.pid)) {
    throw new Error(createI18n().t('cli.lock.alreadyRunning', {
      lockPath,
      pid: existing.pid,
    }));
  }

  await fsp.rm(lockPath, { force: true });
  return createServeLock(lockPath);
}

async function createServeLock(lockPath: string): Promise<ServeLock> {
  const handle = await fsp.open(lockPath, 'wx');