Inheritance diagram for AlCaRecoTriggerBitsRcdRead:

Public Member Functions
	AlCaRecoTriggerBitsRcdRead (const edm::ParameterSet &cfg)

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

void	beginRun (const edm::Run &run, const edm::EventSetup &evtSetup) override

void	endJob () override

void	endRun (edm::Run const &, edm::EventSetup const &) override

	~AlCaRecoTriggerBitsRcdRead () override=default

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

	EDAnalyzer (const EDAnalyzer &)=delete

SerialTaskQueue *	globalLuminosityBlocksQueue () final

SerialTaskQueue *	globalRunsQueue () final

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

bool	wantsGlobalLuminosityBlocks () const noexcept final

bool	wantsGlobalRuns () const noexcept final

bool	wantsInputProcessBlocks () const noexcept final

bool	wantsProcessBlocks () const noexcept 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 noexcept

bool	wantsStreamRuns () const noexcept

	~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

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

std::vector< ESResolverIndex > 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

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

ProductResolverIndexAndSkipBit	uncheckedIndexFrom (EDGetToken) const

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

void	updateLookup (eventsetup::ESRecordsToProductResolverIndices 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 Types
enum	OutputType { kText, kTwiki, kPython }

Private Member Functions
void	printMap (edm::RunNumber_t firstRun, edm::RunNumber_t lastRun, const AlCaRecoTriggerBits &triggerMap) const

OutputType	stringToEnum (const std::string &outputType) const

Private Attributes
edm::RunNumber_t	firstRun_

edm::RunNumber_t	lastRun_

AlCaRecoTriggerBits	lastTriggerBits_

std::unique_ptr< std::ofstream >	output_

const OutputType	outputType_

const edm::ESGetToken< AlCaRecoTriggerBits, AlCaRecoTriggerBitsRcd >	triggerBitsToken_

edm::ESWatcher< AlCaRecoTriggerBitsRcd >	watcher_

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

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

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

Module to read trigger bit mappings (AlCaRecoTriggerBits) from DB and put out as text. Several output formats can be configured via parameter 'outputType':

simple text ('text'),
text in format of a Twiki table for cut and paste ('twiki')
or a python snippet to be inserted into configuration of the AlCaRecoTriggerBitsRcdWrite ('python').

Where to put the text is decided by parameter 'rawFileName':

if empty, use MessageLogger
otherwise open file <rawFileName>.<suffix> where the suffix is chosen to match 'outputType'.

Definition at line 40 of file AlCaRecoTriggerBitsRcdRead.cc.

Member Enumeration Documentation

◆ OutputType

enum AlCaRecoTriggerBitsRcdRead::OutputType

private

Enumerator
kText
kTwiki
kPython

Definition at line 54 of file AlCaRecoTriggerBitsRcdRead.cc.

54 { kText, kTwiki, kPython }; //kHtml};

AlCaRecoTriggerBitsRcdRead::kTwiki

Definition: AlCaRecoTriggerBitsRcdRead.cc:54

AlCaRecoTriggerBitsRcdRead::kPython

Definition: AlCaRecoTriggerBitsRcdRead.cc:54

AlCaRecoTriggerBitsRcdRead::kText

Definition: AlCaRecoTriggerBitsRcdRead.cc:54

Constructor & Destructor Documentation

◆ AlCaRecoTriggerBitsRcdRead()

AlCaRecoTriggerBitsRcdRead::AlCaRecoTriggerBitsRcdRead ( const edm::ParameterSet & cfg )

explicit

Definition at line 80 of file AlCaRecoTriggerBitsRcdRead.cc.

References looper::cfg, MillePedeFileConverter_cfg::fileName, kPython, kText, kTwiki, output_, outputType_, and AlCaHLTBitMon_QueryRunRegistry::string.

     : triggerBitsToken_(esConsumes<edm::Transition::BeginRun>()),
       outputType_(this->stringToEnum(cfg.getUntrackedParameter<std::string>("outputType"))),
       firstRun_(0),
       lastRun_(0) {
   //   edm::LogInfo("") << "@SUB=AlCaRecoTriggerBitsRcdRead"
   //           << cfg.getParameter<std::string>("@module_label");
 
   std::string fileName(cfg.getUntrackedParameter<std::string>("rawFileName"));
   switch (outputType_) {  // now append suffix
     case kText:
       fileName += ".txt";
       break;
     case kPython:
       fileName += ".py";
       break;
     case kTwiki:
       fileName += ".twiki";
       break;
   }
   if (!fileName.empty()) {
     output_ = std::make_unique<std::ofstream>(fileName.c_str());
     if (!output_->good()) {
       edm::LogError("IOproblem") << "Could not open output file " << fileName << ".";
       output_.reset();
     }
   }
 }

◆ ~AlCaRecoTriggerBitsRcdRead()

AlCaRecoTriggerBitsRcdRead::~AlCaRecoTriggerBitsRcdRead ( )

overridedefault

Member Function Documentation

◆ analyze()

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

inlineoverridevirtual

Implements edm::one::EDAnalyzerBase.

Definition at line 45 of file AlCaRecoTriggerBitsRcdRead.cc.

45 {}

◆ beginRun()

void AlCaRecoTriggerBitsRcdRead::beginRun	(	const edm::Run &	run,
		const edm::EventSetup &	evtSetup
	)

override

Definition at line 127 of file AlCaRecoTriggerBitsRcdRead.cc.

References edm::ESWatcher< T >::check(), firstRun_, edm::EventSetup::getData(), lastRun_, lastTriggerBits_, printMap(), writedatasetfile::run, triggerBitsToken_, and watcher_.

                                                                                         {
   if (watcher_.check(iSetup)) {  // new IOV for this run
     edm::LogPrint("AlCaRecoTriggerBitsRcdRead") << "new IOV: " << firstRun_ << "-" << lastRun_;
     // Print last IOV - if there has already been one:
     if (lastRun_ != 0)
       this->printMap(firstRun_, lastRun_, lastTriggerBits_);
 
     // Get AlCaRecoTriggerBits from EventSetup:
     const auto &triggerBits = &iSetup.getData(triggerBitsToken_);
     lastTriggerBits_ = *triggerBits;  // copy for later use
     firstRun_ = run.run();            // keep track where it started
   }
 
   lastRun_ = run.run();  // keep track of last visited run
 }

◆ endJob()

void AlCaRecoTriggerBitsRcdRead::endJob ( void )

overridevirtual

Reimplemented from edm::one::EDAnalyzerBase.

Definition at line 144 of file AlCaRecoTriggerBitsRcdRead.cc.

References firstRun_, lastRun_, lastTriggerBits_, and printMap().

                                         {
   // Print for very last IOV, not treated yet in beginRun(..):
   this->printMap(firstRun_, lastRun_, lastTriggerBits_);
 }

◆ endRun()

void AlCaRecoTriggerBitsRcdRead::endRun	(	edm::Run const &	,
		edm::EventSetup const &
	)

inlineoverride

Definition at line 47 of file AlCaRecoTriggerBitsRcdRead.cc.

47 {}

◆ fillDescriptions()

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

static

Definition at line 71 of file AlCaRecoTriggerBitsRcdRead.cc.

References edm::ConfigurationDescriptions::addWithDefaultLabel(), submitPVResolutionJobs::desc, and AlCaHLTBitMon_QueryRunRegistry::string.

                                                                                             {
   edm::ParameterSetDescription desc;
   desc.setComment("Plugin to read payloads of type AlCaRecoTriggerBits");
   desc.addUntracked<std::string>("rawFileName", "");
   desc.addUntracked<std::string>("outputType", "twiki");
   descriptions.addWithDefaultLabel(desc);
 }

◆ printMap()

void AlCaRecoTriggerBitsRcdRead::printMap	(	edm::RunNumber_t	firstRun,
		edm::RunNumber_t	lastRun,
		const AlCaRecoTriggerBits &	triggerMap
	)		const

private

Definition at line 150 of file AlCaRecoTriggerBitsRcdRead.cc.

References AlCaRecoTriggerBits::decompose(), GCP_Ntuples_cfg::firstRun, mps_fire::i, kPython, kText, kTwiki, PixelBaryCentreAnalyzer_cfg::lastRun, AlCaRecoTriggerBits::m_alcarecoToTrig, convertSQLitetoXML_cfg::output, output_, outputType_, and Skims_PA_cff::paths.

Referenced by beginRun(), and endJob().

                                                                                         {
   // Get map of strings to concatenated list of names of HLT paths:
   typedef std::map<std::string, std::string> TriggerMap;
   const TriggerMap &triggerMap = triggerBits.m_alcarecoToTrig;
 
   // Collect output for given run numbers via ostringstream.
   // Format depends on outputType_ configuration.
   std::ostringstream output;
   switch (outputType_) {
     case kPython:
       output << "  triggerLists = cms.VPSet(\n";
       [[fallthrough]];
     case kText:
       output << "#\n# AlCaRecoTriggerBits settings for IOV " << firstRun << "-" << lastRun << ":\n#\n";
       break;
     case kTwiki:
       output << "---+++++ *IOV*: " << firstRun << "-" << lastRun << "\n"
              << "| *TriggerBits list key* | *HLT paths* |\n";
       break;
   }
 
   //  if (outputType_ == kPython) output << "  triggerLists = cms.VPSet(\n";
 
   // loop over entries in map
   for (TriggerMap::const_iterator i = triggerMap.begin(); i != triggerMap.end(); ++i) {
     if (outputType_ == kPython && i != triggerMap.begin())
       output << ",\n";
 
     switch (outputType_) {
       case kPython:
         output << "      cms.PSet(listName = cms.string('" << i->first << "'),\n"
                << "               hltPaths = cms.vstring(";
         break;
       case kText:
         output << "trigger list key: '" << i->first << "'\npaths:\n";
         break;
       case kTwiki:
         output << "| '" << i->first << "' | ";
     }
     // We must avoid a map<string,vector<string> > in DB for performance reason,
     // so the paths are mapped into one string separated by ';':
     const std::vector<std::string> paths = triggerBits.decompose(i->second);
     for (unsigned int iPath = 0; iPath < paths.size(); ++iPath) {
       if (iPath != 0) {
         output << ", ";  // next path
         switch (outputType_) {
           case kPython:  // only 2 per line
           case kText:    // only 4 per line
             if (0 == (iPath % (outputType_ == kPython ? 2 : 4))) {
               output << "\n";
               if (outputType_ == kPython)
                 output << "                                      ";
             }
             break;
           case kTwiki:  // Twiki will handle that
             break;
         }
       }
       output << "'" << paths[iPath] << "'";
     }
     switch (outputType_) {
       case kPython:
         output << ")\n              )";
         break;
       case kText:
         output << "\n#\n";
         break;
       case kTwiki:
         output << " |\n";
     }
   }
   if (outputType_ == kPython)
     output << "\n      ) # closing of VPSet triggerLists\n";
 
   // Final output - either message logger or output file:
   if (output_.get())
     *output_ << output.str();
   else
     edm::LogInfo("") << output.str();
 }

◆ stringToEnum()

AlCaRecoTriggerBitsRcdRead::OutputType AlCaRecoTriggerBitsRcdRead::stringToEnum ( const std::string & outputType ) const

private

Definition at line 110 of file AlCaRecoTriggerBitsRcdRead.cc.

References Exception, kPython, kText, and kTwiki.

                                                                                                                   {
   if (outputTypeStr == "text")
     return kText;
   if (outputTypeStr == "twiki")
     return kTwiki;
   if (outputTypeStr == "python")
     return kPython;
   // if (outputTypeStr == "html") return kHtml;
 
   throw cms::Exception("BadConfig") << "AlCaRecoTriggerBitsRcdRead: "
                                     << "outputType '" << outputTypeStr << "' not known,"
                                     << " use 'text', 'twiki' or 'python'\n";
 
   return kTwiki;  // never reached, to please compiler
 }