Method processInputBuffer

app/src/IO/Drivers/Audio.cpp:1079–1162

* @brief Converts raw audio input into CSV-formatted text and emits it; * draining the queue lock-free is safe (audio thread is the sole producer), * and the timestamp advances by frameStep * totalFrames so input jitter never * shifts the sample timeline. */

 * shifts the sample timeline.
 */
void IO::Drivers::Audio::processInputBuffer()
{
  QByteArray raw;
  QByteArray chunk;
  while (m_inputQueue.try_dequeue(chunk))
    raw.append(chunk);

  if (raw.isEmpty())
    return;

  const int channels       = m_config.capture.channels;
  const ma_format format   = m_config.capture.format;
  const int bytesPerSample = ma_get_bytes_per_sample(format);
  const int frameSize      = bytesPerSample * channels;
  if (frameSize <= 0 || channels <= 0 || raw.size() % frameSize != 0)
    return;

  const int totalFrames = raw.size() / frameSize;

  m_csvBuffer.seek(0);

  const char* ptr = raw.constData();
  for (int i = 0; i < totalFrames; ++i) {
    for (int ch = 0; ch < channels; ++ch) {
      switch (format) {
        case ma_format_u8: {
          const auto sample = static_cast<quint8>(*ptr);
          m_csvStream << static_cast<int>(sample);
          break;
        }
        case ma_format_s16: {
          const qint16 sample = qFromLittleEndian<qint16>(reinterpret_cast<const quint8*>(ptr));
          m_csvStream << sample;
          break;
        }
        case ma_format_s24: {
          const quint8* b  = reinterpret_cast<const quint8*>(ptr);
          const qint32 s24 = static_cast<qint32>(b[0]) | (static_cast<qint32>(b[1]) << 8)
                           | (static_cast<qint32>(b[2]) << 16);
          const qint32 sample = (s24 & 0x800000) ? (s24 | static_cast<qint32>(0xFF000000)) : s24;
          m_csvStream << sample;
          break;
        }
        case ma_format_s32: {
          const qint32 sample = qFromLittleEndian<qint32>(reinterpret_cast<const quint8*>(ptr));
          m_csvStream << sample;
          break;
        }
        case ma_format_f32: {
          float sample;
          std::memcpy(&sample, ptr, sizeof(float));
          m_csvStream << sample;
          break;
        }
        default:
          return;
      }