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)
template<typename T >
void	writeOne (T *payload, Time_t time)
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 30 of file PopCon.h.

Member Typedef Documentation

Time_t

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

Definition at line 32 of file PopCon.h.

Constructor & Destructor Documentation

PopCon()

popcon::PopCon::PopCon

(

const edm::ParameterSet &

pset

)

Definition at line 12 of file PopCon.cc.

      : 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";
  }

References s_version.

~PopCon()

popcon::PopCon::~PopCon ( )

virtual

Definition at line 29 of file PopCon.cc.

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

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

Member Function Documentation

finalize()

void popcon::PopCon::finalize ( Time_t  lastTill )

private

Definition at line 73 of file PopCon.cc.

                                       {
    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_targetSession.transaction().commit();
    }
  }

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

Referenced by write().

initialize()

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

private

Definition at line 35 of file PopCon.cc.

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

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(), AlCaHLTBitMon_QueryRunRegistry::string, cond::service::PoolDBOutputService::tag(), cond::Iov_t::till, and cond::persistency::Session::transaction().

Referenced by write().

write()

template<typename Source >

void popcon::PopCon::write

(

Source const &

source

)

Definition at line 108 of file PopCon.h.

                                         {
    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& payloads = *ret.first;
 
    if (m_LoggingOn) {
      std::ostringstream s;
      s << "PopCon v" << s_version << "; " << displayIovHelper(payloads) << ret.second;
      //s << "PopCon v" << s_version << "; " << cond::userInfo() << displayIovHelper(payloads) << ret.second;
      m_dbService->setLogHeaderForRecord(m_record, source.id(), s.str());
    }
    displayHelper(payloads);
 
    std::for_each(payloads.begin(),
                  payloads.end(),
                  boost::bind(&popcon::PopCon::writeOne<value_type>,
                              this,
                              boost::bind(&Container::value_type::payload, _1),
                              boost::bind(&Container::value_type::time, _1)));
 
    finalize(payloads.empty() ? Time_t(0) : payloads.back().time);
  }

References popcon::displayHelper(), popcon::displayIovHelper(), finalize(), initialize(), m_dbService, m_logDBEntry, m_LoggingOn, m_record, m_tagInfo, jets_cff::payload, tauJetCorrections_cff::payloads, runTheMatrix::ret, alignCSCRings::s, s_version, cond::service::PoolDBOutputService::setLogHeaderForRecord(), source, and ntuplemaker::time.

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().

writeOne()

template<typename T >

void popcon::PopCon::writeOne	(	T *	payload,
		Time_t	time
	)

Definition at line 80 of file PopCon.h.

                                               {
    m_dbService->writeOne(payload, time, m_record);
  }

References m_dbService, m_record, jets_cff::payload, ntuplemaker::time, and cond::service::PoolDBOutputService::writeOne().

Member Data Documentation

m_authPath

std::string popcon::PopCon::m_authPath

private

Definition at line 56 of file PopCon.h.

Referenced by initialize().

m_authSys

int popcon::PopCon::m_authSys

private

Definition at line 58 of file PopCon.h.

Referenced by initialize().

m_close

bool popcon::PopCon::m_close

private

Definition at line 72 of file PopCon.h.

Referenced by finalize().

m_dbService

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

private

Definition at line 50 of file PopCon.h.

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

m_lastTill

Time_t popcon::PopCon::m_lastTill

private

Definition at line 74 of file PopCon.h.

Referenced by finalize().

m_logDBEntry

cond::LogDBEntry_t popcon::PopCon::m_logDBEntry

private

Definition at line 70 of file PopCon.h.

Referenced by write().

m_LoggingOn

bool popcon::PopCon::m_LoggingOn

private

Definition at line 64 of file PopCon.h.

Referenced by write().

m_payload_name

std::string popcon::PopCon::m_payload_name

private

Definition at line 62 of file PopCon.h.

Referenced by initialize().

m_record

std::string popcon::PopCon::m_record

private

Definition at line 60 of file PopCon.h.

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

m_tag

std::string popcon::PopCon::m_tag

private

Definition at line 66 of file PopCon.h.

Referenced by initialize().

m_tagInfo

cond::TagInfo_t popcon::PopCon::m_tagInfo

private

Definition at line 68 of file PopCon.h.

Referenced by initialize(), and write().

m_targetConnectionString

std::string popcon::PopCon::m_targetConnectionString

private

Definition at line 54 of file PopCon.h.

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

m_targetSession

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

private

Definition at line 52 of file PopCon.h.

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

s_version

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

staticconstexprprivate

Definition at line 76 of file PopCon.h.

Referenced by PopCon(), and write().