Function lockWriteEngines

pj_datastore/src/plugin_data_host.cpp:232–240

};

[[nodiscard]] inline WriteEngineLocks lockWriteEngines(DataEngine& live, DataEngine* staging) {
  if (staging == nullptr) {
    return {live.lockEngine(), {}};
  }
  auto live_lock = live.lockEngineDeferred();
  auto staging_lock = staging->lockEngineDeferred();
  std::lock(live_lock, staging_lock);
  return {std::move(live_lock), std::move(staging_lock)};
}

struct WriteCore {
  explicit WriteCore(DataEngine& data_engine) : engine(data_engine), writer(data_engine.createWriter()) {}