Function acquireStateFileLock

src/proxy/mailbox/state.js:51–82

(stateFile)

}

function acquireStateFileLock(stateFile) {
  ensurePrivateDir(path.dirname(stateFile));
  const lockDir = `${stateFile}.lock`;
  const startedAt = Date.now();
  while (true) {
    try {
      fs.mkdirSync(lockDir, { mode: PRIVATE_DIR_MODE });
      bestEffortChmod(lockDir, PRIVATE_DIR_MODE);
      return function releaseStateFileLock() {
        try { fs.rmdirSync(lockDir); } catch {}
      };
    } catch (e) {
      if (!e || e.code !== 'EEXIST') throw e;
      try {
        const ageMs = Date.now() - fs.statSync(lockDir).mtimeMs;
        if (ageMs > STATE_LOCK_STALE_MS) {
          fs.rmSync(lockDir, { recursive: true, force: true });
          continue;
        }
      } catch (statErr) {
        if (statErr && statErr.code === 'ENOENT') continue;
        throw statErr;
      }
      if (Date.now() - startedAt > STATE_LOCK_STALE_MS) {
        const err = new Error('timed out waiting for mailbox state lock');
        err.code = 'MAILBOX_STATE_LOCK_TIMEOUT';
        throw err;
      }
      sleepSync(STATE_LOCK_WAIT_MS);
    }
  }
}

function isPlainState(value) {
  return value && typeof value === 'object' && !Array.isArray(value);