CMS 3D CMS Logo

 All Classes Namespaces Files Functions Variables Typedefs Enumerations Enumerator Properties Friends Macros Pages
List of all members | Public Types | Public Member Functions | Private Member Functions | Private Attributes
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

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.

10  :
12  m_targetConnectionString(pset.getUntrackedParameter< std::string >("targetDBConnectionString","")),
13  m_authPath( pset.getUntrackedParameter<std::string>("authenticationPath","")),
14  m_authSys( pset.getUntrackedParameter<int>("authenticationSystem",1)),
15  m_record(pset.getParameter<std::string> ("record")),
17  m_LoggingOn(pset.getUntrackedParameter< bool > ("loggingOn",true)),
18  m_IsDestDbCheckedInQueryLog( pset.getUntrackedParameter< bool >("IsDestDbCheckedInQueryLog",true)),
19  m_close(pset.getUntrackedParameter< bool > ("closeIOV",false)),
20  m_lastTill(pset.getUntrackedParameter< bool > ("lastTill",0))
21  {
22  //TODO set the policy (cfg or global configuration?)
23  //Policy if corrupted data found
24 
25  edm::LogInfo ("PopCon") << "This is PopCon (Populator of Condition) V4.0\n"
26  << "Please report any problem and feature request through the savannah portal under the category conditions\n" ;
27  }
T getParameter(std::string const &) const
T getUntrackedParameter(std::string const &, T const &) const
Time_t m_lastTill
Definition: PopCon.h:85
bool m_close
Definition: PopCon.h:84
std::string m_record
Definition: PopCon.h:70
cond::persistency::Session m_targetSession
Definition: PopCon.h:62
std::string m_targetConnectionString
Definition: PopCon.h:64
bool m_IsDestDbCheckedInQueryLog
Definition: PopCon.h:76
int m_authSys
Definition: PopCon.h:68
std::string m_authPath
Definition: PopCon.h:66
std::string m_payload_name
Definition: PopCon.h:72
bool m_LoggingOn
Definition: PopCon.h:74
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().

29  {
30  if( !m_targetConnectionString.empty() ) {
32  }
33  }
Transaction & transaction()
Definition: Session.cc:66
cond::persistency::Session m_targetSession
Definition: PopCon.h:62
std::string m_targetConnectionString
Definition: PopCon.h:64

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

85  {
86 
87  if (m_close) {
88  // avoid to close it before lastSince
89  if (m_lastTill>lastTill) lastTill=m_lastTill;
90  m_dbService->closeIOV(lastTill,m_record);
91  }
92  if( !m_targetConnectionString.empty() ) {
94  }
95  }
void closeIOV(Time_t lastTill, const std::string &recordName, bool withlogging=false)
Time_t m_lastTill
Definition: PopCon.h:85
bool m_close
Definition: PopCon.h:84
std::string m_record
Definition: PopCon.h:70
Transaction & transaction()
Definition: Session.cc:66
cond::persistency::Session m_targetSession
Definition: PopCon.h:62
std::string m_targetConnectionString
Definition: PopCon.h:64
edm::Service< cond::service::PoolDBOutputService > m_dbService
Definition: PopCon.h:60
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().

36  {
37  edm::LogInfo ("PopCon")<<"payload name "<<m_payload_name<<std::endl;
38  if(!m_dbService.isAvailable() ) throw Exception("DBService not available");
39  const std::string & connectionStr = m_dbService->session().connectionString();
43  else {
47  connPool.configure();
50  }
54  m_tagInfo.size = iov.sequenceSize();
55  if( m_tagInfo.size>0 ){
56  cond::Iov_t last = iov.getLast();
59  }
60 
63  std::cout <<" ------ log info searched in the same db: "<< connectionStr << "------" <<std::endl;
64  } else {
66  std::cout <<" ------ log info found in another db "<< "------" <<std::endl;
67  }
68 
69  edm::LogInfo ("PopCon") << "DB: " << connectionStr << "\n"
70  << "TAG: " << m_tag
71  << ", last since/till: " << m_tagInfo.lastInterval.first
72  << "/" << m_tagInfo.lastInterval.second
73  << ", , size: " << m_tagInfo.size << "\n"
74  << "Last writer: " << m_logDBEntry.provenance
75  << ", size: " << m_logDBEntry.payloadIdx+1 << std::endl;
76  } else {
77  edm::LogInfo ("PopCon") << "DB: " << connectionStr << "\n"
78  << "TAG: " << m_tag
79  << "; First writer to this new tag." << std::endl;
80  }
81  return m_targetSession;
82  }
cond::LogDBEntry m_logDBEntry
Definition: PopCon.h:82
unsigned int payloadIdx
Definition: LogDBEntry.h:23
void start(bool readOnly=true)
Definition: Session.cc:22
cond::persistency::Session session() const
Time_t since
Definition: Types.h:56
size_t size
Definition: Types.h:77
std::pair< Time_t, Time_t > ValidityInterval
Definition: Time.h:19
std::string m_tag
Definition: PopCon.h:78
std::string m_record
Definition: PopCon.h:70
Transaction & transaction()
Definition: Session.cc:66
std::string tag(const std::string &recordName)
cond::persistency::Session m_targetSession
Definition: PopCon.h:62
std::string name
Definition: Types.h:73
cond::ValidityInterval lastInterval
Definition: Types.h:75
IOVProxy readIov(const std::string &tag, bool full=false)
Definition: Session.cc:81
tuple iov
Definition: o2o.py:307
void setAuthenticationSystem(int authSysCode)
Session createSession(const std::string &connectionString, bool writeCapable=false, BackendType backType=DEFAULT_DB)
bool isAvailable() const
Definition: Service.h:46
Hash payloadId
Definition: Types.h:58
std::string m_targetConnectionString
Definition: PopCon.h:64
cond::TagInfo_t m_tagInfo
Definition: PopCon.h:80
std::string connectionString()
Definition: Session.cc:268
bool m_IsDestDbCheckedInQueryLog
Definition: PopCon.h:76
int m_authSys
Definition: PopCon.h:68
std::string lastPayloadToken
Definition: Types.h:76
bool existsIov(const std::string &tag)
Definition: Session.cc:97
std::string provenance
Definition: LogDBEntry.h:19
std::string m_authPath
Definition: PopCon.h:66
void LookupLastEntryByTag(const std::string &iovtag, LogDBEntry &logentry, bool filterFailedOp=true) const
Definition: Logger.cc:289
tuple cout
Definition: gather_cfg.py:121
void setAuthenticationPath(const std::string &p)
std::string m_payload_name
Definition: PopCon.h:72
const cond::Logger & queryLog() const
edm::Service< cond::service::PoolDBOutputService > m_dbService
Definition: PopCon.h:60
Time_t till
Definition: Types.h:57
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().

125  {
126  typedef typename Source::value_type value_type;
127  typedef typename Source::Container Container;
128 
129  std::pair<Container const *, std::string const> ret = source(initialize(),
131  Container const & payloads = *ret.first;
132 
133  if(m_LoggingOn)
134  m_dbService->setLogHeaderForRecord(m_record,source.id(),"PopCon v4.0; " +
135  displayIovHelper(payloads) + ret.second);
136  //m_dbService->setLogHeaderForRecord(m_record,source.id(),"PopCon v4.0; " +
137  // cond::userInfo() + displayIovHelper(payloads) + ret.second);
138 
139  displayHelper(payloads);
140 
141  std::for_each(payloads.begin(),payloads.end(),
142  boost::bind(&popcon::PopCon::writeOne<value_type>,this,
143  boost::bind(&Container::value_type::payload,_1),
144  boost::bind(&Container::value_type::time,_1)
145  )
146  );
147 
148 
149  finalize(payloads.empty() ? Time_t(0): payloads.back().time);
150  }
cond::LogDBEntry m_logDBEntry
Definition: PopCon.h:82
void finalize(Time_t lastTill)
Definition: PopCon.cc:85
EcalChannelStatus Container
cond::Time_t Time_t
Definition: PopCon.h:37
std::string m_record
Definition: PopCon.h:70
void displayHelper(Container const &payloads)
Definition: PopCon.h:98
cond::TagInfo_t m_tagInfo
Definition: PopCon.h:80
Container::value_type value_type
void setLogHeaderForRecord(const std::string &recordName, const std::string &provenance, const std::string &usertext)
cond::persistency::Session initialize()
Definition: PopCon.cc:36
const std::string displayIovHelper(Container const &payloads)
Definition: PopCon.h:106
static std::string const source
Definition: EdmProvDump.cc:42
edm::Service< cond::service::PoolDBOutputService > m_dbService
Definition: PopCon.h:60
bool m_LoggingOn
Definition: PopCon.h:74
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().

92  {
94  }
std::string m_record
Definition: PopCon.h:70
void writeOne(T *payload, Time_t time, const std::string &recordName, bool withlogging=false)
edm::Service< cond::service::PoolDBOutputService > m_dbService
Definition: PopCon.h:60
bool m_LoggingOn
Definition: PopCon.h:74

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