Inheritance diagram for SiStripDetVOffPrinter:

Public Member Functions
void	analyze (const edm::Event &evt, const edm::EventSetup &evtSetup) override

void	endJob () override

	SiStripDetVOffPrinter (const edm::ParameterSet &iConfig)

	~SiStripDetVOffPrinter () override

Public Member Functions inherited from edm::one::EDAnalyzer<>
	EDAnalyzer ()=default

	EDAnalyzer (const EDAnalyzer &)=delete

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

const EDAnalyzer &	operator= (const EDAnalyzer &)=delete

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () const final

bool	wantsInputProcessBlocks () const final

bool	wantsProcessBlocks () const final

Public Member Functions inherited from edm::one::EDAnalyzerBase
void	callWhenNewProductsRegistered (std::function< void(BranchDescription const &)> const &func)

	EDAnalyzerBase ()

ModuleDescription const &	moduleDescription () const

bool	wantsStreamLuminosityBlocks () const

bool	wantsStreamRuns () const

	~EDAnalyzerBase () override

Public Member Functions inherited from edm::EDConsumerBase
std::vector< ConsumesInfo >	consumesInfo () const

void	convertCurrentProcessAlias (std::string const &processName)
	Convert "@currentProcess" in InputTag process names to the actual current process name. More...

	EDConsumerBase ()

	EDConsumerBase (EDConsumerBase const &)=delete

	EDConsumerBase (EDConsumerBase &&)=default

ESProxyIndex const *	esGetTokenIndices (edm::Transition iTrans) const

std::vector< ESProxyIndex > const &	esGetTokenIndicesVector (edm::Transition iTrans) const

std::vector< ESRecordIndex > const &	esGetTokenRecordIndicesVector (edm::Transition iTrans) const

ProductResolverIndexAndSkipBit	indexFrom (EDGetToken, BranchType, TypeID const &) const

void	itemsMayGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

void	itemsToGet (BranchType, std::vector< ProductResolverIndexAndSkipBit > &) const

std::vector < ProductResolverIndexAndSkipBit > const &	itemsToGetFrom (BranchType iType) const

void	labelsForToken (EDGetToken iToken, Labels &oLabels) const

void	modulesWhoseProductsAreConsumed (std::array< std::vector< ModuleDescription const * > , NumBranchTypes > &modulesAll, std::vector< ModuleProcessName > &modulesInPreviousProcesses, ProductRegistry const &preg, std::map< std::string, ModuleDescription const > const &labelsToDesc, std::string const &processName) const

EDConsumerBase const &	operator= (EDConsumerBase const &)=delete

EDConsumerBase &	operator= (EDConsumerBase &&)=default

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

void	selectInputProcessBlocks (ProductRegistry const &productRegistry, ProcessBlockHelperBase const &processBlockHelperBase)

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

void	updateLookup (BranchType iBranchType, ProductResolverIndexHelper const &, bool iPrefetchMayGet)

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &)

virtual	~EDConsumerBase () noexcept(false)

Static Public Member Functions
static void	fillDescriptions (edm::ConfigurationDescriptions &descriptions)

Static Public Member Functions inherited from edm::one::EDAnalyzerBase
static const std::string &	baseType ()

static void	fillDescriptions (ConfigurationDescriptions &descriptions)

static void	prevalidate (ConfigurationDescriptions &descriptions)

Private Attributes
std::map< uint32_t, std::vector< cond::Time_t > >	detidMap

std::map< cond::Time_t, std::set< uint32_t > >	iovMap_HVOff

std::map< cond::Time_t, std::set< uint32_t > >	iovMap_LVOff

std::string	m_condDb

cond::persistency::ConnectionPool	m_connectionPool

std::string	m_endTime

std::string	m_output

std::string	m_startTime

std::string	m_tagName

Additional Inherited Members
Public Types inherited from edm::one::EDAnalyzerBase
typedef EDAnalyzerBase	ModuleType

Public Types inherited from edm::EDConsumerBase
typedef ProductLabels	Labels

Protected Member Functions inherited from edm::EDConsumerBase
template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (edm::InputTag const &tag)

template<BranchType B = InEvent>
EDConsumerBaseAdaptor< B >	consumes (edm::InputTag tag) noexcept

EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	consumes (TypeToGet const &id, edm::InputTag const &tag)

ConsumesCollector	consumesCollector ()
	Use a ConsumesCollector to gather consumes information from helper functions. More...

template<typename ProductType , BranchType B = InEvent>
void	consumesMany ()

void	consumesMany (const TypeToGet &id)

template<BranchType B>
void	consumesMany (const TypeToGet &id)

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes ()

template<typename ESProduct , typename ESRecord , Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag const &tag)

template<Transition Tr = Transition::Event>
constexpr auto	esConsumes () noexcept

template<Transition Tr = Transition::Event>
auto	esConsumes (ESInputTag tag) noexcept

template<Transition Tr = Transition::Event>
ESGetTokenGeneric	esConsumes (eventsetup::EventSetupRecordKey const &iRecord, eventsetup::DataKey const &iKey)
	Used with EventSetupRecord::doGet. More...

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	mayConsume (edm::InputTag const &tag)

EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

template<BranchType B>
EDGetToken	mayConsume (const TypeToGet &id, edm::InputTag const &tag)

void	resetItemsToGetFrom (BranchType iType)

Detailed Description

Definition at line 25 of file SiStripDetVOffPrinter.cc.

Constructor & Destructor Documentation

SiStripDetVOffPrinter::SiStripDetVOffPrinter ( const edm::ParameterSet & iConfig )

explicit

Definition at line 51 of file SiStripDetVOffPrinter.cc.

References cond::persistency::ConnectionPool::configure(), edm::ParameterSet::getParameter(), m_connectionPool, and cond::persistency::ConnectionPool::setParameters().

     : m_connectionPool(),
       m_condDb(iConfig.getParameter<std::string>("conditionDatabase")),
       m_tagName(iConfig.getParameter<std::string>("tagName")),
       m_startTime(iConfig.getParameter<std::string>("startTime")),
       m_endTime(iConfig.getParameter<std::string>("endTime")),
       m_output(iConfig.getParameter<std::string>("output")) {
   m_connectionPool.setParameters(iConfig.getParameter<edm::ParameterSet>("DBParameters"));
   m_connectionPool.configure();
 }

SiStripDetVOffPrinter::~SiStripDetVOffPrinter ( )

overridedefault

Member Function Documentation

void SiStripDetVOffPrinter::analyze	(	const edm::Event &	evt,
		const edm::EventSetup &	evtSetup
	)

overridevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 64 of file SiStripDetVOffPrinter.cc.

References cond::persistency::Transaction::commit(), cond::persistency::ConnectionPool::createSession(), detidMap, Exception, cond::persistency::Session::fetchPayload(), spr::find(), groupFilesInBlocks::fout, cond::time::from_boost(), iovMap_HVOff, iovMap_LVOff, run_AlCaRecoTriggerBitsUpdateWorkflow::iovs, m_condDb, m_connectionPool, m_endTime, m_output, m_startTime, m_tagName, jetCorrFactors_cfi::payload, cond::persistency::Session::readIov(), cond::persistency::IOVProxy::selectAll(), contentValuesCheck::ss, cond::persistency::Transaction::start(), cond::time::to_boost(), and cond::persistency::Session::transaction().

                                                                                       {
   // use start and end time from config file
   boost::posix_time::ptime p_start, p_end;
   p_start = boost::posix_time::time_from_string(m_startTime);
   p_end = boost::posix_time::time_from_string(m_endTime);
   cond::Time_t startIov = cond::time::from_boost(p_start);
   cond::Time_t endIov = cond::time::from_boost(p_end);
   if (startIov > endIov)
     throw cms::Exception("endTime must be greater than startTime!");
   edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                                         << "Set start time " << startIov << " ("
                                         << boost::posix_time::to_simple_string(p_start) << ")"
                                         << "\n ... Set end time " << endIov << " ("
                                         << boost::posix_time::to_simple_string(p_end) << ")";
 
   // open db session
   edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                                         << "Query the condition database " << m_condDb;
   cond::persistency::Session condDbSession = m_connectionPool.createSession(m_condDb);
   condDbSession.transaction().start(true);
 
   std::stringstream ss;
   // list of times with new IOVs within the time range
   std::vector<cond::Time_t> vTime;
 
   // query the database
   edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                                         << "Reading IOVs from tag " << m_tagName;
   cond::persistency::IOVProxy iovProxy = condDbSession.readIov(m_tagName);  // load all?
   auto iovs = iovProxy.selectAll();
   auto iiov = iovs.find(startIov);
   auto eiov = iovs.find(endIov);
   int niov = 0;
   while (iiov != iovs.end() && (*iiov).since <= (*eiov).since) {
     // convert cond::Time_t to seconds since epoch
     if ((*iiov).since < startIov) {
       vTime.push_back(startIov);
     } else {
       vTime.push_back((*iiov).since);
     }
     auto payload = condDbSession.fetchPayload<SiStripDetVOff>((*iiov).payloadId);
     // print IOVs summary
     ss << boost::posix_time::to_simple_string(cond::time::to_boost((*iiov).since)) << " (" << (*iiov).since << ")"
        << ", # HV Off=" << std::setw(6) << payload->getHVoffCounts() << ", # LV Off=" << std::setw(6)
        << payload->getLVoffCounts() << std::endl;
 
     // list of detids with HV/LV Off
     std::vector<uint32_t> detIds;
     payload->getDetIds(detIds);
     std::set<uint32_t> detIds_HVOff;
     std::set<uint32_t> detIds_LVOff;
     std::vector<uint32_t>::const_iterator it = detIds.begin();
     for (; it != detIds.end(); ++it) {
       if (payload->IsModuleHVOff(*it))
         detIds_HVOff.insert(*it);
       if (payload->IsModuleLVOff(*it))
         detIds_LVOff.insert(*it);
 
       if (detidMap.find(*it) == detidMap.end()) {
         std::vector<cond::Time_t> vec;
         detidMap[*it] = vec;
       }
 
       // for each module concerned by the IOV, add the time in an history vector
       detidMap[*it].push_back(vTime.back());
     }
 
     // fill list of channels Off at a given time
     iovMap_HVOff[vTime.back()] = detIds_HVOff;
     iovMap_LVOff[vTime.back()] = detIds_LVOff;
 
     /*std::vector<uint32_t>::const_iterator it = detIds.begin();
       for( ; it!=detIds.end(); ++it ) {
       std::cout << *it << std::endl;
       }*/
 
     ++iiov;
     ++niov;
   }
   vTime.push_back(endIov);  // used to compute last IOV duration
 
   edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] "
                                         << "Read " << niov << " IOVs from tag " << m_tagName
                                         << " corresponding to the specified time interval.\n"
                                         << ss.str();
 
   // Create a map of IOVs time_duration
   std::map<cond::Time_t, boost::posix_time::time_duration> mIOVsDuration;
   std::vector<cond::Time_t>::const_iterator itTime = ++vTime.begin();
   std::vector<cond::Time_t>::const_iterator itPreviousTime = vTime.begin();
   //std::vector< cond::Time_t >::const_iterator itLastTime = --vTime.end();
   for (; itTime != vTime.end(); ++itTime) {
     mIOVsDuration[*itPreviousTime] = cond::time::to_boost(*itTime) - cond::time::to_boost(*itPreviousTime);
     itPreviousTime = itTime;
   }
   boost::posix_time::time_duration time_period =
       cond::time::to_boost(*(--vTime.end())) - cond::time::to_boost(*(vTime.begin()));
 
   // debug
   /*for( itTime=vTime.begin(); itTime!=itLastTime; ++itTime ) {
     std::cout<<boost::posix_time::to_simple_string( cond::time::to_boost(*itTime) ) << "    " <<boost::posix_time::to_simple_string(mIOVsDuration[ *itTime ])<<std::endl;
   }*/
 
   // Print summary per module
   edm::LogInfo("SiStripDetVOffPrinter") << "[SiStripDetVOffPrinter::" << __func__ << "] " << detidMap.size()
                                         << " modules were Off at some point during the time interval";
   ss.str("");
 
   // Loop over detIds
   std::map<uint32_t, std::vector<cond::Time_t> >::const_iterator itMap = detidMap.begin();
   for (; itMap != detidMap.end(); ++itMap) {
     std::vector<cond::Time_t> vecTime = itMap->second;
 
     boost::posix_time::time_duration cumul_time_HVOff(0, 0, 0, 0);
     boost::posix_time::time_duration cumul_time_LVOff(0, 0, 0, 0);
     // Loop over IOVs
     std::vector<cond::Time_t>::const_iterator itTime = vecTime.begin();
     for (; itTime != vecTime.end(); ++itTime) {
       if (iovMap_HVOff[*itTime].find(itMap->first) != iovMap_HVOff[*itTime].end())
         cumul_time_HVOff += mIOVsDuration[*itTime];
       if (iovMap_LVOff[*itTime].find(itMap->first) != iovMap_LVOff[*itTime].end())
         cumul_time_LVOff += mIOVsDuration[*itTime];
     }
     ss << "detId " << itMap->first << " #IOVs: " << vecTime.size() << "  HVOff: " << cumul_time_HVOff << " "
        << cumul_time_HVOff.total_milliseconds() * 100.0 / time_period.total_milliseconds() << "% "
        << "  LVOff: " << cumul_time_LVOff << " "
        << cumul_time_LVOff.total_milliseconds() * 100.0 / time_period.total_milliseconds() << "%" << std::endl;
   }
 
   condDbSession.transaction().commit();
 
   if (!m_output.empty()) {
     std::ofstream fout;
     fout.open(m_output);
     fout << ss.str();
     fout.close();
   }
 }

void SiStripDetVOffPrinter::endJob ( void )

overridevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 222 of file SiStripDetVOffPrinter.cc.

Referenced by o2olib.O2ORunMgr::executeJob().

222 {}

void SiStripDetVOffPrinter::fillDescriptions ( edm::ConfigurationDescriptions & descriptions )

static

Definition at line 203 of file SiStripDetVOffPrinter.cc.

References edm::ConfigurationDescriptions::add(), edm::ParameterSetDescription::add(), edm::ParameterSetDescription::addUntracked(), submitPVResolutionJobs::desc, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                        {
   edm::ParameterSetDescription desc;
   desc.add<std::string>("conditionDatabase", "frontier://FrontierProd/CMS_CONDITIONS");
   desc.add<std::string>("tagName", "SiStripDetVOff_1hourDelay_v1_Validation");
   desc.add<std::string>("startTime", "2002-01-20 23:59:59.000");
   desc.add<std::string>("endTime", "2002-01-20 23:59:59.000");
   desc.add<std::string>("output", "PerModuleSummary.txt");
   desc.add<std::string>("connect", "");
 
   edm::ParameterSetDescription descDBParameters;
   descDBParameters.addUntracked<std::string>("authenticationPath", "");
   descDBParameters.addUntracked<int>("authenticationSystem", 0);
   descDBParameters.addUntracked<std::string>("security", "");
   descDBParameters.addUntracked<int>("messageLevel", 0);
 
   desc.add<edm::ParameterSetDescription>("DBParameters", descDBParameters);
   descriptions.add("siStripDetVOffPrinter", desc);
 }

Member Data Documentation

std::map<uint32_t, std::vector<cond::Time_t> > SiStripDetVOffPrinter::detidMap

private

Definition at line 48 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::map<cond::Time_t, std::set<uint32_t> > SiStripDetVOffPrinter::iovMap_HVOff

private

Definition at line 45 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::map<cond::Time_t, std::set<uint32_t> > SiStripDetVOffPrinter::iovMap_LVOff

private

Definition at line 46 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_condDb

private

Definition at line 35 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

cond::persistency::ConnectionPool SiStripDetVOffPrinter::m_connectionPool

private

Definition at line 34 of file SiStripDetVOffPrinter.cc.

Referenced by analyze(), and SiStripDetVOffPrinter().

std::string SiStripDetVOffPrinter::m_endTime

private

Definition at line 40 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_output

private

Definition at line 42 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_startTime

private

Definition at line 39 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

std::string SiStripDetVOffPrinter::m_tagName

private

Definition at line 36 of file SiStripDetVOffPrinter.cc.

Referenced by analyze().

Public Member Functions

Static Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation