Method stopDatasetAndWait

pj_app/src/StreamingSourceManager.cpp:116–142

}

bool StreamingSourceManager::stopDatasetAndWait(DatasetId dataset_id, const QString& reason) {
  auto it = sessions_.find(dataset_id);
  if (it == sessions_.end()) {
    return false;
  }

  StreamingSession* sess = it->second.get();
  if (sess->runtime_host != nullptr) {
    sess->runtime_host->requestStop(reason.toStdString());
  }
  if (sess->worker != nullptr) {
    sess->worker->wait();
  }

  QString stopped_reason = reason;
  if (sess->runtime_host != nullptr && !sess->runtime_host->lastError().empty()) {
    stopped_reason = QString::fromStdString(sess->runtime_host->lastError());
  }

  sessions_.erase(it);
  for (const ObjectTopicId topic_id : secondary_object_store_->listTopics(dataset_id)) {
    secondary_object_store_->removeTopic(topic_id);
  }
  secondary_data_engine_->removeDataset(dataset_id);
  emit streamStopped(dataset_id, stopped_reason);
  return true;
}

void StreamingSourceManager::stopAllAndWait(const QString& reason) {
  std::vector<DatasetId> dataset_ids;