popcon::OnlinePopCon Class Reference

#include <OnlinePopCon.h>

Public Types
typedef cond::Time_t	Time_t

Public Member Functions
	OnlinePopCon (const edm::ParameterSet &pset)
template<typename Source >
void	write (Source const &source)
virtual	~OnlinePopCon ()

Private Member Functions
void	finalize ()
cond::persistency::Session	initialize ()
cond::persistency::Session	preparePopCon ()

Private Attributes
std::string	m_authPath
int	m_authSys
int	m_dbLoggerReturn_
edm::Service< cond::service::OnlineDBOutputService >	m_dbService
cond::LogDBEntry_t	m_logDBEntry
std::string	m_recordName
cond::TagInfo_t	m_tagInfo
std::string	m_targetConnectionString
cond::persistency::Session	m_targetSession
bool	m_useLockRecors

Static Private Attributes
static constexpr const char *const	s_version = "1.0"

Detailed Description

Definition at line 26 of file OnlinePopCon.h.

Member Typedef Documentation

Time_t

typedef cond::Time_t popcon::OnlinePopCon::Time_t

Definition at line 28 of file OnlinePopCon.h.

Constructor & Destructor Documentation

OnlinePopCon()

popcon::OnlinePopCon::OnlinePopCon

(

const edm::ParameterSet &

pset

)

Definition at line 12 of file OnlinePopCon.cc.

References s_version.

      : m_targetSession(),
        m_targetConnectionString(pset.getUntrackedParameter<std::string>("targetDBConnectionString", "")),
        m_authPath(pset.getUntrackedParameter<std::string>("authenticationPath", "")),
        m_authSys(pset.getUntrackedParameter<int>("authenticationSystem", 1)),
        m_recordName(pset.getParameter<std::string>("record")),
        m_useLockRecors(pset.getUntrackedParameter<bool>("useLockRecords", false)) {
    edm::LogInfo("OnlinePopCon")
        << "This is OnlinePopCon (Populator of Condition) v" << s_version << ".\n"
        << "Please report any problem and feature request through the JIRA project CMSCONDDB.\n";
  }

~OnlinePopCon()

popcon::OnlinePopCon::~OnlinePopCon ( )

virtual

Definition at line 24 of file OnlinePopCon.cc.

References cond::persistency::Transaction::commit(), m_targetConnectionString, m_targetSession, and cond::persistency::Session::transaction().

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

Member Function Documentation

finalize()

void popcon::OnlinePopCon::finalize ( )

private

Definition at line 90 of file OnlinePopCon.cc.

References cond::persistency::Transaction::commit(), cond::service::PoolDBOutputService::commitTransaction(), cond::persistency::Logger::end(), Exception, edm::Service< T >::isAvailable(), cond::service::PoolDBOutputService::logger(), cond::persistency::Logger::logInfo(), m_dbLoggerReturn_, m_dbService, m_recordName, m_targetConnectionString, m_targetSession, m_useLockRecors, cond::service::PoolDBOutputService::releaseLocks(), and cond::persistency::Session::transaction().

Referenced by write().

                              {
    // Check if DB service is available
    if (!m_dbService.isAvailable()) {
      throw Exception("OnlinePopCon", "[finalize] DBService not available");
    }

    // Release locks if previously locked
    if (m_useLockRecors) {
      m_dbService->logger().logInfo() << "OnlinePopCon::finalize - releasing locks";
      m_dbService->releaseLocks();
    }

    // Finalize PopCon infrastructure
    if (m_targetConnectionString.empty()) {
      m_dbService->commitTransaction();
    } else {
      m_targetSession.transaction().commit();
    }

    // Stop DB logging service
    m_dbService->logger().logInfo() << "OnlinePopCon::finalize - end logging for record: " << m_recordName;
    m_dbService->logger().end(m_dbLoggerReturn_);
  }

initialize()

cond::persistency::Session popcon::OnlinePopCon::initialize ( )

private

Definition at line 68 of file OnlinePopCon.cc.

References Exception, edm::Service< T >::isAvailable(), cond::service::PoolDBOutputService::lockRecords(), cond::service::PoolDBOutputService::logger(), cond::persistency::Logger::logInfo(), m_dbLoggerReturn_, m_dbService, m_recordName, m_useLockRecors, preparePopCon(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, and cond::persistency::Logger::start().

Referenced by write().

                                                  {
    // Check if DB service is available
    if (!m_dbService.isAvailable()) {
      throw Exception("OnlinePopCon", "[initialize] DBService not available");
    }

    // Start DB logging service
    m_dbLoggerReturn_ = 0;
    m_dbService->logger().start();
    m_dbService->logger().logInfo() << "OnlinePopCon::initialize - begin logging for record: " << m_recordName;

    // If requested, lock records
    if (m_useLockRecors) {
      m_dbService->logger().logInfo() << "OnlinePopCon::initialize - locking records";
      m_dbService->lockRecords();
    }

    // Prepare the rest of PopCon infrastructure
    auto session = preparePopCon();
    return session;
  }

preparePopCon()

cond::persistency::Session popcon::OnlinePopCon::preparePopCon ( )

private

Definition at line 30 of file OnlinePopCon.cc.

References cond::persistency::ConnectionPool::configure(), cond::persistency::Session::connectionString(), cond::persistency::ConnectionPool::createSession(), cond::persistency::Session::existsDatabase(), cond::persistency::Session::existsIov(), cond::service::PoolDBOutputService::forceInit(), cond::persistency::IOVProxy::getLast(), cond::TagInfo_t::lastInterval, cond::service::PoolDBOutputService::logger(), cond::persistency::Logger::logInfo(), m_authPath, m_authSys, m_dbService, m_recordName, m_tagInfo, m_targetConnectionString, m_targetSession, cond::TagInfo_t::name, cond::persistency::Session::readIov(), cond::persistency::IOVProxy::sequenceSize(), cond::service::PoolDBOutputService::session(), cond::persistency::ConnectionPool::setAuthenticationPath(), cond::persistency::ConnectionPool::setAuthenticationSystem(), cond::Iov_t::since, cond::TagInfo_t::size, cond::persistency::Transaction::start(), cond::service::PoolDBOutputService::startTransaction(), AlCaHLTBitMon_QueryRunRegistry::string, cond::service::PoolDBOutputService::tag(), dcs_print_summary_cfg::tagName, cond::Iov_t::till, and cond::persistency::Session::transaction().

Referenced by initialize().

                                                     {
    // Initialization almost identical to PopCon
    const std::string& connectionStr = m_dbService->session().connectionString();
    m_dbService->forceInit();
    std::string tagName = m_dbService->tag(m_recordName);
    m_tagInfo.name = tagName;
    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();
    }

    m_dbService->logger().logInfo() << "OnlinePopCon::preparePopCon";
    m_dbService->logger().logInfo() << "  destination DB: " << connectionStr;
    m_dbService->logger().logInfo() << "  target DB: "
                                    << (m_targetConnectionString.empty() ? connectionStr : m_targetConnectionString);

    if (m_targetSession.existsDatabase() && m_targetSession.existsIov(tagName)) {
      cond::persistency::IOVProxy iov = m_targetSession.readIov(tagName);
      m_tagInfo.size = iov.sequenceSize();
      if (m_tagInfo.size > 0) {
        m_tagInfo.lastInterval = iov.getLast();
      }
      m_dbService->logger().logInfo() << "  TAG: " << tagName << ", last since/till: " << m_tagInfo.lastInterval.since
                                      << "/" << m_tagInfo.lastInterval.till;
      m_dbService->logger().logInfo() << "  size: " << m_tagInfo.size;
    } else {
      m_dbService->logger().logInfo() << "  TAG: " << tagName << "; First writer to this new tag.";
    }
    return m_targetSession;
  }

write()

template<typename Source >

void popcon::OnlinePopCon::write

(

Source const &

source

)

Definition at line 64 of file OnlinePopCon.h.

References MillePedeFileConverter_cfg::e, cppFunctionSkipper::exception, Exception, finalize(), initialize(), run_AlCaRecoTriggerBitsUpdateWorkflow::iovs, edm::Service< T >::isAvailable(), cond::persistency::Logger::logError(), cond::service::PoolDBOutputService::logger(), cond::persistency::Logger::logInfo(), m_dbLoggerReturn_, m_dbService, m_logDBEntry, m_recordName, m_tagInfo, jetsAK4_Puppi_cff::payload, runTheMatrix::ret, source, and cond::service::OnlineDBOutputService::writeIOVForNextLumisection().

Referenced by pkg.AbstractPkg::generate(), popcon::OnlinePopConAnalyzer< S >::write(), and querying.connection::write_and_commit().

                                               {
    // Get data to be uploaded
    typedef typename Source::Container Container;
    std::pair<Container const*, std::string const> ret = source(initialize(), m_tagInfo, m_logDBEntry);
    Container const& iovs = *ret.first;

    // Check that only 1 iov/payload is provided
    if (iovs.size() > 1) {
      throw Exception("OnlinePopCon", "[write] More than one iov/payload provided!");
    }

    // If zero payloads to transfer, finalize and return
    if (iovs.empty()) {
      m_dbService->logger().logInfo() << "OnlinePopCon::write - Nothing to transfer";
      finalize();
      return;
    }

    // Upload
    // Check if DB service is available
    if (!m_dbService.isAvailable()) {
      throw Exception("OnlinePopCon", "[write] DBService not available");
    }

    // Get the only payload to transfer
    auto [originalSince, payload] = *iovs.begin();

    // Log the original since
    m_dbService->logger().logInfo() << "OnlinePopCon::write - original since: " << originalSince;

    // Upload the payload
    try {
      auto targetSince = m_dbService->writeIOVForNextLumisection(*payload, m_recordName);
      m_dbService->logger().logInfo() << "OnlinePopCon::write - writeForNextLumisection successful!";
      m_dbService->logger().logInfo() << "OnlinePopCon::write - uploaded with since: " << targetSince;
    } catch (const std::exception& e) {
      m_dbService->logger().logError() << "OnlinePopCon::write - Error writing record: " << m_recordName;
      m_dbService->logger().logError() << "Error is: " << e.what();
      m_dbLoggerReturn_ = 2;
    }

    // Finalize
    finalize();
  }

Member Data Documentation

m_authPath

std::string popcon::OnlinePopCon::m_authPath

private

Definition at line 49 of file OnlinePopCon.h.

Referenced by preparePopCon().

m_authSys

int popcon::OnlinePopCon::m_authSys

private

Definition at line 50 of file OnlinePopCon.h.

Referenced by preparePopCon().

m_dbLoggerReturn_

int popcon::OnlinePopCon::m_dbLoggerReturn_

private

Definition at line 56 of file OnlinePopCon.h.

Referenced by finalize(), initialize(), and write().

m_dbService

edm::Service<cond::service::OnlineDBOutputService> popcon::OnlinePopCon::m_dbService

private

Definition at line 44 of file OnlinePopCon.h.

Referenced by finalize(), initialize(), preparePopCon(), and write().

m_logDBEntry

cond::LogDBEntry_t popcon::OnlinePopCon::m_logDBEntry

private

Definition at line 53 of file OnlinePopCon.h.

Referenced by write().

m_recordName

std::string popcon::OnlinePopCon::m_recordName

private

Definition at line 51 of file OnlinePopCon.h.

Referenced by finalize(), initialize(), preparePopCon(), and write().

m_tagInfo

cond::TagInfo_t popcon::OnlinePopCon::m_tagInfo

private

Definition at line 52 of file OnlinePopCon.h.

Referenced by preparePopCon(), and write().

m_targetConnectionString

std::string popcon::OnlinePopCon::m_targetConnectionString

private

Definition at line 48 of file OnlinePopCon.h.

Referenced by finalize(), preparePopCon(), and ~OnlinePopCon().

m_targetSession

cond::persistency::Session popcon::OnlinePopCon::m_targetSession

private

Definition at line 47 of file OnlinePopCon.h.

Referenced by finalize(), preparePopCon(), and ~OnlinePopCon().

m_useLockRecors

bool popcon::OnlinePopCon::m_useLockRecors

private

Definition at line 57 of file OnlinePopCon.h.

Referenced by finalize(), and initialize().

s_version

constexpr const char *const popcon::OnlinePopCon::s_version = "1.0"

staticprivate

Definition at line 60 of file OnlinePopCon.h.

Referenced by OnlinePopCon().