Method processData

app/src/IO/FrameReader.cpp:78–142

* @brief Processes a chunk of received bytes and extracts complete frames. */

 * @brief Processes a chunk of received bytes and extracts complete frames.
 */
void IO::FrameReader::processData(const CapturedDataPtr& data)
{
  Q_ASSERT(m_operationMode >= SerialStudio::ProjectFile
           && m_operationMode <= SerialStudio::QuickPlot);
  Q_ASSERT(m_checksumLength >= 0);

  if (!data || data->data.isEmpty())
    return;

  if (m_operationMode == SerialStudio::ConsoleOnly)
    return;

  bool framesEnqueued = false;

  if (m_operationMode == SerialStudio::ProjectFile
      && m_frameDetectionMode == SerialStudio::NoDelimiters) {
    framesEnqueued = m_queue.try_enqueue(data);
    if (!framesEnqueued) [[unlikely]]
      noteDroppedFrame();
  }

  else {
    appendChunk(data);
    const auto overflow = m_circularBuffer.overflowCount();
    if (overflow > 0) [[unlikely]] {
      const auto now = CapturedData::SteadyClock::now();
      if (now - m_lastOverflowLog >= std::chrono::seconds(5)) {
        m_lastOverflowLog = now;
        qWarning() << "[FrameReader] Buffer overflow:" << overflow
                   << "bytes lost -- data rate exceeds processing capacity";
      }
      discardPendingBytes(overflow);
      m_circularBuffer.resetOverflowCount();
    }

    const auto initialSize = m_queue.size_approx();
    switch (m_operationMode) {
      case SerialStudio::QuickPlot:
        readEndDelimitedFrames();
        break;
      case SerialStudio::ProjectFile:
        switch (m_frameDetectionMode) {
          case SerialStudio::EndDelimiterOnly:
            readEndDelimitedFrames();
            break;
          case SerialStudio::StartDelimiterOnly:
            readStartDelimitedFrames();
            break;
          case SerialStudio::StartAndEndDelimiter:
            readStartEndDelimitedFrames();
            break;
          default:
            break;
        }
        break;
      default:
        break;
    }