Inheritance diagram for L1TGlobalPrescalesVetosOnlineProd:

Public Member Functions
	L1TGlobalPrescalesVetosOnlineProd (const edm::ParameterSet &)

std::unique_ptr< const L1TGlobalPrescalesVetosFract >	newObject (const std::string &objectKey, const L1TGlobalPrescalesVetosFractO2ORcd &record) override

	~L1TGlobalPrescalesVetosOnlineProd (void) override

Public Member Functions inherited from L1ConfigOnlineProdBaseExt< L1TGlobalPrescalesVetosFractO2ORcd, L1TGlobalPrescalesVetosFract >
	L1ConfigOnlineProdBaseExt (const edm::ParameterSet &)

std::unique_ptr< const L1TGlobalPrescalesVetosFract >	produce (const L1TGlobalPrescalesVetosFractO2ORcd &iRecord)

	~L1ConfigOnlineProdBaseExt () override

Public Member Functions inherited from edm::ESProducer
	ESProducer ()

	ESProducer (const ESProducer &)=delete

ESProxyIndex const *	getTokenIndices (unsigned int iIndex) const

ESRecordIndex const *	getTokenRecordIndices (unsigned int iIndex) const

bool	hasMayConsumes () const noexcept

size_t	numberOfTokenIndices (unsigned int iIndex) const

ESProducer const &	operator= (const ESProducer &)=delete

SerialTaskQueueChain &	queue ()

template<typename Record >
std::optional< std::vector< ESProxyIndex > >	updateFromMayConsumes (unsigned int iIndex, const Record &iRecord) const

void	updateLookup (eventsetup::ESRecordsToProxyIndices const &) final

	~ESProducer () noexcept(false) override

Public Member Functions inherited from edm::ESProxyFactoryProducer
	ESProxyFactoryProducer ()

	ESProxyFactoryProducer (const ESProxyFactoryProducer &)=delete

const ESProxyFactoryProducer &	operator= (const ESProxyFactoryProducer &)=delete

	~ESProxyFactoryProducer () noexcept(false) override

Public Member Functions inherited from edm::eventsetup::DataProxyProvider
void	createKeyedProxies (EventSetupRecordKey const &key, unsigned int nConcurrentIOVs)

	DataProxyProvider ()

	DataProxyProvider (const DataProxyProvider &)=delete

const ComponentDescription &	description () const

void	fillRecordsNotAllowingConcurrentIOVs (std::set< EventSetupRecordKey > &recordsNotAllowingConcurrentIOVs) const

virtual void	initConcurrentIOVs (EventSetupRecordKey const &key, unsigned int nConcurrentIOVs)

bool	isUsingRecord (const EventSetupRecordKey &key) const

KeyedProxies &	keyedProxies (const EventSetupRecordKey &iRecordKey, unsigned int iovIndex=0)

const DataProxyProvider &	operator= (const DataProxyProvider &)=delete

void	setAppendToDataLabel (const edm::ParameterSet &)

void	setDescription (const ComponentDescription &iDescription)

std::set< EventSetupRecordKey >	usingRecords () const

virtual	~DataProxyProvider () noexcept(false)

Private Attributes
bool	transactionSafe

Additional Inherited Members
Static Public Member Functions inherited from edm::eventsetup::DataProxyProvider
static void	prevalidate (ConfigurationDescriptions &)

Protected Types inherited from edm::ESProxyFactoryProducer
using	EventSetupRecordKey = eventsetup::EventSetupRecordKey

Protected Types inherited from edm::eventsetup::DataProxyProvider
using	KeyedProxiesVector = std::vector< std::pair< DataKey, std::shared_ptr< DataProxy > >>

Protected Member Functions inherited from L1ConfigOnlineProdBaseExt< L1TGlobalPrescalesVetosFractO2ORcd, L1TGlobalPrescalesVetosFract >
bool	getObjectKey (const L1TGlobalPrescalesVetosFractO2ORcd &record, std::string &objectKey)

edm::ESConsumesCollectorT< L1TGlobalPrescalesVetosFractO2ORcd >	wrappedSetWhatProduced (const edm::ParameterSet &)

Protected Member Functions inherited from edm::ESProducer
template<typename T >
auto	setWhatProduced (T iThis, const char iLabel)

template<typename T >
auto	setWhatProduced (T *iThis, const es::Label &iLabel={})

template<typename T >
auto	setWhatProduced (T *iThis, const std::string &iLabel)

template<typename T , typename TDecorator >
auto	setWhatProduced (T *iThis, const TDecorator &iDec, const es::Label &iLabel={})

template<typename T , typename TReturn , typename TRecord >
auto	setWhatProduced (T iThis, TReturn(T ::iMethod)(const TRecord &), const es::Label &iLabel={})

template<typename T , typename TReturn , typename TRecord , typename TArg >
ESConsumesCollectorT< TRecord >	setWhatProduced (T iThis, TReturn(T ::iMethod)(const TRecord &), const TArg &iDec, const es::Label &iLabel={})

void	usesResources (std::vector< std::string > const &)

Protected Member Functions inherited from edm::ESProxyFactoryProducer
template<class TFactory >
void	registerFactory (std::unique_ptr< TFactory > iFactory, const std::string &iLabel=std::string())

virtual void	registerFactoryWithKey (const EventSetupRecordKey &iRecord, std::unique_ptr< eventsetup::ProxyFactoryBase > iFactory, const std::string &iLabel=std::string())

KeyedProxiesVector	registerProxies (const EventSetupRecordKey &, unsigned int iovIndex) override

Protected Member Functions inherited from edm::eventsetup::DataProxyProvider
template<class T >
void	usingRecord ()

void	usingRecordWithKey (const EventSetupRecordKey &key)

Protected Attributes inherited from L1ConfigOnlineProdBaseExt< L1TGlobalPrescalesVetosFractO2ORcd, L1TGlobalPrescalesVetosFract >
bool	m_copyFromCondDB

cond::persistency::Session	m_dbSession

bool	m_forceGeneration

l1t::OMDSReader	m_omdsReader

Detailed Description

Definition at line 28 of file L1TGlobalPrescalesVetosOnlineProd.cc.

Constructor & Destructor Documentation

◆ L1TGlobalPrescalesVetosOnlineProd()

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

Definition at line 41 of file L1TGlobalPrescalesVetosOnlineProd.cc.

     : L1ConfigOnlineProdBaseExt<L1TGlobalPrescalesVetosFractO2ORcd, L1TGlobalPrescalesVetosFract>(iConfig) {
   wrappedSetWhatProduced(iConfig);
   transactionSafe = iConfig.getParameter<bool>("transactionSafe");
 }

References edm::ParameterSet::getParameter(), transactionSafe, and L1ConfigOnlineProdBaseExt< L1TGlobalPrescalesVetosFractO2ORcd, L1TGlobalPrescalesVetosFract >::wrappedSetWhatProduced().

◆ ~L1TGlobalPrescalesVetosOnlineProd()

L1TGlobalPrescalesVetosOnlineProd::~L1TGlobalPrescalesVetosOnlineProd ( void )

inlineoverride

Definition at line 38 of file L1TGlobalPrescalesVetosOnlineProd.cc.

38 {}

Member Function Documentation

◆ newObject()

std::unique_ptr< const L1TGlobalPrescalesVetosFract > L1TGlobalPrescalesVetosOnlineProd::newObject	(	const std::string &	objectKey,
		const L1TGlobalPrescalesVetosFractO2ORcd &	record
	)

overridevirtual

std::vector< std::string > queryColumns;

Implements L1ConfigOnlineProdBaseExt< L1TGlobalPrescalesVetosFractO2ORcd, L1TGlobalPrescalesVetosFract >.

Definition at line 47 of file L1TGlobalPrescalesVetosOnlineProd.cc.

                                                                                   {
   edm::LogInfo("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
       << "Producing L1TGlobalPrescalesVetos with TSC:RS key = " << objectKey;
  
   if (objectKey.empty()) {
     if (transactionSafe)
       throw std::runtime_error("SummaryForFunctionManager: uGTrs | Faulty  | Empty objectKey");
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
   unsigned int m_numberPhysTriggers = 512;
  
   // dictionary that maps algorithm name to it's index
   std::unordered_map<std::string, int, std::hash<std::string>> algoName2bit;
  
   std::string uGTtscKey = objectKey.substr(0, objectKey.find(':'));
   std::string uGTrsKey = objectKey.substr(objectKey.find(':') + 1, std::string::npos);
  
   std::string stage2Schema = "CMS_TRG_L1_CONF";
  
   std::string l1_menu_key;
   std::vector<std::string> queryStrings;
   queryStrings.push_back("L1_MENU");
  
   // select L1_MENU from CMS_TRG_L1_CONF.UGT_KEYS where ID = objectKey ;
   l1t::OMDSReader::QueryResults queryResult = m_omdsReader.basicQuery(
       queryStrings, stage2Schema, "UGT_KEYS", "UGT_KEYS.ID", m_omdsReader.singleAttribute(uGTtscKey));
  
   if (queryResult.queryFailed() || queryResult.numberRows() != 1) {
     edm::LogError("L1-O2O") << "Cannot get UGT_KEYS.L1_MENU for ID = " << uGTtscKey << " ";
     if (transactionSafe)
       throw std::runtime_error("SummaryForFunctionManager: uGTrs | Faulty  | Broken key");
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
   if (!queryResult.fillVariable("L1_MENU", l1_menu_key))
     l1_menu_key = "";
  
   edm::LogInfo("L1-O2O: L1TGlobalPrescalesVetosOnlineProd") << "Producing L1TUtmTriggerMenu with key =" << l1_menu_key;
  
   if (uGTtscKey.empty()) {
     edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd") << "TSC key is empty, returning";
     if (transactionSafe)
       throw std::runtime_error("SummaryForFunctionManager: uGTrs | Faulty  | Empty objectKey");
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
   std::vector<std::string> queryColumns;
   queryColumns.push_back("CONF");
  
   queryResult = m_omdsReader.basicQuery(
       queryColumns, stage2Schema, "UGT_L1_MENU", "UGT_L1_MENU.ID", m_omdsReader.singleAttribute(l1_menu_key));
  
   if (queryResult.queryFailed() || queryResult.numberRows() != 1) {
     edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
         << "Cannot get UGT_L1_MENU.CONF for ID = " << l1_menu_key;
     if (transactionSafe)
       throw std::runtime_error("SummaryForFunctionManager: uGTrs | Faulty  | Broken key");
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
   std::string l1Menu;
   queryResult.fillVariable("CONF", l1Menu);
   std::istringstream iss(l1Menu);
  
   std::shared_ptr<L1TUtmTriggerMenu> pMenu(
       const_cast<L1TUtmTriggerMenu *>(reinterpret_cast<const L1TUtmTriggerMenu *>(tmeventsetup::getTriggerMenu(iss))));
  
   for (const auto &algo : pMenu->getAlgorithmMap())
     algoName2bit[algo.first] = algo.second.getIndex();
  
   queryColumns.clear();
   queryColumns.push_back("ALGOBX_MASK");
   queryColumns.push_back("ALGO_FINOR_MASK");
   queryColumns.push_back("ALGO_FINOR_VETO");
   queryColumns.push_back("ALGO_PRESCALE");
  
   std::string prescale_key, bxmask_key, mask_key, vetomask_key;
   std::string xmlPayload_prescale, xmlPayload_mask_algobx, xmlPayload_mask_finor, xmlPayload_mask_veto;
   try {
     std::map<std::string, std::string> subKeys =
         l1t::OnlineDBqueryHelper::fetch(queryColumns, "UGT_RS_KEYS", uGTrsKey, m_omdsReader);
     prescale_key = subKeys["ALGO_PRESCALE"];
     bxmask_key = subKeys["ALGOBX_MASK"];
     mask_key = subKeys["ALGO_FINOR_MASK"];
     vetomask_key = subKeys["ALGO_FINOR_VETO"];
     xmlPayload_prescale = l1t::OnlineDBqueryHelper::fetch({"CONF"}, "UGT_RS_CLOBS", prescale_key, m_omdsReader)["CONF"];
     xmlPayload_mask_algobx =
         l1t::OnlineDBqueryHelper::fetch({"CONF"}, "UGT_RS_CLOBS", bxmask_key, m_omdsReader)["CONF"];
     xmlPayload_mask_finor = l1t::OnlineDBqueryHelper::fetch({"CONF"}, "UGT_RS_CLOBS", mask_key, m_omdsReader)["CONF"];
     xmlPayload_mask_veto =
         l1t::OnlineDBqueryHelper::fetch({"CONF"}, "UGT_RS_CLOBS", vetomask_key, m_omdsReader)["CONF"];
   } catch (std::runtime_error &e) {
     edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd") << e.what();
     if (transactionSafe)
       throw std::runtime_error(std::string("SummaryForFunctionManager: uGTrs | Faulty  | ") + e.what());
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
   // for debugging purposes dump the payloads to /tmp
   std::ofstream output1(std::string("/tmp/").append(prescale_key.substr(0, prescale_key.find('/'))).append(".xml"));
   output1 << xmlPayload_prescale;
   output1.close();
   std::ofstream output2(std::string("/tmp/").append(mask_key.substr(0, mask_key.find('/'))).append(".xml"));
   output2 << xmlPayload_mask_finor;
   output2.close();
   std::ofstream output3(std::string("/tmp/").append(bxmask_key.substr(0, bxmask_key.find('/'))).append(".xml"));
   output3 << xmlPayload_mask_algobx;
   output3.close();
   std::ofstream output4(std::string("/tmp/").append(vetomask_key.substr(0, vetomask_key.find('/'))).append(".xml"));
   output4 << xmlPayload_mask_veto;
   output4.close();
  
  
   std::vector<std::vector<double>> prescales;
   std::vector<unsigned int> triggerMasks;
   std::vector<int> triggerVetoMasks;
   std::map<int, std::vector<int>> triggerAlgoBxMaskAlgoTrig;
  
   // Prescales
   try {
     l1t::XmlConfigParser xmlReader_prescale;
     l1t::TriggerSystem ts_prescale;
     ts_prescale.addProcessor("uGtProcessor", "uGtProcessor", "-1", "-1");
  
     // run the parser
     xmlReader_prescale.readDOMFromString(xmlPayload_prescale);  // initialize it
     xmlReader_prescale.readRootElement(ts_prescale, "uGT");     // extract all of the relevant context
     ts_prescale.setConfigured();
  
     const std::map<std::string, l1t::Parameter> &settings_prescale = ts_prescale.getParameters("uGtProcessor");
     std::map<std::string, unsigned int> prescaleColumns = settings_prescale.at("prescales").getColumnIndices();
  
     unsigned int numColumns_prescale = prescaleColumns.size();
     int nPrescaleSets = numColumns_prescale - 1;
     std::vector<std::string> algoNames =
         settings_prescale.at("prescales").getTableColumn<std::string>("algo/prescale-index");
  
     if (nPrescaleSets > 0) {
       // Fill default prescale set
       for (int iSet = 0; iSet < nPrescaleSets; iSet++) {
         prescales.push_back(std::vector<double>());
         for (unsigned int iBit = 0; iBit < m_numberPhysTriggers; ++iBit) {
           double inputDefaultPrescale = 0;  // only prescales that are set in the block below are used
           prescales[iSet].push_back(inputDefaultPrescale);
         }
       }
  
       for (auto &col : prescaleColumns) {
         if (col.second < 1)
           continue;  // we don't care for the algorithms' indicies in 0th column
         int iSet = col.second - 1;
         std::vector<double> prescalesForSet =
             settings_prescale.at("prescales").getTableColumn<double>(col.first.c_str());
         for (unsigned int row = 0; row < prescalesForSet.size(); row++) {
           double prescale = prescalesForSet[row];
           std::string algoName = algoNames[row];
           unsigned int algoBit = algoName2bit[algoName];
           prescales[iSet][algoBit] = prescale;
         }
       }
     }
   } catch (std::runtime_error &e) {
     if (transactionSafe)
       throw std::runtime_error(std::string("SummaryForFunctionManager: uGTrs | Faulty  | ") + e.what());
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
  
   // finor mask
   try {
     l1t::XmlConfigParser xmlReader_mask_finor;
     l1t::TriggerSystem ts_mask_finor;
     ts_mask_finor.addProcessor("uGtProcessor", "uGtProcessor", "-1", "-1");
  
     // run the parser
     xmlReader_mask_finor.readDOMFromString(xmlPayload_mask_finor);  // initialize it
     xmlReader_mask_finor.readRootElement(ts_mask_finor, "uGT");     // extract all of the relevant context
     ts_mask_finor.setConfigured();
  
     const std::map<std::string, l1t::Parameter> &settings_mask_finor = ts_mask_finor.getParameters("uGtProcessor");
  
     std::vector<std::string> algo_mask_finor = settings_mask_finor.at("finorMask").getTableColumn<std::string>("algo");
     std::vector<unsigned int> mask_mask_finor =
         settings_mask_finor.at("finorMask").getTableColumn<unsigned int>("mask");
  
     // mask (default=1 - unmask)
     unsigned int default_finor_mask = 1;
     auto default_finor_row = std::find_if(algo_mask_finor.cbegin(), algo_mask_finor.cend(), [](const std::string &s) {
       // simpler than overweight std::tolower(s[], std::locale()) POSIX solution (thx to BA):
       return strcasecmp("all", s.c_str()) == 0;
     });
     if (default_finor_row == algo_mask_finor.cend()) {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "\nWarning: No default found in FinOR mask xml, use 1 (unmasked) as default" << std::endl;
     } else {
       default_finor_mask = mask_mask_finor[std::distance(algo_mask_finor.cbegin(), default_finor_row)];
     }
  
     for (unsigned int iAlg = 0; iAlg < m_numberPhysTriggers; iAlg++)
       triggerMasks.push_back(default_finor_mask);
  
     for (unsigned int row = 0; row < algo_mask_finor.size(); row++) {
       std::string algoName = algo_mask_finor[row];
       if (strcasecmp("all", algoName.c_str()) == 0)
         continue;
       unsigned int algoBit = algoName2bit[algoName];
       unsigned int mask = mask_mask_finor[row];
       if (algoBit < m_numberPhysTriggers)
         triggerMasks[algoBit] = mask;
     }
   } catch (std::runtime_error &e) {
     if (transactionSafe)
       throw std::runtime_error(std::string("SummaryForFunctionManager: uGTrs | Faulty  | ") + e.what());
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
  
   // veto mask
   try {
     l1t::XmlConfigParser xmlReader_mask_veto;
     l1t::TriggerSystem ts_mask_veto;
     ts_mask_veto.addProcessor("uGtProcessor", "uGtProcessor", "-1", "-1");
  
     // run the parser
     xmlReader_mask_veto.readDOMFromString(xmlPayload_mask_veto);  // initialize it
     xmlReader_mask_veto.readRootElement(ts_mask_veto, "uGT");     // extract all of the relevant context
     ts_mask_veto.setConfigured();
  
     const std::map<std::string, l1t::Parameter> &settings_mask_veto = ts_mask_veto.getParameters("uGtProcessor");
     std::vector<std::string> algo_mask_veto = settings_mask_veto.at("vetoMask").getTableColumn<std::string>("algo");
     std::vector<unsigned int> veto_mask_veto = settings_mask_veto.at("vetoMask").getTableColumn<unsigned int>("veto");
  
     // veto mask (default=0 - no veto)
     unsigned int default_veto_mask = 1;
     auto default_veto_row = std::find_if(algo_mask_veto.cbegin(), algo_mask_veto.cend(), [](const std::string &s) {
       // simpler than overweight std::tolower(s[], std::locale()) POSIX solution (thx to BA):
       return strcasecmp("all", s.c_str()) == 0;
     });
     if (default_veto_row == algo_mask_veto.cend()) {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "\nWarning: No default found in Veto mask xml, use 0 (unvetoed) as default" << std::endl;
     } else {
       default_veto_mask = veto_mask_veto[std::distance(algo_mask_veto.cbegin(), default_veto_row)];
     }
  
     for (unsigned int iAlg = 0; iAlg < m_numberPhysTriggers; iAlg++)
       triggerVetoMasks.push_back(default_veto_mask);
  
     for (unsigned int row = 0; row < algo_mask_veto.size(); row++) {
       std::string algoName = algo_mask_veto[row];
       if (strcasecmp("all", algoName.c_str()) == 0)
         continue;
       unsigned int algoBit = algoName2bit[algoName];
       unsigned int veto = veto_mask_veto[row];
       if (algoBit < m_numberPhysTriggers)
         triggerVetoMasks[algoBit] = int(veto);
     }
   } catch (std::runtime_error &e) {
     if (transactionSafe)
       throw std::runtime_error(std::string("SummaryForFunctionManager: uGTrs | Faulty  | ") + e.what());
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
  
   // Algo bx mask
   unsigned int m_bx_mask_default = 1;
  
   std::vector<std::string> bx_algo_name;
   std::vector<std::string> bx_range;
   std::vector<unsigned int> bx_mask;
  
   try {
     l1t::XmlConfigParser xmlReader_mask_algobx;
     l1t::TriggerSystem ts_mask_algobx;
     ts_mask_algobx.addProcessor("uGtProcessor", "uGtProcessor", "-1", "-1");
  
     // run the parser
     xmlReader_mask_algobx.readDOMFromString(xmlPayload_mask_algobx);  // initialize it
     xmlReader_mask_algobx.readRootElement(ts_mask_algobx, "uGT");     // extract all of the relevant context
     ts_mask_algobx.setConfigured();
  
     const std::map<std::string, l1t::Parameter> &settings_mask_algobx = ts_mask_algobx.getParameters("uGtProcessor");
     bx_algo_name = settings_mask_algobx.at("algorithmBxMask").getTableColumn<std::string>("algo");
     bx_range = settings_mask_algobx.at("algorithmBxMask").getTableColumn<std::string>("range");
     bx_mask = settings_mask_algobx.at("algorithmBxMask").getTableColumn<unsigned int>("mask");
   } catch (std::runtime_error &e) {
     if (transactionSafe)
       throw std::runtime_error(std::string("SummaryForFunctionManager: uGTrs | Faulty  | ") + e.what());
     else {
       edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
           << "returning empty L1TGlobalPrescalesVetosFract object";
       return std::make_unique<const L1TGlobalPrescalesVetosFract>();
     }
   }
  
   int default_bxmask_row = -1;
   typedef std::pair<unsigned long, unsigned long> Range_t;
   // auto comp = [] (Range_t a, Range_t b){ return a.first < b.first; };
   struct RangeComp_t {
     bool operator()(const Range_t &a, const Range_t &b) const { return a.first < b.first; }
   };
   std::map<std::string, std::set<Range_t, RangeComp_t>> non_default_bx_ranges;
  
   for (unsigned int row = 0; row < bx_algo_name.size(); row++) {
     const std::string &s1 = bx_algo_name[row];
     const std::string &s2 = bx_range[row];
     // find "all" broadcast keywords
     bool broadcastAlgo = false;
     bool broadcastRange = false;
     if (strcasecmp("all", s1.c_str()) == 0)
       broadcastAlgo = true;
     if (strcasecmp("all", s2.c_str()) == 0)
       broadcastRange = true;
     // ALL-ALL-default:
     if (broadcastAlgo && broadcastRange) {
       if (row != 0) {
         edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
             << "\nWarning: ALL-ALL row is not the first one, ignore it assuming 1 (unmasked) as the default"
             << std::endl;
         continue;
       }
       if (default_bxmask_row >= 0) {
         edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
             << "\nWarning: multiple ALL-ALL rows found, using the first" << std::endl;
         continue;
       }
       default_bxmask_row = row;
       m_bx_mask_default = bx_mask[row];
       continue;
     }
     // interpret the range
     unsigned long first = 0, last = 0;
     if (broadcastRange) {
       first = 0;
       last = 3563;
     } else {
       char *dash = nullptr;
       first = strtoul(s2.data(), &dash, 0);
       while (*dash != '\0' && *dash != '-')
         ++dash;
       last = (*dash != '\0' ? strtoul(++dash, &dash, 0) : first);
       if (first == 3564)
         first = 0;
       if (last == 3564)
         last = 0;
       // what could possibly go wrong?
       if (*dash != '\0') {
         edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
             << "\nWarning: parsing " << s2 << " as [" << first << "," << last << "] range" << std::endl;
       }
       if (first > 3563) {
         edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
             << "\nWarning: start of interval is out of range: " << s2 << ", skipping the row" << std::endl;
         continue;
       }
       if (last > 3563) {
         last = 3563;
         edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
             << "\nWarning: end of interval is out of range: " << s2 << ", force [" << first << "," << last << "] range"
             << std::endl;
       }
       if (first > last) {
         edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
             << "\nWarning: inverse/spillover range " << s2 << ", accounting for circular orbit as [0," << last
             << "] & [" << first << ",3563]" << std::endl;
       }
     }
     // {algo,ALL}-{range,ALL}-{0,1}:
     std::vector<std::string> algos;
     std::vector<std::pair<unsigned long, unsigned long>> orderedRanges;
     if (first <= last) {
       if (!broadcastAlgo) {
         algos.push_back(bx_algo_name[row]);
         orderedRanges.push_back(std::make_pair(first, last));
       } else {
         for (const auto &i : non_default_bx_ranges) {
           algos.push_back(i.first);
           orderedRanges.push_back(std::make_pair(first, last));
         }
       }
     } else {
       if (!broadcastAlgo) {
         algos.push_back(bx_algo_name[row]);
         algos.push_back(bx_algo_name[row]);
         orderedRanges.push_back(std::make_pair(0, last));
         orderedRanges.push_back(std::make_pair(first, 3563));
       } else {
         for (const auto &i : non_default_bx_ranges) {
           algos.push_back(i.first);
           algos.push_back(i.first);
           orderedRanges.push_back(std::make_pair(0, last));
           orderedRanges.push_back(std::make_pair(first, 3563));
         }
       }
     }
  
     for (unsigned int item = 0; item < algos.size(); item++) {
       const std::string &algoName = algos[item];
       unsigned int first = orderedRanges[item].first;
       unsigned int last = orderedRanges[item].second;
  
       std::set<Range_t, RangeComp_t> &ranges = non_default_bx_ranges[algoName];
       //           .insert
       //           (
       //               std::pair< std::string, std::set<Range_t,RangeComp_t> >
       //               (
       //                   algoName,  std::set<Range_t,RangeComp_t>()
       //               )
       //           ).first->second; // I don't care if insert was successfull or if I've got a hold on existing range
  
       // current range may or may not overlap with the already present ranges
       // if end of the predecessor starts before begin of the current range and begin
       //  of the successor starts after end of the current range there is no overlap
       //  and I save this range only if it has mask different from the default
       //  otherwise modify predecessor/successor ranges accordingly
       std::set<Range_t>::iterator curr = ranges.end();  // inserted range
       std::set<Range_t>::iterator succ =
           ranges.lower_bound(std::make_pair(first, last));  // successor starts at current or later
       std::set<Range_t>::iterator pred = succ;
       if (pred != ranges.begin())
         pred--;
       else
         pred = ranges.end();
  
       if ((pred == ranges.end() || pred->second < first) && (succ == ranges.end() || succ->first > last)) {
         // no overlap
         if (m_bx_mask_default != bx_mask[row])
           curr = ranges.insert(std::make_pair(first, last)).first;
         // do nothing if this is a default-mask interval
       } else {
         // pred/succ iterators are read-only, create intermediate adjusted copies
         Range_t newPred, newSucc;
         bool modifiedPred = false, gapInPred = false, modifiedSucc = false, dropSucc = false;
         // overlap found with predecessor range
         if (pred != ranges.end() && pred->second >= first && pred->second <= last) {
           if (m_bx_mask_default != bx_mask[row]) {
             if (last == pred->second) {
               // both ranges end in the same place - nothing to do
               modifiedPred = false;
             } else {
               // extend predecessor range
               newPred.first = pred->first;
               newPred.second = last;
               modifiedPred = true;
             }
           } else {
             // shrink predecessor range
             newPred.first = pred->first;
             newPred.second = first - 1;  // non-negative for the predecessor by design
             // by design pred->first < first, so the interval above is always valid
             modifiedPred = true;
           }
         }
         // current range is fully contained in predecessor
         if (pred != ranges.end() && pred->second > first && pred->second > last) {
           if (m_bx_mask_default != bx_mask[row]) {
             // no change to the predecessor range
             modifiedPred = false;
           } else {
             // make a "gap" in predecessor range
             newPred.first = first;
             newPred.second = last;
             gapInPred = true;
             modifiedPred = true;
           }
         }
         // overlap found with successor range
         if (succ != ranges.end() && succ->first <= last) {
           if (m_bx_mask_default != bx_mask[row]) {
             // extend successor range
             newSucc.first = first;
             newSucc.second = succ->second;
           } else {
             // shrink successor range
             newSucc.first = last + 1;
             newSucc.second = succ->second;
             if (newSucc.first > 3563 || newSucc.first > newSucc.second)
               dropSucc = true;
           }
           modifiedSucc = true;
         }
         // overlap found with both, predecessor and successor, such that I need to merge them
         if (modifiedPred && modifiedSucc && newPred.second >= newSucc.first) {
           // make newPred and newSucc identical just in case
           newPred.second = newSucc.second;
           newSucc.first = newPred.first;
           ranges.erase(pred, ++succ);
           curr = ranges.insert(newPred).first;
         } else {
           // merging is not the case, but I still need to propagate the new ranges back to the source
           if (modifiedPred) {
             if (!gapInPred) {
               ranges.erase(pred);
               curr = ranges.insert(newPred).first;
             } else {
               // make a gap by splitting predecessor into two ranges
               Range_t r1(pred->first, newPred.first - 1);  // non-negative for the predecessor by design
               Range_t r2(newPred.second + 1, pred->second);
               ranges.erase(pred);
               ranges.insert(r1);
               ranges.insert(r2);
               curr = ranges.end();  // gap cannot cover any additional ranges
             }
           }
           if (modifiedSucc) {
             ranges.erase(succ);
             if (!dropSucc)
               curr = ranges.insert(newSucc).first;
           }
         }
       }
       // if current range spans over few more ranges after the successor
       //  remove those from the consideration up until the last covered range
       //  that may or may not extend beyond the current range end
       if (curr != ranges.end()) {  // insertion took place
         std::set<Range_t, RangeComp_t>::iterator last_covered = ranges.upper_bound(std::make_pair(curr->second, 0));
         if (last_covered != ranges.begin())
           last_covered--;
         else
           last_covered = ranges.end();
  
         if (last_covered != ranges.end() && last_covered->first != curr->first) {
           // ranges is not empty and last_covered is not current itself (i.e. it is different)
           if (curr->second < last_covered->second) {
             // the range needs to be extended
             Range_t newRange(curr->first, last_covered->second);
             ranges.erase(curr);
             curr = ranges.insert(newRange).first;
           }
           ranges.erase(++curr, last_covered);
         }
       }
     }
   }
  
   if (default_bxmask_row < 0) {
     edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
         << "\nWarning: No default found in BX mask xml, used 1 (unmasked) as default" << std::endl;
   }
  
   for (auto &algo : non_default_bx_ranges) {
     const std::string &algoName = algo.first;
     unsigned int algoBit = algoName2bit[algoName];
     for (auto range : algo.second)
       for (unsigned int bx = range.first; bx <= range.second; bx++) {
         triggerAlgoBxMaskAlgoTrig[bx].push_back(algoBit);
       }
   }
  
   // Set prescales to zero if masked
   for (unsigned int iSet = 0; iSet < prescales.size(); iSet++) {
     for (unsigned int iBit = 0; iBit < prescales[iSet].size(); iBit++) {
       // Add protection in case prescale table larger than trigger mask size
       if (iBit >= triggerMasks.size()) {
         edm::LogError("L1-O2O: L1TGlobalPrescalesVetosOnlineProd")
             << "\nWarning: algoBit in prescale table >= triggerMasks.size() "
             << "\nWarning: no information on masking bit or not, setting as unmasked " << std::endl;
       } else {
         prescales[iSet][iBit] *= triggerMasks[iBit];
       }
     }
   }
  
  
   l1t::PrescalesVetosFractHelper data_(new L1TGlobalPrescalesVetosFract());
  
   data_.setBxMaskDefault(m_bx_mask_default);
   data_.setPrescaleFactorTable(prescales);
   data_.setTriggerMaskVeto(triggerVetoMasks);
   data_.setTriggerAlgoBxMask(triggerAlgoBxMaskAlgoTrig);
  
   auto payload = std::make_unique<const L1TGlobalPrescalesVetosFract>(*data_.getWriteInstance());
  
   edm::LogInfo("L1-O2O: L1TCaloParamsOnlineProd") << "SummaryForFunctionManager: uGTrs | OK      | All looks good";
  
   return payload;
 }

References a, l1t::TriggerSystem::addProcessor(), MillePedeAlignmentAlgorithm_cfi::algoName, jets_cff::algos, mps_setup::append, b, l1t::OMDSReader::basicQuery(), l1GtPatternGenerator_cfi::bx, cuy::col, HLT_FULL_cff::distance, MillePedeFileConverter_cfg::e, l1t::OnlineDBqueryHelper::fetch(), l1t::OMDSReader::QueryResults::fillVariable(), first, l1t::TriggerSystem::getParameters(), l1t::PrescalesVetosFractHelper::getWriteInstance(), mps_fire::i, createfilelist::int, B2GTnPMonitor_cfi::item, dqmdumpme::last, L1ConfigOnlineProdBaseExt< L1TGlobalPrescalesVetosFractO2ORcd, L1TGlobalPrescalesVetosFract >::m_omdsReader, l1t::OMDSReader::QueryResults::numberRows(), skim900GeV_StreamA_MinBiasPD_cfg::output1, skim900GeV_StreamA_MinBiasPD_cfg::output2, skim900GeV_StreamA_MinBiasPD_cfg::output3, jets_cff::payload, hltrates_dqm_sourceclient-live_cfg::prescales, l1t::OMDSReader::QueryResults::queryFailed(), diffTwoXMLs::r1, diffTwoXMLs::r2, FastTimerService_cff::range, diffTwoXMLs::ranges, l1t::XmlConfigParser::readDOMFromString(), l1t::XmlConfigParser::readRootElement(), alignCSCRings::s, l1t::PrescalesVetosFractHelper::setBxMaskDefault(), l1t::TriggerSystem::setConfigured(), l1t::PrescalesVetosFractHelper::setPrescaleFactorTable(), l1t::PrescalesVetosFractHelper::setTriggerAlgoBxMask(), l1t::PrescalesVetosFractHelper::setTriggerMaskVeto(), l1t::OMDSReader::singleAttribute(), AlCaHLTBitMon_QueryRunRegistry::string, transactionSafe, and PbPb_ZMuSkimMuonDPG_cff::veto.

Member Data Documentation

◆ transactionSafe

bool L1TGlobalPrescalesVetosOnlineProd::transactionSafe

private

Definition at line 31 of file L1TGlobalPrescalesVetosOnlineProd.cc.

Referenced by L1TGlobalPrescalesVetosOnlineProd(), and newObject().

Public Member Functions

Private Attributes

Additional Inherited Members