Provides a code based selection for trigger and DCS information in order to have no failing filters in the CMSSW path. More...

#include <TriggerHelper.h>

Public Member Functions
bool	accept (const edm::Event &event, const edm::EventSetup &setup)
	To be called from analyze/filter() methods. More...

void	initRun (const edm::Run &run, const edm::EventSetup &setup)
	To be called from beginedm::Run() methods. More...

bool	off ()

bool	on ()

template<typename T >
	TriggerHelper (const edm::ParameterSet &config, edm::ConsumesCollector &&iC, T &module)

template<typename T >
	TriggerHelper (const edm::ParameterSet &config, edm::ConsumesCollector &iC, T &module)

	~TriggerHelper ()
	To be called from d'tors by 'delete'. More...

Private Member Functions
bool	acceptDcs (const edm::Event &event)

bool	acceptDcsPartition (const edm::Handle< DcsStatusCollection > &dcsStatus, const edm::Handle< DCSRecord > &dcsRecord, bool useDCSRecord, int dcsPartition) const

bool	acceptGt (const edm::Event &event)

bool	acceptGtLogicalExpression (const edm::Handle< L1GlobalTriggerReadoutRecord > &gtReadoutRecord, std::string gtLogicalExpression)
	Does this event fulfill this particular GT status bits' logical expression? More...

bool	acceptHlt (const edm::Event &event)

bool	acceptHltLogicalExpression (const edm::Handle< edm::TriggerResults > &hltTriggerResults, std::string hltLogicalExpression) const
	Was this event accepted by this particular HLT paths' logical expression? More...

bool	acceptL1 (const edm::Event &event, const edm::EventSetup &setup)
	Was this event accepted by the configured L1 logical expression combination? More...

bool	acceptL1LogicalExpression (const edm::Event &event, std::string l1LogicalExpression)

std::vector< std::string >	expressionsFromDB (const std::string &key, const edm::EventSetup &setup)
	Reads and returns logical expressions from DB. More...

bool	negate (std::string &word) const
	Checks for negated words. More...

	TriggerHelper (const edm::ParameterSet &config, edm::ConsumesCollector &iC)
	To be called from the ED module's c'tor. More...

Private Attributes
edm::ESGetToken< AlCaRecoTriggerBits, AlCaRecoTriggerBitsRcd >	alcaRecotriggerBitsToken_

bool	andOr_

bool	andOrDcs_

bool	andOrGt_

bool	andOrHlt_

bool	andOrL1_

const std::string	configError_

edm::InputTag	dcsInputTag_

edm::EDGetTokenT< DcsStatusCollection >	dcsInputToken_

std::vector< int >	dcsPartitions_

edm::InputTag	dcsRecordInputTag_

edm::EDGetTokenT< DCSRecord >	dcsRecordToken_

bool	errorReplyDcs_

bool	errorReplyGt_

bool	errorReplyHlt_

bool	errorReplyL1_

std::string	gtDBKey_

edm::InputTag	gtInputTag_

edm::EDGetTokenT< L1GlobalTriggerReadoutRecord >	gtInputToken_

std::vector< std::string >	gtLogicalExpressions_

HLTConfigProvider	hltConfig_

bool	hltConfigInit_

std::string	hltDBKey_

edm::InputTag	hltInputTag_

edm::EDGetTokenT< edm::TriggerResults >	hltInputToken_

std::vector< std::string >	hltLogicalExpressions_

std::string	l1DBKey_

std::unique_ptr< L1GtUtils >	l1Gt_

std::vector< std::string >	l1LogicalExpressions_

bool	on_

bool	onDcs_

bool	onGt_

bool	onHlt_

bool	onL1_

edm::ESWatcher< AlCaRecoTriggerBitsRcd > *	watchDB_

Detailed Description

Provides a code based selection for trigger and DCS information in order to have no failing filters in the CMSSW path.

"DQM/TrackerCommon/interface/TriggerHelper.h" [...]

Author: Volker Adler

Definition at line 43 of file TriggerHelper.h.

Constructor & Destructor Documentation

◆ TriggerHelper() [1/3]

template<typename T >

TriggerHelper::TriggerHelper	(	const edm::ParameterSet &	config,
		edm::ConsumesCollector &&	iC,
		T &	module
	)

Definition at line 134 of file TriggerHelper.h.

References alcaRecotriggerBitsToken_, gtInputTag_, and gtInputToken_.

     : TriggerHelper(config, iC, module) {
   gtInputTag_ = config.getParameter<edm::InputTag>("gtInputTag");
   gtInputToken_ = iC.consumes<L1GlobalTriggerReadoutRecord>(gtInputTag_);
   alcaRecotriggerBitsToken_ = iC.esConsumes<AlCaRecoTriggerBits, AlCaRecoTriggerBitsRcd>();
 }

◆ TriggerHelper() [2/3]

template<typename T >

TriggerHelper::TriggerHelper	(	const edm::ParameterSet &	config,
		edm::ConsumesCollector &	iC,
		T &	module
	)

Definition at line 142 of file TriggerHelper.h.

References DMR_cfg::config, L1GtUtils::Event, l1DBKey_, l1Gt_, l1LogicalExpressions_, callgraph::module, and onL1_.

     : TriggerHelper(config, iC) {
   if (onL1_ && (!l1DBKey_.empty() || !l1LogicalExpressions_.empty())) {
     l1Gt_ = std::make_unique<L1GtUtils>(config, iC, false, module, L1GtUtils::UseEventSetupIn::Event);
   }
 }

◆ ~TriggerHelper()

TriggerHelper::~TriggerHelper ( )

To be called from d'tors by 'delete'.

Definition at line 83 of file TriggerHelper.cc.

References on_, and watchDB_.

                               {
   if (on_)
     delete watchDB_;
 }

◆ TriggerHelper() [3/3]

TriggerHelper::TriggerHelper	(	const edm::ParameterSet &	config,
		edm::ConsumesCollector &	iC
	)

private

To be called from the ED module's c'tor.

Definition at line 12 of file TriggerHelper.cc.

References andOr_, andOrDcs_, andOrGt_, andOrHlt_, andOrL1_, dcsInputTag_, dcsInputToken_, dcsPartitions_, dcsRecordInputTag_, dcsRecordToken_, errorReplyDcs_, errorReplyGt_, errorReplyHlt_, errorReplyL1_, gtDBKey_, gtLogicalExpressions_, hltDBKey_, hltInputTag_, hltInputToken_, hltLogicalExpressions_, l1DBKey_, l1LogicalExpressions_, edm::ConsumesCollector::mayConsume(), on_, onDcs_, onGt_, onHlt_, onL1_, AlCaHLTBitMon_QueryRunRegistry::string, and watchDB_.

     : watchDB_(nullptr),
       gtDBKey_(""),
       l1DBKey_(""),
       hltDBKey_(""),
       on_(true),
       onDcs_(true),
       onGt_(true),
       onL1_(true),
       onHlt_(true),
       configError_("CONFIG_ERROR") {
   // General switch(es)
   if (config.exists("andOr")) {
     andOr_ = config.getParameter<bool>("andOr");
   } else {
     on_ = false;
     onDcs_ = false;
     onGt_ = false;
     onL1_ = false;
     onHlt_ = false;
   }
 
   if (on_) {
     if (config.exists("andOrDcs")) {
       andOrDcs_ = config.getParameter<bool>("andOrDcs");
       dcsInputTag_ = config.getParameter<edm::InputTag>("dcsInputTag");
       dcsInputToken_ = iC.mayConsume<DcsStatusCollection>(dcsInputTag_);
       dcsRecordInputTag_ = config.getParameter<edm::InputTag>("dcsRecordInputTag");
       dcsRecordToken_ = iC.mayConsume<DCSRecord>(dcsRecordInputTag_);
       dcsPartitions_ = config.getParameter<std::vector<int>>("dcsPartitions");
       errorReplyDcs_ = config.getParameter<bool>("errorReplyDcs");
     } else {
       onDcs_ = false;
     }
     if (config.exists("andOrGt")) {
       andOrGt_ = config.getParameter<bool>("andOrGt");
       gtLogicalExpressions_ = config.getParameter<std::vector<std::string>>("gtStatusBits");
       errorReplyGt_ = config.getParameter<bool>("errorReplyGt");
       if (config.exists("gtDBKey"))
         gtDBKey_ = config.getParameter<std::string>("gtDBKey");
     } else {
       onGt_ = false;
     }
     if (config.exists("andOrL1")) {
       andOrL1_ = config.getParameter<bool>("andOrL1");
       l1LogicalExpressions_ = config.getParameter<std::vector<std::string>>("l1Algorithms");
       errorReplyL1_ = config.getParameter<bool>("errorReplyL1");
       if (config.exists("l1DBKey"))
         l1DBKey_ = config.getParameter<std::string>("l1DBKey");
     } else {
       onL1_ = false;
     }
     if (config.exists("andOrHlt")) {
       andOrHlt_ = config.getParameter<bool>("andOrHlt");
       hltInputTag_ = config.getParameter<edm::InputTag>("hltInputTag");
       hltInputToken_ = iC.mayConsume<edm::TriggerResults>(hltInputTag_);
       hltLogicalExpressions_ = config.getParameter<std::vector<std::string>>("hltPaths");
       errorReplyHlt_ = config.getParameter<bool>("errorReplyHlt");
       if (config.exists("hltDBKey"))
         hltDBKey_ = config.getParameter<std::string>("hltDBKey");
     } else {
       onHlt_ = false;
     }
     if (!onDcs_ && !onGt_ && !onL1_ && !onHlt_)
       on_ = false;
     else
       watchDB_ = new edm::ESWatcher<AlCaRecoTriggerBitsRcd>;
   }
 }

Member Function Documentation

◆ accept()

bool TriggerHelper::accept	(	const edm::Event &	event,
		const edm::EventSetup &	setup
	)

To be called from analyze/filter() methods.

Definition at line 129 of file TriggerHelper.cc.

References acceptDcs(), acceptGt(), acceptHlt(), acceptL1(), andOr_, on_, and singleTopDQM_cfi::setup.

Referenced by esMonitoring.FDJsonServer::handle_accept().

                                                                             {
   if (!on_)
     return true;
 
   // Determine decision
   if (andOr_)
     return (acceptDcs(event) || acceptGt(event) || acceptL1(event, setup) || acceptHlt(event));
   return (acceptDcs(event) && acceptGt(event) && acceptL1(event, setup) && acceptHlt(event));
 }

◆ acceptDcs()

bool TriggerHelper::acceptDcs ( const edm::Event & event )

private

Definition at line 139 of file TriggerHelper.cc.

References acceptDcsPartition(), andOr_, andOrDcs_, dcsInputTag_, dcsInputToken_, dcsPartitions_, DQMOffline_cff::dcsRecord, dcsRecordInputTag_, dcsRecordToken_, edm::InputTag::encode(), errorReplyDcs_, edm::HandleBase::isValid(), and onDcs_.

Referenced by accept().

                                                    {
   // An empty DCS partitions list acts as switch.
   if (!onDcs_ || dcsPartitions_.empty())
     return (!andOr_);  // logically neutral, depending on base logical connective
 
   bool useDCSRecord(false);
 
   // Accessing the DcsStatusCollection
   edm::Handle<DcsStatusCollection> dcsStatus;
   event.getByToken(dcsInputToken_, dcsStatus);
 
   edm::Handle<DCSRecord> dcsRecord;
   event.getByToken(dcsRecordToken_, dcsRecord);
 
   // none of the DCS products is valid
   if (!dcsStatus.isValid() && !dcsRecord.isValid()) {
     edm::LogWarning("TriggerHelper") << "DcsStatusCollection product with InputTag \"" << dcsInputTag_.encode()
                                      << "\" not in event \n"
                                      << "DCSRecord product with InputTag \"" << dcsRecordInputTag_.encode()
                                      << "\" not in event \n"
                                      << " ==> decision: " << errorReplyDcs_;
     return errorReplyDcs_;
   }
   if (dcsStatus.isValid() && (*dcsStatus).empty()) {
     if (event.eventAuxiliary().isRealData()) {
       // this is the Data case for >= Run3, DCSStatus is available (unpacked), but empty
       // becasue SCAL is not in data-taking. In this case we fall back to s/w FED 1022
       if (dcsRecord.isValid()) {
         useDCSRecord = true;
       } else {
         edm::LogWarning("TriggerHelper") << "DCSRecord product with InputTag \"" << dcsRecordInputTag_.encode()
                                          << "\" empty ==> decision: " << errorReplyDcs_;
         return errorReplyDcs_;
       }
     } else {
       // this is the case in which the DCS status is empty, but it's not real data.
       edm::LogInfo("TriggerHelper") << "DcsStatusCollection product with InputTag \"" << dcsInputTag_.encode()
                                     << "\" empty ==> decision: " << errorReplyDcs_;
       return errorReplyDcs_;
     }
   }
 
   // Determine decision of DCS partition combination and return
   if (andOrDcs_) {  // OR combination
     for (std::vector<int>::const_iterator partitionNumber = dcsPartitions_.begin();
          partitionNumber != dcsPartitions_.end();
          ++partitionNumber) {
       if (acceptDcsPartition(dcsStatus, dcsRecord, useDCSRecord, *partitionNumber))
         return true;
     }
     return false;
   }
   for (std::vector<int>::const_iterator partitionNumber = dcsPartitions_.begin();
        partitionNumber != dcsPartitions_.end();
        ++partitionNumber) {
     if (!acceptDcsPartition(dcsStatus, dcsRecord, useDCSRecord, *partitionNumber))
       return false;
   }
   return true;
 }

◆ acceptDcsPartition()

bool TriggerHelper::acceptDcsPartition	(	const edm::Handle< DcsStatusCollection > &	dcsStatus,
		const edm::Handle< DCSRecord > &	dcsRecord,
		bool	useDCSRecord,
		int	dcsPartition
	)		const

private

Definition at line 200 of file TriggerHelper.cc.

References DCSRecord::BPIX, DcsStatus::BPIX, DCSRecord::CASTOR, DcsStatus::CASTOR, DCSRecord::CSCm, DcsStatus::CSCm, DCSRecord::CSCp, DcsStatus::CSCp, DCSRecord::DT0, DcsStatus::DT0, DCSRecord::DTm, DcsStatus::DTm, DCSRecord::DTp, DcsStatus::DTp, DCSRecord::EBm, DcsStatus::EBm, DCSRecord::EBp, DcsStatus::EBp, DcsStatus::EEm, DCSRecord::EEp, DcsStatus::EEp, errorReplyDcs_, DCSRecord::ESm, DcsStatus::ESm, DCSRecord::ESp, DcsStatus::ESp, DCSRecord::FPIX, DcsStatus::FPIX, DCSRecord::HBHEa, DcsStatus::HBHEa, DCSRecord::HBHEb, DcsStatus::HBHEb, DCSRecord::HBHEc, DcsStatus::HBHEc, DCSRecord::HF, DcsStatus::HF, DCSRecord::HO, DcsStatus::HO, LogDebug, DCSRecord::RPC, DcsStatus::RPC, DCSRecord::TECm, DcsStatus::TECm, DCSRecord::TECp, DcsStatus::TECp, DCSRecord::TIBTID, DcsStatus::TIBTID, DCSRecord::TOB, and DcsStatus::TOB.

Referenced by acceptDcs().

                                                                {
   int theDCSRecordPartition;
   // Error checks
   switch (dcsPartition) {
     case DcsStatus::EBp:
       theDCSRecordPartition = DCSRecord::EBp;
       break;
     case DcsStatus::EBm:
       theDCSRecordPartition = DCSRecord::EBm;
       break;
     case DcsStatus::EEp:
       theDCSRecordPartition = DCSRecord::EEp;
       break;
     case DcsStatus::EEm:
       theDCSRecordPartition = DCSRecord::EBm;
       break;
     case DcsStatus::HBHEa:
       theDCSRecordPartition = DCSRecord::HBHEa;
       break;
     case DcsStatus::HBHEb:
       theDCSRecordPartition = DCSRecord::HBHEb;
       break;
     case DcsStatus::HBHEc:
       theDCSRecordPartition = DCSRecord::HBHEc;
       break;
     case DcsStatus::HF:
       theDCSRecordPartition = DCSRecord::HF;
       break;
     case DcsStatus::HO:
       theDCSRecordPartition = DCSRecord::HO;
       break;
     case DcsStatus::RPC:
       theDCSRecordPartition = DCSRecord::RPC;
       break;
     case DcsStatus::DT0:
       theDCSRecordPartition = DCSRecord::DT0;
       break;
     case DcsStatus::DTp:
       theDCSRecordPartition = DCSRecord::DTp;
       break;
     case DcsStatus::DTm:
       theDCSRecordPartition = DCSRecord::DTm;
       break;
     case DcsStatus::CSCp:
       theDCSRecordPartition = DCSRecord::CSCp;
       break;
     case DcsStatus::CSCm:
       theDCSRecordPartition = DCSRecord::CSCm;
       break;
     case DcsStatus::CASTOR:
       theDCSRecordPartition = DCSRecord::CASTOR;
       break;
     case DcsStatus::TIBTID:
       theDCSRecordPartition = DCSRecord::TIBTID;
       break;
     case DcsStatus::TOB:
       theDCSRecordPartition = DCSRecord::TOB;
       break;
     case DcsStatus::TECp:
       theDCSRecordPartition = DCSRecord::TECp;
       break;
     case DcsStatus::TECm:
       theDCSRecordPartition = DCSRecord::TECm;
       break;
     case DcsStatus::BPIX:
       theDCSRecordPartition = DCSRecord::BPIX;
       break;
     case DcsStatus::FPIX:
       theDCSRecordPartition = DCSRecord::FPIX;
       break;
     case DcsStatus::ESp:
       theDCSRecordPartition = DCSRecord::ESp;
       break;
     case DcsStatus::ESm:
       theDCSRecordPartition = DCSRecord::ESm;
       break;
     default:
       edm::LogWarning("TriggerHelper") << "DCS partition number \"" << dcsPartition
                                        << "\" does not exist ==> decision: " << errorReplyDcs_;
       return errorReplyDcs_;
   }
 
   // Determine decision
   if (!useDCSRecord) {
     return dcsStatus->at(0).ready(dcsPartition);
   } else {
     LogDebug("TriggerHelper") << "using dcs record, dcsPartition:" << dcsPartition << " " << theDCSRecordPartition
                               << " " << (*dcsRecord).partitionName(theDCSRecordPartition) << " "
                               << (*dcsRecord).highVoltageReady(theDCSRecordPartition) << std::endl;
     return (*dcsRecord).highVoltageReady(theDCSRecordPartition);
   }
 }

◆ acceptGt()

bool TriggerHelper::acceptGt ( const edm::Event & event )

private

Does this event fulfill the configured GT status logical expression combination?

Definition at line 298 of file TriggerHelper.cc.

References acceptGtLogicalExpression(), andOr_, andOrGt_, errorReplyGt_, gtInputToken_, gtLogicalExpressions_, edm::HandleBase::isValid(), and onGt_.

Referenced by accept().

                                                   {
   // An empty GT status bits logical expressions list acts as switch.
   if (!onGt_ || gtLogicalExpressions_.empty())
     return (!andOr_);  // logically neutral, depending on base logical connective
 
   // Accessing the L1GlobalTriggerReadoutRecord
   edm::Handle<L1GlobalTriggerReadoutRecord> gtReadoutRecord;
   event.getByToken(gtInputToken_, gtReadoutRecord);
   if (!gtReadoutRecord.isValid()) {
     //edm::LogError("TriggerHelper") << "L1GlobalTriggerReadoutRecord product with InputTag \"" << gtInputTag_.encode()
     //                               << "\" not in event ==> decision: " << errorReplyGt_;
     return errorReplyGt_;
   }
 
   // Determine decision of GT status bits logical expression combination and
   // return
   if (andOrGt_) {  // OR combination
     for (std::vector<std::string>::const_iterator gtLogicalExpression = gtLogicalExpressions_.begin();
          gtLogicalExpression != gtLogicalExpressions_.end();
          ++gtLogicalExpression) {
       if (acceptGtLogicalExpression(gtReadoutRecord, *gtLogicalExpression))
         return true;
     }
     return false;
   }
   for (std::vector<std::string>::const_iterator gtLogicalExpression = gtLogicalExpressions_.begin();
        gtLogicalExpression != gtLogicalExpressions_.end();
        ++gtLogicalExpression) {
     if (!acceptGtLogicalExpression(gtReadoutRecord, *gtLogicalExpression))
       return false;
   }
   return true;
 }

◆ acceptGtLogicalExpression()

bool TriggerHelper::acceptGtLogicalExpression	(	const edm::Handle< L1GlobalTriggerReadoutRecord > &	gtReadoutRecord,
		std::string	gtLogicalExpression
	)

private

Does this event fulfill this particular GT status bits' logical expression?

Definition at line 333 of file TriggerHelper.cc.

References errorReplyDcs_, errorReplyGt_, L1GtLogicParser::expressionResult(), L1GlobalTriggerReadoutRecord::gtFdlWord(), negate(), L1GtLogicParser::operandTokenVector(), L1GtFdlWord::physicsDeclared(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by acceptGt().

                                                                              {
   // Check empty std::strings
   if (gtLogicalExpression.empty()) {
     edm::LogError("TriggerHelper") << "Empty logical expression ==> decision: " << errorReplyGt_;
     return errorReplyGt_;
   }
 
   // Negated paths
   bool negExpr(negate(gtLogicalExpression));
   if (negExpr && gtLogicalExpression.empty()) {
     edm::LogError("TriggerHelper") << "Empty (negated) logical expression ==> decision: " << errorReplyGt_;
     return errorReplyGt_;
   }
 
   // Parse logical expression and determine GT status bit decision
   L1GtLogicParser gtAlgoLogicParser(gtLogicalExpression);
   // Loop over status bits
   for (size_t iStatusBit = 0; iStatusBit < gtAlgoLogicParser.operandTokenVector().size(); ++iStatusBit) {
     const std::string gtStatusBit(gtAlgoLogicParser.operandTokenVector().at(iStatusBit).tokenName);
     // Manipulate status bit decision as stored in the parser
     bool decision;
     // Hard-coded status bits!!!
     if (gtStatusBit == "PhysDecl" || gtStatusBit == "PhysicsDeclared") {
       decision = (gtReadoutRecord->gtFdlWord().physicsDeclared() == 1);
     } else {
       edm::LogError("TriggerHelper") << "GT status bit \"" << gtStatusBit
                                      << "\" is not defined ==> decision: " << errorReplyGt_;
       decision = errorReplyDcs_;
     }
     gtAlgoLogicParser.operandTokenVector().at(iStatusBit).tokenResult = decision;
   }
 
   // Determine decision
   const bool gtDecision(gtAlgoLogicParser.expressionResult());
   return negExpr ? (!gtDecision) : gtDecision;
 }

◆ acceptHlt()

bool TriggerHelper::acceptHlt ( const edm::Event & event )

private

Was this event accepted by the configured HLT logical expression combination?

Definition at line 444 of file TriggerHelper.cc.

References acceptHltLogicalExpression(), andOr_, andOrHlt_, edm::InputTag::encode(), errorReplyHlt_, hltConfigInit_, hltInputTag_, hltInputToken_, hltLogicalExpressions_, edm::HandleBase::isValid(), and onHlt_.

Referenced by accept().

                                                    {
   // An empty HLT logical expressions list acts as switch.
   if (!onHlt_ || hltLogicalExpressions_.empty())
     return (!andOr_);  // logically neutral, depending on base logical connective
 
   // Checking the HLT configuration,
   if (!hltConfigInit_) {
     edm::LogError("TriggerHelper") << "HLT config error ==> decision: " << errorReplyHlt_;
     return errorReplyHlt_;
   }
 
   // Accessing the TriggerResults
   edm::Handle<edm::TriggerResults> hltTriggerResults;
   event.getByToken(hltInputToken_, hltTriggerResults);
   if (!hltTriggerResults.isValid()) {
     edm::LogError("TriggerHelper") << "TriggerResults product with InputTag \"" << hltInputTag_.encode()
                                    << "\" not in event ==> decision: " << errorReplyHlt_;
     return errorReplyHlt_;
   }
 
   // Determine decision of HLT logical expression combination and return
   if (andOrHlt_) {  // OR combination
     for (std::vector<std::string>::const_iterator hltLogicalExpression = hltLogicalExpressions_.begin();
          hltLogicalExpression != hltLogicalExpressions_.end();
          ++hltLogicalExpression) {
       if (acceptHltLogicalExpression(hltTriggerResults, *hltLogicalExpression))
         return true;
     }
     return false;
   }
   for (std::vector<std::string>::const_iterator hltLogicalExpression = hltLogicalExpressions_.begin();
        hltLogicalExpression != hltLogicalExpressions_.end();
        ++hltLogicalExpression) {
     if (!acceptHltLogicalExpression(hltTriggerResults, *hltLogicalExpression))
       return false;
   }
   return true;
 }

◆ acceptHltLogicalExpression()

bool TriggerHelper::acceptHltLogicalExpression	(	const edm::Handle< edm::TriggerResults > &	hltTriggerResults,
		std::string	hltLogicalExpression
	)		const

private

Was this event accepted by this particular HLT paths' logical expression?

Definition at line 484 of file TriggerHelper.cc.

References edm::HLTGlobalStatus::accept(), edm::HLTGlobalStatus::error(), errorReplyHlt_, L1GtLogicParser::expressionResult(), hltConfig_, hltInputTag_, negate(), L1GtLogicParser::operandTokenVector(), edm::InputTag::process(), HLTConfigProvider::size(), AlCaHLTBitMon_QueryRunRegistry::string, and HLTConfigProvider::triggerIndex().

Referenced by acceptHlt().

                                                                                      {
   // Check empty std::strings
   if (hltLogicalExpression.empty()) {
     edm::LogError("TriggerHelper") << "Empty logical expression ==> decision: " << errorReplyHlt_;
     return errorReplyHlt_;
   }
 
   // Negated paths
   bool negExpr(negate(hltLogicalExpression));
   if (negExpr && hltLogicalExpression.empty()) {
     edm::LogError("TriggerHelper") << "Empty (negated) logical expression ==> decision: " << errorReplyHlt_;
     return errorReplyHlt_;
   }
 
   // Parse logical expression and determine HLT decision
   L1GtLogicParser hltAlgoLogicParser(hltLogicalExpression);
   // Loop over paths
   for (size_t iPath = 0; iPath < hltAlgoLogicParser.operandTokenVector().size(); ++iPath) {
     const std::string hltPathName(hltAlgoLogicParser.operandTokenVector().at(iPath).tokenName);
     const unsigned indexPath(hltConfig_.triggerIndex(hltPathName));
     // Further error checks
     if (indexPath == hltConfig_.size()) {
       edm::LogError("TriggerHelper") << "HLT path \"" << hltPathName << "\" is not found in process "
                                      << hltInputTag_.process() << " ==> decision: " << errorReplyHlt_;
       hltAlgoLogicParser.operandTokenVector().at(iPath).tokenResult = errorReplyHlt_;
       continue;
     }
     if (hltTriggerResults->error(indexPath)) {
       edm::LogError("TriggerHelper") << "HLT path \"" << hltPathName << "\" in error ==> decision: " << errorReplyHlt_;
       hltAlgoLogicParser.operandTokenVector().at(iPath).tokenResult = errorReplyHlt_;
       continue;
     }
     // Manipulate algo decision as stored in the parser
     const bool decision(hltTriggerResults->accept(indexPath));
     hltAlgoLogicParser.operandTokenVector().at(iPath).tokenResult = decision;
   }
 
   // Determine decision
   const bool hltDecision(hltAlgoLogicParser.expressionResult());
   return negExpr ? (!hltDecision) : hltDecision;
 }

◆ acceptL1()

bool TriggerHelper::acceptL1	(	const edm::Event &	event,
		const edm::EventSetup &	setup
	)

private

Was this event accepted by the configured L1 logical expression combination?

Definition at line 372 of file TriggerHelper.cc.

References acceptL1LogicalExpression(), andOr_, andOrL1_, l1Gt_, l1LogicalExpressions_, onL1_, and singleTopDQM_cfi::setup.

Referenced by accept().

                                                                               {
   // An empty L1 logical expressions list acts as switch.
   if (!onL1_ || l1LogicalExpressions_.empty())
     return (!andOr_);  // logically neutral, depending on base logical connective
 
   // Getting the L1 event setup
   l1Gt_->retrieveL1EventSetup(setup);  // FIXME This can possibly go to initRun()
 
   // Determine decision of L1 logical expression combination and return
   if (andOrL1_) {  // OR combination
     for (std::vector<std::string>::const_iterator l1LogicalExpression = l1LogicalExpressions_.begin();
          l1LogicalExpression != l1LogicalExpressions_.end();
          ++l1LogicalExpression) {
       if (acceptL1LogicalExpression(event, *l1LogicalExpression))
         return true;
     }
     return false;
   }
   for (std::vector<std::string>::const_iterator l1LogicalExpression = l1LogicalExpressions_.begin();
        l1LogicalExpression != l1LogicalExpressions_.end();
        ++l1LogicalExpression) {
     if (!acceptL1LogicalExpression(event, *l1LogicalExpression))
       return false;
   }
   return true;
 }

◆ acceptL1LogicalExpression()

bool TriggerHelper::acceptL1LogicalExpression	(	const edm::Event &	event,
		std::string	l1LogicalExpression
	)

private

Was this event accepted by this particular L1 algorithms' logical expression?

Definition at line 401 of file TriggerHelper.cc.

References relativeConstraints::error, errorReplyL1_, L1GtLogicParser::expressionResult(), l1Gt_, negate(), L1GtLogicParser::operandTokenVector(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by acceptL1().

                                                                                                   {
   // Check empty std::strings
   if (l1LogicalExpression.empty()) {
     edm::LogError("TriggerHelper") << "Empty logical expression ==> decision: " << errorReplyL1_;
     return errorReplyL1_;
   }
 
   // Negated logical expression
   bool negExpr(negate(l1LogicalExpression));
   if (negExpr && l1LogicalExpression.empty()) {
     edm::LogError("TriggerHelper") << "Empty (negated) logical expression ==> decision: " << errorReplyL1_;
     return errorReplyL1_;
   }
 
   // Parse logical expression and determine L1 decision
   L1GtLogicParser l1AlgoLogicParser(l1LogicalExpression);
   // Loop over algorithms
   for (size_t iAlgorithm = 0; iAlgorithm < l1AlgoLogicParser.operandTokenVector().size(); ++iAlgorithm) {
     const std::string l1AlgoName(l1AlgoLogicParser.operandTokenVector().at(iAlgorithm).tokenName);
     int error(-1);
     const bool decision(l1Gt_->decision(event, l1AlgoName, error));
     // Error checks
     if (error != 0) {
       if (error == 1)
         edm::LogError("TriggerHelper") << "L1 algorithm \"" << l1AlgoName
                                        << "\" does not exist in the L1 menu ==> decision: " << errorReplyL1_;
       else
         edm::LogError("TriggerHelper") << "L1 algorithm \"" << l1AlgoName << "\" received error code " << error
                                        << " from L1GtUtils::decisionBeforeMask ==> decision: " << errorReplyL1_;
       l1AlgoLogicParser.operandTokenVector().at(iAlgorithm).tokenResult = errorReplyL1_;
       continue;
     }
     // Manipulate algo decision as stored in the parser
     l1AlgoLogicParser.operandTokenVector().at(iAlgorithm).tokenResult = decision;
   }
 
   // Return decision
   const bool l1Decision(l1AlgoLogicParser.expressionResult());
   return negExpr ? (!l1Decision) : l1Decision;
 }

◆ expressionsFromDB()

std::vector< std::string > TriggerHelper::expressionsFromDB	(	const std::string &	key,
		const edm::EventSetup &	setup
	)

private

Reads and returns logical expressions from DB.

Definition at line 528 of file TriggerHelper.cc.

References alcaRecotriggerBitsToken_, configError_, AlCaRecoTriggerBits::decompose(), crabWrapper::key, AlCaRecoTriggerBits::m_alcarecoToTrig, and singleTopDQM_cfi::setup.

Referenced by initRun().

                                                                                                       {
   const AlCaRecoTriggerBits *logicalExpressions = &(setup.getData(alcaRecotriggerBitsToken_));
   const std::map<std::string, std::string> &expressionMap = logicalExpressions->m_alcarecoToTrig;
   std::map<std::string, std::string>::const_iterator listIter = expressionMap.find(key);
   if (listIter == expressionMap.end()) {
     edm::LogError("TriggerHelper") << "No logical expressions found under key " << key
                                    << " in 'AlCaRecoTriggerBitsRcd'";
     return std::vector<std::string>(1, configError_);
   }
   return logicalExpressions->decompose(listIter->second);
 }

◆ initRun()

void TriggerHelper::initRun	(	const edm::Run &	run,
		const edm::EventSetup &	setup
	)

To be called from beginedm::Run() methods.

Definition at line 89 of file TriggerHelper.cc.

References edm::ESWatcher< T >::check(), configError_, edm::InputTag::encode(), expressionsFromDB(), gtDBKey_, gtLogicalExpressions_, hltConfig_, hltConfigInit_, hltDBKey_, hltInputTag_, hltLogicalExpressions_, HLTConfigProvider::init(), l1DBKey_, l1LogicalExpressions_, onGt_, onHlt_, onL1_, edm::InputTag::process(), writedatasetfile::run, singleTopDQM_cfi::setup, HLTConfigProvider::size(), and watchDB_.

                                                                          {
   // FIXME Can this stay safely in the run loop, or does it need to go to the
   // event loop? Means: Are the event setups identical?
   if (watchDB_->check(setup)) {
     if (onGt_ && !gtDBKey_.empty()) {
       const std::vector<std::string> exprs(expressionsFromDB(gtDBKey_, setup));
       if (exprs.empty() || exprs.at(0) != configError_)
         gtLogicalExpressions_ = exprs;
     }
     if (onL1_ && !l1DBKey_.empty()) {
       const std::vector<std::string> exprs(expressionsFromDB(l1DBKey_, setup));
       if (exprs.empty() || exprs.at(0) != configError_)
         l1LogicalExpressions_ = exprs;
     }
     if (onHlt_ && !hltDBKey_.empty()) {
       const std::vector<std::string> exprs(expressionsFromDB(hltDBKey_, setup));
       if (exprs.empty() || exprs.at(0) != configError_)
         hltLogicalExpressions_ = exprs;
     }
   }
 
   hltConfigInit_ = false;
   if (onHlt_) {
     if (hltInputTag_.process().empty()) {
       edm::LogError("TriggerHelper") << "HLT TriggerResults InputTag \"" << hltInputTag_.encode()
                                      << "\" specifies no process";
     } else {
       bool hltChanged(false);
       if (!hltConfig_.init(run, setup, hltInputTag_.process(), hltChanged)) {
         edm::LogError("TriggerHelper") << "HLT config initialization error with process name \""
                                        << hltInputTag_.process() << "\"";
       } else if (hltConfig_.size() <= 0) {
         edm::LogError("TriggerHelper") << "HLT config size error";
       } else
         hltConfigInit_ = true;
     }
   }
 }

◆ negate()

bool TriggerHelper::negate ( std::string & word ) const

private

Checks for negated words.

Definition at line 541 of file TriggerHelper.cc.

Referenced by acceptGtLogicalExpression(), acceptHltLogicalExpression(), and acceptL1LogicalExpression().

                                                 {
   bool negate(false);
   if (word.at(0) == '~') {
     negate = true;
     word.erase(0, 1);
   }
   return negate;
 }