Method WorkThread

lib/mdflib/mdflib/src/writecache.cpp:102–146

}

void WriteCache::WorkThread() {
  do {
    std::unique_lock lock(locker_);
    sample_event_.wait_for(lock, 10s,
                           [&]() -> bool { return stop_thread_.load(); });
    if (stop_thread_) {
      break;
    }
    for (auto& [channel_group, sample_queue] : cache_) {
      if (!sample_queue) {
        continue;
      }

      switch (writer_.State()) {
        case WriteState::Init: {
          sample_queue->TrimQueue();  // Purge the queue using pre-trig time
            break;
        }
        case WriteState::StartMeas: {
          if (writer_.IsSavePeriodic()) {
            sample_queue->SaveQueue(lock);  // Save the contents of the queue to file
          }
          break;
        }

        case WriteState::StopMeas: {
          sample_queue->CleanQueue(lock);
          break;
        }

        default:
          sample_queue->Reset();
          break;
      }
    }
  } while (!stop_thread_);
  {
    std::unique_lock lock(locker_);
    for (auto& [channel_group, sample_queue] : cache_) {
      if (sample_queue) {
        sample_queue->CleanQueue(lock);
      }
    }
  }
}

void WriteCache::RecalculateTimeMaster() {
  for (auto& [data_group, sample_queue] : cache_) {