Method SaveQueue

lib/mdflib/mdflib/src/convertersamplequeue.cpp:31–125

}

void ConverterSampleQueue::SaveQueue(std::unique_lock<std::mutex>& lock) {
  if (writer_.CompressData()) {
    SaveQueueCompressed(lock);
    return;
  }
  auto* dg4 = dynamic_cast<Dg4Block*>(&data_group_);
  if (dg4 == nullptr) {
    return;
  }

  lock.unlock(); // OK to add samples to the queue
  // Save uncompressed data in last DG/DT block

  // File should be open at this point
  if (!IsOpen()) {
    lock.lock();
    return;
  }
  if (dg4->FilePosition() <= 0) {
    dg4->Write(*writer_.file_); // Flush out data
  }

  auto* dt4 = dg4->CreateOrGetDt4(*writer_.file_);
  if (dt4 == nullptr) {
    return;
  }

  SetLastPosition(*writer_.file_);

  const auto id_size = dg4->RecordIdSize();

  lock.lock(); // Lock the sample queue while flushing out to file

  while (!IsEmpty() ) {
    // Write all samples last to file
    SampleRecord sample = GetSample();

    auto* cg4 = dg4->FindCgRecordId(sample.record_id);
    if (cg4 == nullptr) {
      continue;
    }
    lock.unlock();

    auto* vlsd_group = sample.vlsd_data ?
                                        dg4->FindCgRecordId(sample.record_id + 1) : nullptr;
    // The next group must have the VLSD flag set otherwise it's not a VLSD group.
    if (vlsd_group != nullptr && (vlsd_group->Flags() & CgFlag::VlsdChannel) == 0) {
      vlsd_group = nullptr;
    }
    auto* cn4 = sample.vlsd_data && vlsd_group == nullptr ?
                                                          cg4->FindSdChannel() : nullptr;
    // If the sample holds VLSD data, save this data first and then update
    // the data index. VLSD data is stored in SD or CG. A dirty trick is that
    // the VLSD CG must have the next record_id
    if (vlsd_group != nullptr) {
      // Store as a VLSD record
      const auto vlsd_index = vlsd_group->WriteVlsdSample(*writer_.file_, id_size,
                                                          sample.vlsd_buffer);