CondCore/PopCon/src/PopCon.cc - master - githubmirror/cmssw

CondCore/PopCon/src/PopCon.cc
87 строк4 KB
Giacomo Govi
Fixes for PopCon transactions
09 дек 2021, 12:08
09 дек 2021, 12:087448d37
#include "CondCore/PopCon/interface/PopCon.h"
#include "CondCore/PopCon/interface/Exception.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "CondCore/CondDB/interface/ConnectionPool.h"
#include <iostream>

namespace popcon {

  constexpr const char* const PopCon::s_version;

  PopCon::PopCon(const edm::ParameterSet& pset)
      : m_targetSession(),
        m_targetConnectionString(pset.getUntrackedParameter<std::string>("targetDBConnectionString", "")),
        m_authPath(pset.getUntrackedParameter<std::string>("authenticationPath", "")),
        m_authSys(pset.getUntrackedParameter<int>("authenticationSystem", 1)),
        m_record(pset.getParameter<std::string>("record")),
        m_payload_name(pset.getUntrackedParameter<std::string>("name", "")),
        m_LoggingOn(pset.getUntrackedParameter<bool>("loggingOn", true)),
        m_close(pset.getUntrackedParameter<bool>("closeIOV", false)),
        m_lastTill(pset.getUntrackedParameter<bool>("lastTill", false)) {
    //TODO set the policy (cfg or global configuration?)
    //Policy if corrupted data found

    edm::LogInfo("PopCon") << "This is PopCon (Populator of Condition) v" << s_version << ".\n"
                           << "Please report any problem and feature request through the JIRA project CMSCONDDB.\n";
  }

  PopCon::~PopCon() {
    if (!m_targetConnectionString.empty()) {
      m_targetSession.transaction().commit();
    }
  }

  cond::persistency::Session PopCon::initialize() {
    edm::LogInfo("PopCon") << "payload name " << m_payload_name << std::endl;
    if (!m_dbService.isAvailable())
      throw Exception("DBService not available");
    const std::string& connectionStr = m_dbService->session().connectionString();
    m_dbService->forceInit();
    m_tag = m_dbService->tag(m_record);
    m_tagInfo.name = m_tag;
    if (m_targetConnectionString.empty()) {
      m_targetSession = m_dbService->session();
      m_dbService->startTransaction();
    } else {
      cond::persistency::ConnectionPool connPool;
      connPool.setAuthenticationPath(m_authPath);
      connPool.setAuthenticationSystem(m_authSys);
      connPool.configure();
      m_targetSession = connPool.createSession(m_targetConnectionString);
      m_targetSession.transaction().start();
    }
    if (m_targetSession.existsDatabase() && m_targetSession.existsIov(m_tag)) {
      cond::persistency::IOVProxy iov = m_targetSession.readIov(m_tag);
      m_tagInfo.size = iov.sequenceSize();
      if (m_tagInfo.size > 0) {
        m_tagInfo.lastInterval = iov.getLast();
      }
      edm::LogInfo("PopCon") << "destination DB: " << connectionStr << ", target DB: "
                             << (m_targetConnectionString.empty() ? connectionStr : m_targetConnectionString) << "\n"
                             << "TAG: " << m_tag << ", last since/till: " << m_tagInfo.lastInterval.since << "/"
                             << m_tagInfo.lastInterval.till << ", size: " << m_tagInfo.size << "\n"
                             << std::endl;
    } else {
      edm::LogInfo("PopCon") << "destination DB: " << connectionStr << ", target DB: "
                             << (m_targetConnectionString.empty() ? connectionStr : m_targetConnectionString) << "\n"
                             << "TAG: " << m_tag << "; First writer to this new tag." << std::endl;
    }
    return m_targetSession;
  }

  void PopCon::finalize(Time_t lastTill) {
    if (m_close) {
      // avoid to close it before lastSince
      if (m_lastTill > lastTill)
        lastTill = m_lastTill;
      m_dbService->closeIOV(lastTill, m_record);
    }
    if (m_targetConnectionString.empty()) {
      m_dbService->commitTransaction();
    } else {
      m_targetSession.transaction().commit();
    }
  }

}  // namespace popcon