Function runPollOnce

packages/node/src/backend/nodeBackendInline.ts:431–490

()

  }

  function runPollOnce(): void {
    if (!started || disposed || stopRequested || fatal !== null) return;
    if (engineId === null || native === null || discardBuffer === null) return;
    if (pollActive) return;
    pollActive = true;
    try {
      const outBuf = eventPool.length > 0 ? (eventPool.pop() ?? discardBuffer) : discardBuffer;
      let written = -1;
      const startMs = PERF_ENABLED ? performance.now() : 0;
      try {
        written = native.enginePollEvents(engineId, 0, new Uint8Array(outBuf));
      } catch (err) {
        failWith("enginePollEvents", -1, `engine_poll_events threw: ${safeDetail(err)}`);
        return;
      }
      if (PERF_ENABLED) {
        perfRecord("event_poll", performance.now() - startMs);
      }
      if (written === ZR_ERR_LIMIT) {
        if (outBuf !== discardBuffer) eventPool.push(outBuf);
        droppedSinceLast++;
        schedulePoll(POLL_BUSY_MS);
        return;
      }
      if (!Number.isInteger(written) || written > outBuf.byteLength) {
        if (outBuf !== discardBuffer) eventPool.push(outBuf);
        failWith(
          "enginePollEvents",
          -1,
          `engine_poll_events returned invalid byte count: written=${String(written)} capacity=${String(outBuf.byteLength)}`,
        );
        return;
      }
      if (written < 0) {
        if (outBuf !== discardBuffer) eventPool.push(outBuf);
        failWith("enginePollEvents", written, "engine_poll_events failed");
        return;
      }
      if (written === 0) {
        if (outBuf !== discardBuffer) eventPool.push(outBuf);
        schedulePoll(POLL_IDLE_MS);
        return;
      }
      if (outBuf === discardBuffer) {
        droppedSinceLast++;
        schedulePoll(POLL_BUSY_MS);
        return;
      }
      const waiter = eventWaiters.shift();
      if (waiter !== undefined) {
        waiter.resolve(buildBatch(outBuf, written, droppedSinceLast));
      } else {
        eventQueue.push({ batch: outBuf, byteLen: written, droppedSinceLast });
      }
      droppedSinceLast = 0;
      schedulePoll(POLL_BUSY_MS);
    } finally {
      pollActive = false;