Method writeRawBytes

app/src/Sessions/Export.cpp:487–521

* @brief Drains the raw bytes queue and writes entries to the database. */

 * @brief Drains the raw bytes queue and writes entries to the database.
 */
void Sessions::ExportWorker::writeRawBytes()
{
  Q_ASSERT(m_dbOpen);

  if (!m_db || !m_rawBytesQuery) [[unlikely]]
    return;

  constexpr size_t kMaxRawBatch = 1000;
  TimestampedRawBytes entry;
  size_t count = 0;

  m_db->transaction();
  while (count < kMaxRawBatch && m_rawQueue->try_dequeue(entry)) {
    const auto elapsed = entry.data->timestamp - m_steadyBaseline;
    qint64 ns          = std::chrono::duration_cast<std::chrono::nanoseconds>(elapsed).count();

    if (ns < 0) [[unlikely]]
      ns = 0;
    if (ns <= m_lastRawBytesNs)
      ns = m_lastRawBytesNs + 1;

    m_lastRawBytesNs = ns;

    m_rawBytesQuery->bindValue(0, m_sessionId);
    m_rawBytesQuery->bindValue(1, ns);
    m_rawBytesQuery->bindValue(2, entry.deviceId);
    m_rawBytesQuery->bindValue(3, entry.data ? entry.data->data : QByteArray());

    if (!m_rawBytesQuery->exec()) [[unlikely]]
      qWarning() << "[SQLite] Insert raw_bytes failed:" << m_rawBytesQuery->lastError().text();

    ++count;
  }
  m_db->commit();
}

/**
 * @brief Drains the table snapshot queue and writes register changes to the database.