Function _acquireLock

packages/socket.io-cluster-engine/lib/engine.ts:433–463

(
    sid: SessionId,
    transportName: string,
    lockType: "read" | "write",
    onSuccess: (senderId: NodeId) => void,
    onError: () => void,
  )

  }

  private _acquireLock(
    sid: SessionId,
    transportName: string,
    lockType: class="st">"read" | class="st">"write",
    onSuccess: (senderId: NodeId) => void,
    onError: () => void,
  ) {
    const requestId = ++this._requestCount as RequestId;

    const timer = setTimeout(() => {
      this._requests.delete(requestId);
      onError();
    }, this._opts.responseTimeout);

    this._requests.set(requestId, {
      timer,
      onSuccess,
      onError,
    });

    this.publishMessage({
      requestId,
      senderId: this._nodeId,
      type: MessageType.ACQUIRE_LOCK,
      data: {
        sid,
        transportName,
        type: lockType,
      },
    });
  }

  private _hookTransport(
    sid: SessionId,