popcon::PopCon Class Reference

#include <PopCon.h>

Public Types
typedef cond::Time_t	Time_t

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

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

Private Attributes
std::string	m_authPath
int	m_authSys
bool	m_close
edm::Service< cond::service::PoolDBOutputService >	m_dbService
Time_t	m_lastTill
cond::LogDBEntry_t	m_logDBEntry
bool	m_LoggingOn
std::string	m_payload_name
std::string	m_record
std::string	m_tag
cond::TagInfo_t	m_tagInfo
std::string	m_targetConnectionString
cond::persistency::Session	m_targetSession

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

Detailed Description

Definition at line 29 of file PopCon.h.

Member Typedef Documentation

Time_t

typedef cond::Time_t popcon::PopCon::Time_t

Definition at line 31 of file PopCon.h.

Constructor & Destructor Documentation

PopCon()

popcon::PopCon::PopCon

(

const edm::ParameterSet &

pset

)

Definition at line 12 of file PopCon.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_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::PopCon::~PopCon ( )

virtual

Definition at line 29 of file PopCon.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::PopCon::finalize ( Time_t  lastTill )

private

Definition at line 73 of file PopCon.cc.

References cond::service::PoolDBOutputService::closeIOV(), cond::persistency::Transaction::commit(), cond::service::PoolDBOutputService::commitTransaction(), m_close, m_dbService, m_lastTill, m_record, m_targetConnectionString, m_targetSession, and cond::persistency::Session::transaction().

Referenced by write().

                                       {
    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();
    }
  }

initialize()

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

private

Definition at line 35 of file PopCon.cc.

References cond::persistency::ConnectionPool::configure(), cond::persistency::Session::connectionString(), cond::persistency::ConnectionPool::createSession(), Exception, cond::persistency::Session::existsDatabase(), cond::persistency::Session::existsIov(), cond::service::PoolDBOutputService::forceInit(), cond::persistency::IOVProxy::getLast(), edm::Service< T >::isAvailable(), cond::TagInfo_t::lastInterval, m_authPath, m_authSys, m_dbService, m_payload_name, m_record, m_tag, 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(), cond::Iov_t::till, and cond::persistency::Session::transaction().

Referenced by write().

                                            {
    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;
  }

write()

template<typename Source >

void popcon::PopCon::write

(

Source const &

source

)

Definition at line 75 of file PopCon.h.

References finalize(), dqmdumpme::first, initialize(), m_dbService, m_logDBEntry, m_LoggingOn, m_record, m_tagInfo, mps_check::msg, runTheMatrix::ret, alignCSCRings::s, s_version, cond::service::PoolDBOutputService::setLogHeaderForRecord(), source, AlCaHLTBitMon_QueryRunRegistry::string, and cond::service::PoolDBOutputService::writeMany().

Referenced by SiStripPopConDQMEDHarvester< SourceHandler >::dqmEndJob(), pkg.AbstractPkg::generate(), ExTestEcalChannelStatusAnalyzer::write(), HcalSiPMCharacteristicsPopConAnalyzer::write(), HcalSiPMParametersPopConAnalyzer::write(), HcalTPChannelParametersPopConAnalyzer::write(), HcalTPParametersPopConAnalyzer::write(), HcalFrontEndMapPopConAnalyzer::write(), CastorPedestalWidthsPopConAnalyzer::write(), HcalTimeCorrsPopConAnalyzer::write(), HcalFlagHFDigiTimeParamsPopConAnalyzer::write(), HcalValidationCorrsPopConAnalyzer::write(), HcalL1TriggerObjectsPopConAnalyzer::write(), HcalRecoParamsPopConAnalyzer::write(), HcalQIETypesPopConAnalyzer::write(), HcalQIEDataPopConAnalyzer::write(), HcalPFCorrsPopConAnalyzer::write(), HcalPedestalWidthsPopConAnalyzer::write(), HcalPedestalsPopConAnalyzer::write(), HcalMCParamsPopConAnalyzer::write(), HcalElectronicsMapPopConAnalyzer::write(), HcalLUTCorrsPopConAnalyzer::write(), HcalLongRecoParamsPopConAnalyzer::write(), CastorElectronicsMapPopConAnalyzer::write(), HcalGainWidthsPopConAnalyzer::write(), HcalZSThresholdsPopConAnalyzer::write(), HcalTimingParamsPopConAnalyzer::write(), HcalRespCorrsPopConAnalyzer::write(), CastorChannelQualityPopConAnalyzer::write(), HcalDcsValuesPopConAnalyzer::write(), HcalDcsMapPopConAnalyzer::write(), HcalChannelQualityPopConAnalyzer::write(), HcalLutMetadataPopConAnalyzer::write(), CastorRecoParamsPopConAnalyzer::write(), CastorQIEDataPopConAnalyzer::write(), CastorPedestalsPopConAnalyzer::write(), HcalGainsPopConAnalyzer::write(), CastorGainWidthsPopConAnalyzer::write(), CastorSaturationCorrsPopConAnalyzer::write(), CastorGainsPopConAnalyzer::write(), HcalZDCLowGainFractionsPopConAnalyzer::write(), popcon::PopConAnalyzer< HcalTPParametersHandler >::write(), and querying.connection::write_and_commit().

                                         {
    typedef typename Source::value_type value_type;
    typedef typename Source::Container Container;

    std::pair<Container const*, std::string const> ret = source(initialize(), m_tagInfo, m_logDBEntry);
    Container const& iovs = *ret.first;

    if (m_LoggingOn) {
      std::string msg("Nothing to transfer;");
      size_t niovs = iovs.size();
      if (niovs) {
        std::ostringstream s;
        if (niovs == 1) {
          s << "Since " << (*iovs.begin()).first << "; ";
        } else {
          s << "first payload Since " << (*iovs.begin()).first << ", "
            << "last payload Since " << (*iovs.rbegin()).first << "; ";
        }
        msg = s.str();
      }
      std::ostringstream s;
      s << "PopCon v" << s_version << "; " << msg << ret.second;
      m_dbService->setLogHeaderForRecord(m_record, source.id(), s.str());
    }
    for (const auto& it : iovs)
      edm::LogInfo("PopCon") << "Since " << it.first << std::endl;

    m_dbService->writeMany(iovs, m_record);

    finalize(iovs.empty() ? Time_t(0) : iovs.rbegin()->first);
  }

Member Data Documentation

m_authPath

std::string popcon::PopCon::m_authPath

private

Definition at line 51 of file PopCon.h.

Referenced by initialize().

m_authSys

int popcon::PopCon::m_authSys

private

Definition at line 53 of file PopCon.h.

Referenced by initialize().

m_close

bool popcon::PopCon::m_close

private

Definition at line 67 of file PopCon.h.

Referenced by finalize().

m_dbService

edm::Service<cond::service::PoolDBOutputService> popcon::PopCon::m_dbService

private

Definition at line 45 of file PopCon.h.

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

m_lastTill

Time_t popcon::PopCon::m_lastTill

private

Definition at line 69 of file PopCon.h.

Referenced by finalize().

m_logDBEntry

cond::LogDBEntry_t popcon::PopCon::m_logDBEntry

private

Definition at line 65 of file PopCon.h.

Referenced by write().

m_LoggingOn

bool popcon::PopCon::m_LoggingOn

private

Definition at line 59 of file PopCon.h.

Referenced by write().

m_payload_name

std::string popcon::PopCon::m_payload_name

private

Definition at line 57 of file PopCon.h.

Referenced by initialize().

m_record

std::string popcon::PopCon::m_record

private

Definition at line 55 of file PopCon.h.

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

m_tag

std::string popcon::PopCon::m_tag

private

Definition at line 61 of file PopCon.h.

Referenced by initialize().

m_tagInfo

cond::TagInfo_t popcon::PopCon::m_tagInfo

private

Definition at line 63 of file PopCon.h.

Referenced by initialize(), and write().

m_targetConnectionString

std::string popcon::PopCon::m_targetConnectionString

private

Definition at line 49 of file PopCon.h.

Referenced by finalize(), initialize(), and ~PopCon().

m_targetSession

cond::persistency::Session popcon::PopCon::m_targetSession

private

Definition at line 47 of file PopCon.h.

Referenced by finalize(), initialize(), and ~PopCon().

s_version

constexpr const char *const popcon::PopCon::s_version = "5.0"

staticprivate

Definition at line 71 of file PopCon.h.

Referenced by PopCon(), and write().