Method flushSecondaryIntoPrimary

pj_app/src/StreamingSourceManager.cpp:246–257

}

void StreamingSourceManager::flushSecondaryIntoPrimary() {
  // Zero-copy bulk transfer: ObjectStore::flushTo moves every ObjectEntry
  // from secondary into primary by value-moving the entry (its std::variant
  // / std::any holds either a shared_ptr or a closure; both transfer with
  // their captured state intact, so no payload bytes are copied and no lazy
  // closure is invoked during the flush). Topics matched by descriptor;
  // lockstep registration in DataSourceRuntimeHost::cbEnsureParserBinding
  // guarantees compatibility. Topics stay registered on the secondary.
  if (auto result = secondary_object_store_->flushTo(session_manager_.objectStore()); !result) {
    qCWarning(lcStream) << "flushSecondaryIntoPrimary failed:" << QString::fromStdString(result.error());
  }
}

void StreamingSourceManager::startSession(const QString& plugin_id) {
  const LoadedDataSource* source_ptr = resolveStreamSource(extensions_, plugin_id);