Inheritance diagram for BeamSpotRcdPrinter:

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

	BeamSpotRcdPrinter (const edm::ParameterSet &iConfig)

void	endJob () override

	~BeamSpotRcdPrinter () override

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

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

bool	wantsGlobalLuminosityBlocks () const final

bool	wantsGlobalRuns () 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 &&)=default

	EDConsumerBase (EDConsumerBase const &)=delete

ESProxyIndex const *	esGetTokenIndices (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::vector< ModuleDescription const * > &modules, ProductRegistry const &preg, std::map< std::string, ModuleDescription const * > const &labelsToDesc, std::string const &processName) const

EDConsumerBase &	operator= (EDConsumerBase &&)=default

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

bool	registeredToConsume (ProductResolverIndex, bool, BranchType) const

bool	registeredToConsumeMany (TypeID const &, BranchType) const

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::string	m_condDb

cond::persistency::ConnectionPool	m_connectionPool

unsigned long long	m_endTime

std::string	m_output

unsigned long long	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
EDGetToken	consumes (const TypeToGet &id, edm::InputTag const &tag)

template<typename ProductType , BranchType B = InEvent>
EDGetTokenT< ProductType >	consumes (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)

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

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

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

Detailed Description

Definition at line 34 of file BeamSpotRcdPrinter.cc.

Constructor & Destructor Documentation

◆ BeamSpotRcdPrinter()

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

explicit

Definition at line 54 of file BeamSpotRcdPrinter.cc.

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

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

◆ ~BeamSpotRcdPrinter()

BeamSpotRcdPrinter::~BeamSpotRcdPrinter ( )

override

Definition at line 65 of file BeamSpotRcdPrinter.cc.

65 {}

Member Function Documentation

◆ analyze()

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

overridevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 67 of file BeamSpotRcdPrinter.cc.

                                                                                    {
   cond::Time_t startIov = m_startTime;
   cond::Time_t endIov = m_endTime;
   if (startIov > endIov)
     throw cms::Exception("endTime must be greater than startTime!");
   edm::LogInfo("BeamSpotRcdPrinter") << "[BeamSpotRcdPrinter::" << __func__ << "] "
                                      << "Set start time " << startIov << "\n ... Set end time " << endIov;
  
   // open db session
   edm::LogInfo("BeamSpotRcdPrinter") << "[BeamSpotRcdPrinter::" << __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("BeamSpotRcdPrinter") << "[BeamSpotRcdPrinter::" << __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<BeamSpotObjects>((*iiov).payloadId);
     auto runLS = BSPrintUtils::unpack((*iiov).since);
     // print IOVs summary
     ss << runLS.first << "," << runLS.second << " (" << (*iiov).since << ")"
        << " [hash: " << (*iiov).payloadId << "] \n"
        << *payload << std::endl;
  
     ++iiov;
     ++niov;
   }
  
   vTime.push_back(endIov);  // used to compute last IOV duration
  
   edm::LogInfo("BeamSpotRcdPrinter") << "[BeamSpotRcdPrinter::" << __func__ << "] "
                                      << "Read " << niov << " IOVs from tag " << m_tagName
                                      << " corresponding to the specified time interval.\n\n"
                                      << ss.str();
  
   condDbSession.transaction().commit();
  
   if (!m_output.empty()) {
     std::ofstream fout;
     fout.open(m_output);
     fout << ss.str();
     fout.close();
   }
 }

◆ endJob()

void BeamSpotRcdPrinter::endJob ( void )

overridevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 147 of file BeamSpotRcdPrinter.cc.

147 {}

◆ fillDescriptions()

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

static

Definition at line 128 of file BeamSpotRcdPrinter.cc.

                                                                                     {
   edm::ParameterSetDescription desc;
   desc.add<std::string>("conditionDatabase", "frontier://FrontierProd/CMS_CONDITIONS");
   desc.add<std::string>("tagName", "BeamSpotObjects_PCL_byLumi_v0_prompt");
   desc.add<unsigned long long>("startIOV", 1406859487478481);
   desc.add<unsigned long long>("endIOV", 1406876667347162);
   desc.add<std::string>("output", "summary.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("BeamSpotRcdPrinter", desc);
 }

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

Member Data Documentation

◆ m_condDb

std::string BeamSpotRcdPrinter::m_condDb

private

Definition at line 44 of file BeamSpotRcdPrinter.cc.

Referenced by analyze().

◆ m_connectionPool

cond::persistency::ConnectionPool BeamSpotRcdPrinter::m_connectionPool

private

Definition at line 43 of file BeamSpotRcdPrinter.cc.

Referenced by analyze(), and BeamSpotRcdPrinter().

◆ m_endTime

unsigned long long BeamSpotRcdPrinter::m_endTime

private

Definition at line 49 of file BeamSpotRcdPrinter.cc.

Referenced by analyze().

◆ m_output

std::string BeamSpotRcdPrinter::m_output

private

Definition at line 51 of file BeamSpotRcdPrinter.cc.

Referenced by analyze().

◆ m_startTime

unsigned long long BeamSpotRcdPrinter::m_startTime

private

Definition at line 48 of file BeamSpotRcdPrinter.cc.

Referenced by analyze().

◆ m_tagName

std::string BeamSpotRcdPrinter::m_tagName

private

Definition at line 45 of file BeamSpotRcdPrinter.cc.

Referenced by analyze().

Public Member Functions

Static Public Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

◆ BeamSpotRcdPrinter()

◆ ~BeamSpotRcdPrinter()

Member Function Documentation

◆ analyze()

◆ endJob()

◆ fillDescriptions()

Member Data Documentation

◆ m_condDb

◆ m_connectionPool

◆ m_endTime

◆ m_output

◆ m_startTime

◆ m_tagName