Function withLock

workspaces/libnpmexec/lib/with-lock.js:48–67

* Acquire an advisory lock for the given path and hold it for the duration of the callback. * * The lock will be released automatically when the callback resolves or rejects. * Concurrent calls to withLock() for the same path will wait until the lock is released.

(lockPath, cb)

 * Concurrent calls to withLock() for the same path will wait until the lock is released.
 */
async function withLock (lockPath, cb) {
  try {
    const signal = await acquireLock(lockPath)
    return await new Promise((resolve, reject) => {
      signal.addEventListener('abort', () => {
        reject(Object.assign(new Error('Lock compromised'), { code: 'ECOMPROMISED' }))
      });

      (async () => {
        try {
          resolve(await cb(signal))
        } catch (err) {
          reject(err)
        }
      })()
    })
  } finally {
    releaseLock(lockPath)
  }
}

function acquireLock (lockPath) {
  return promiseRetry(async (retry) => {