Method runDataPipeline

app/src/Benchmark/HotpathBenchmark.cpp:500–558

* @brief Measures raw FrameReader extraction throughput (the driver pipeline, no parse). */

 * @brief Measures raw FrameReader extraction throughput (the driver pipeline, no parse).
 */
HotpathBenchmark::Result HotpathBenchmark::runDataPipeline(quint64 targetFrames,
                                                           double minFps,
                                                           double minSeconds)
{
  Q_ASSERT(targetFrames > 0);
  Q_ASSERT(minFps > 0.0);
  Q_ASSERT(minSeconds >= 0.0);

  constexpr int kChannels       = 8;
  constexpr int kFramesPerChunk = 1000;

  const QByteArray chunk = buildChunk(kFramesPerChunk, kChannels);

  IO::FrameReader reader;
  reader.setOperationMode(SerialStudio::QuickPlot);
  reader.setFinishSequences({QByteArrayLiteral("\n")});

  auto& queue = reader.queue();
  IO::CapturedDataPtr drained;

  using Clock             = std::chrono::steady_clock;
  const quint64 maxFrames = targetFrames + static_cast<quint64>(minSeconds * 1.0e9);
  const quint64 maxChunks = maxFrames / kFramesPerChunk + 1;

  quint64 extracted = 0;
  quint64 fed       = 0;
  double seconds    = 0.0;
  double spentSpin  = 0.0;
  double lastSpin   = 0.0;
  const auto start  = Clock::now();
  for (quint64 c = 0; c < maxChunks && (fed < targetFrames || seconds < minSeconds); ++c) {
    reader.processData(IO::makeCapturedData(chunk));

    // code-verify off
    while (queue.try_dequeue(drained))
      ++extracted;
    // code-verify on

    fed     += kFramesPerChunk;
    seconds  = std::chrono::duration<double>(Clock::now() - start).count() - spentSpin;

    if (seconds - lastSpin >= kSpinIntervalSec) {
      spentSpin += spinEventLoop();
      lastSpin   = seconds;
    }
  }

  const double fps = seconds > 0.0 ? static_cast<double>(extracted) / seconds : 0.0;

  Result result;
  result.passed          = fps >= minFps;
  result.language        = -1;
  result.minFps          = minFps;
  result.framesPerSecond = fps;
  result.elapsedSeconds  = seconds;
  result.framesParsed    = extracted;
  result.framesSkipped   = 0;
  return result;