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
bool	m_IsDestDbCheckedInQueryLog
Time_t	m_lastTill
cond::LogDBEntry	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

Detailed Description

Definition at line 35 of file PopCon.h.

Member Typedef Documentation

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

Definition at line 37 of file PopCon.h.

Constructor & Destructor Documentation

popcon::PopCon::PopCon

(

const edm::ParameterSet &

pset

)

Definition at line 10 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_IsDestDbCheckedInQueryLog( pset.getUntrackedParameter< bool >("IsDestDbCheckedInQueryLog",true)),
    m_close(pset.getUntrackedParameter< bool > ("closeIOV",false)),
    m_lastTill(pset.getUntrackedParameter< bool > ("lastTill",0))
    {
      //TODO set the policy (cfg or global configuration?)
      //Policy if corrupted data found
      
      edm::LogInfo ("PopCon") << "This is PopCon (Populator of Condition) V4.0\n"
                  << "Please report any problem and feature request through the savannah portal under the category conditions\n" ; 
    }

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

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

private

Definition at line 85 of file PopCon.cc.

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

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

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

private

Definition at line 36 of file PopCon.cc.

References cond::persistency::ConnectionPool::configure(), cond::persistency::Session::connectionString(), gather_cfg::cout, cond::persistency::ConnectionPool::createSession(), Exception, cond::persistency::Session::existsIov(), cond::persistency::IOVProxy::getLast(), o2o::iov, edm::Service< T >::isAvailable(), prof2calltree::last, cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, cond::Logger::LookupLastEntryByTag(), m_authPath, m_authSys, m_dbService, m_IsDestDbCheckedInQueryLog, m_logDBEntry, m_payload_name, m_record, m_tag, m_tagInfo, m_targetConnectionString, m_targetSession, cond::TagInfo_t::name, cond::Iov_t::payloadId, cond::LogDBEntry::payloadIdx, cond::LogDBEntry::provenance, cond::service::PoolDBOutputService::queryLog(), 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().

                                            {   
    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_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.existsIov( m_tag ) ){
      cond::persistency::IOVProxy iov = m_targetSession.readIov( m_tag );
      m_tagInfo.name = m_tag;
      m_tagInfo.size = iov.sequenceSize();
      if( m_tagInfo.size>0 ){
    cond::Iov_t last = iov.getLast();
    m_tagInfo.lastInterval = cond::ValidityInterval( last.since, last.till );
    m_tagInfo.lastPayloadToken = last.payloadId;
      }

      if( m_IsDestDbCheckedInQueryLog ) {
    m_dbService->queryLog().LookupLastEntryByTag( m_tag, connectionStr, m_logDBEntry );
    std::cout <<" ------ log info searched in the same db: "<< connectionStr << "------" <<std::endl;
      } else {
    m_dbService->queryLog().LookupLastEntryByTag( m_tag, m_logDBEntry );
    std::cout <<" ------ log info found in another db "<< "------" <<std::endl;
      }

      edm::LogInfo ("PopCon") << "DB: " << connectionStr << "\n"
                  << "TAG: " << m_tag 
                  << ", last since/till: " <<  m_tagInfo.lastInterval.first
                  << "/" << m_tagInfo.lastInterval.second
                  << ", , size: " << m_tagInfo.size << "\n"
                  << "Last writer: " <<  m_logDBEntry.provenance 
                  << ", size: " << m_logDBEntry.payloadIdx+1 << std::endl;
    } else {
      edm::LogInfo ("PopCon") << "DB: " << connectionStr << "\n"
                  << "TAG: " << m_tag 
                  << "; First writer to this new tag." << std::endl; 
    }
    return m_targetSession;
  }

template<typename Source >

void popcon::PopCon::write

(

Source const &

source

)

Definition at line 125 of file PopCon.h.

References popcon::displayHelper(), popcon::displayIovHelper(), finalize(), initialize(), m_dbService, m_logDBEntry, m_LoggingOn, m_record, m_tagInfo, tauJetCorrections_cff::payloads, run_regression::ret, cond::service::PoolDBOutputService::setLogHeaderForRecord(), source, and cond::rpcobgas::time.

Referenced by pkg.AbstractPkg::generate(), ExTestEcalChannelStatusAnalyzer::write(), HcalZSThresholdsPopConAnalyzer::write(), HcalFlagHFDigiTimeParamsPopConAnalyzer::write(), HcalValidationCorrsPopConAnalyzer::write(), CastorElectronicsMapPopConAnalyzer::write(), HcalDcsValuesPopConAnalyzer::write(), HcalRespCorrsPopConAnalyzer::write(), HcalRecoParamsPopConAnalyzer::write(), HcalQIEDataPopConAnalyzer::write(), HcalPFCorrsPopConAnalyzer::write(), HcalPedestalWidthsPopConAnalyzer::write(), HcalPedestalsPopConAnalyzer::write(), HcalMCParamsPopConAnalyzer::write(), HcalLutMetadataPopConAnalyzer::write(), HcalLUTCorrsPopConAnalyzer::write(), HcalLongRecoParamsPopConAnalyzer::write(), HcalL1TriggerObjectsPopConAnalyzer::write(), HcalGainWidthsPopConAnalyzer::write(), HcalGainsPopConAnalyzer::write(), CastorQIEDataPopConAnalyzer::write(), HcalTimeCorrsPopConAnalyzer::write(), HcalTimingParamsPopConAnalyzer::write(), HcalDcsMapPopConAnalyzer::write(), HcalCovarianceMatricesPopConAnalyzer::write(), HcalCholeskyMatricesPopConAnalyzer::write(), HcalChannelQualityPopConAnalyzer::write(), CastorSaturationCorrsPopConAnalyzer::write(), CastorRecoParamsPopConAnalyzer::write(), HcalElectronicsMapPopConAnalyzer::write(), CastorPedestalWidthsPopConAnalyzer::write(), CastorPedestalsPopConAnalyzer::write(), CastorGainWidthsPopConAnalyzer::write(), CastorGainsPopConAnalyzer::write(), CastorChannelQualityPopConAnalyzer::write(), HcalZDCLowGainFractionsPopConAnalyzer::write(), and popcon::PopConAnalyzer< HcalPedestalWidthsHandler >::write().

                                          {
    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)
      m_dbService->setLogHeaderForRecord(m_record,source.id(),"PopCon v4.0; " + 
                     displayIovHelper(payloads) +  ret.second);
    //m_dbService->setLogHeaderForRecord(m_record,source.id(),"PopCon v4.0; " + 
    //               cond::userInfo() + displayIovHelper(payloads) +  ret.second);
    
    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);
  }

template<typename T >

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

Definition at line 92 of file PopCon.h.

References m_dbService, m_LoggingOn, m_record, and cond::service::PoolDBOutputService::writeOne().

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

Member Data Documentation

std::string popcon::PopCon::m_authPath

private

Definition at line 66 of file PopCon.h.

Referenced by initialize().

int popcon::PopCon::m_authSys

private

Definition at line 68 of file PopCon.h.

Referenced by initialize().

bool popcon::PopCon::m_close

private

Definition at line 84 of file PopCon.h.

Referenced by finalize().

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

private

Definition at line 60 of file PopCon.h.

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

bool popcon::PopCon::m_IsDestDbCheckedInQueryLog

private

Definition at line 76 of file PopCon.h.

Referenced by initialize().

Time_t popcon::PopCon::m_lastTill

private

Definition at line 85 of file PopCon.h.

Referenced by finalize().

cond::LogDBEntry popcon::PopCon::m_logDBEntry

private

Definition at line 82 of file PopCon.h.

Referenced by initialize(), and write().

bool popcon::PopCon::m_LoggingOn

private

Definition at line 74 of file PopCon.h.

Referenced by write(), and writeOne().

std::string popcon::PopCon::m_payload_name

private

Definition at line 72 of file PopCon.h.

Referenced by initialize().

std::string popcon::PopCon::m_record

private

Definition at line 70 of file PopCon.h.

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

std::string popcon::PopCon::m_tag

private

Definition at line 78 of file PopCon.h.

Referenced by initialize().

cond::TagInfo_t popcon::PopCon::m_tagInfo

private

Definition at line 80 of file PopCon.h.

Referenced by initialize(), and write().

std::string popcon::PopCon::m_targetConnectionString

private

Definition at line 64 of file PopCon.h.

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

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

private

Definition at line 62 of file PopCon.h.

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