#include <RecoLuminosity/LumiProducer/src/LumiCorrectionSource.cc>

Inheritance diagram for LumiCorrectionSource:

Public Types
typedef std::shared_ptr< const LumiCorrectionParam >	ReturnParamType

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

ReturnParamType	produceLumiCorrectionParam (const LumiCorrectionParamRcd &)

	~LumiCorrectionSource () override

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

	ESProducer (const ESProducer &)=delete

	ESProducer (ESProducer &&)=delete

ESResolverIndex 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 &	operator= (const ESProducer &)=delete

ESProducer &	operator= (ESProducer &&)=delete

SerialTaskQueueChain &	queue ()

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

void	updateLookup (eventsetup::ESRecordsToProductResolverIndices const &) final

	~ESProducer () noexcept(false) override

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

	ESProductResolverFactoryProducer (const ESProductResolverFactoryProducer &)=delete

const ESProductResolverFactoryProducer &	operator= (const ESProductResolverFactoryProducer &)=delete

	~ESProductResolverFactoryProducer () noexcept(false) override

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

const ComponentDescription &	description () const

	ESProductResolverProvider ()

	ESProductResolverProvider (const ESProductResolverProvider &)=delete

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

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

bool	isUsingRecord (const EventSetupRecordKey &key) const

KeyedResolvers &	keyedResolvers (const EventSetupRecordKey &iRecordKey, unsigned int iovIndex=0)

const ESProductResolverProvider &	operator= (const ESProductResolverProvider &)=delete

void	setAppendToDataLabel (const edm::ParameterSet &)

void	setDescription (const ComponentDescription &iDescription)

std::set< EventSetupRecordKey >	usingRecords () const

virtual	~ESProductResolverProvider () noexcept(false)

Public Member Functions inherited from edm::EventSetupRecordIntervalFinder
bool	concurrentFinder () const

const eventsetup::ComponentDescription &	descriptionForFinder () const

	EventSetupRecordIntervalFinder ()

	EventSetupRecordIntervalFinder (const EventSetupRecordIntervalFinder &)=delete

std::set< eventsetup::EventSetupRecordKey >	findingForRecords () const

const ValidityInterval &	findIntervalFor (const eventsetup::EventSetupRecordKey &, const IOVSyncValue &)

bool	nonconcurrentAndIOVNeedsUpdate (const eventsetup::EventSetupRecordKey &key, const IOVSyncValue &syncValue) const

const EventSetupRecordIntervalFinder &	operator= (const EventSetupRecordIntervalFinder &)=delete

void	resetInterval (const eventsetup::EventSetupRecordKey &)

void	setDescriptionForFinder (const eventsetup::ComponentDescription &iDescription)

virtual	~EventSetupRecordIntervalFinder () noexcept(false)

Protected Member Functions
void	setIntervalFor (const edm::eventsetup::EventSetupRecordKey &, const edm::IOVSyncValue &, edm::ValidityInterval &) override

Protected Member Functions inherited from edm::ESProducer
ESConsumesInfo *	consumesInfoPushBackNew ()

unsigned int	consumesInfoSize () const

template<typename CallbackT , typename TList , typename TRecord >
void	registerProducts (std::shared_ptr< std::pair< unsigned int, std::shared_ptr< CallbackT >>> iCallback, const TList , const TRecord iRecord, const es::Label &iLabel)

template<typename CallbackT , typename TRecord >
void	registerProducts (std::shared_ptr< std::pair< unsigned int, std::shared_ptr< CallbackT >>>, const eventsetup::produce::Null , const TRecord , const es::Label &)

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

template<typename T >
auto	setWhatProduced (T iThis, const char 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 TDecorator >
auto	setWhatProduced (T iThis, TReturn(T ::iMethod)(const TRecord &), const TDecorator &iDec, const es::Label &iLabel={})

template<typename TFunc >
auto	setWhatProduced (TFunc &&func, const es::Label &iLabel={})

template<typename TReturn , typename TRecord , typename TFunc , typename TDecorator >
ESConsumesCollectorT< TRecord >	setWhatProduced (TFunc &&func, TDecorator &&iDec, const es::Label &iLabel={})

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

Protected Member Functions inherited from edm::ESProductResolverFactoryProducer
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::ESProductResolverFactoryBase > iFactory, const std::string &iLabel=std::string())

KeyedResolversVector	registerResolvers (const EventSetupRecordKey &, unsigned int iovIndex) override

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

void	usingRecordWithKey (const EventSetupRecordKey &key)

Protected Member Functions inherited from edm::EventSetupRecordIntervalFinder
template<class T >
void	findingRecord ()

void	findingRecordWithKey (const eventsetup::EventSetupRecordKey &)

Private Member Functions
float	fetchIntglumi (coral::ISchema &schema, unsigned int runnumber)

void	fillparamcache (unsigned int runnumber)

void	parseGlobaltagForLumi (coral::ISchema &schema, const std::string &globaltag)

void	reloadAuth ()

XMLCh *	s2x (const std::string &input) const

const std::string	servletTranslation (const std::string &servlet) const

std::string	toParentString (const xercesc::DOMNode &nodeToConvert) const

std::string	translateFrontierConnect (const std::string &connectStr)

std::string	x2s (const XMLCh *input) const

Private Attributes
std::string	m_authfilename

unsigned int	m_cachesize

std::string	m_connectStr

std::string	m_datatag

std::string	m_globaltag

bool	m_isNullRun

std::string	m_normtag

std::map< unsigned int, std::shared_ptr< const LumiCorrectionParam > >	m_paramcache

unsigned int	m_paramcachedrun

std::shared_ptr< const LumiCorrectionParam >	m_paramresult

const edm::IOVSyncValue *	m_pcurrentTime

std::string	m_siteconfpath

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

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

Protected Types inherited from edm::eventsetup::ESProductResolverProvider
using	KeyedResolversVector = std::vector< std::pair< DataKey, std::shared_ptr< ESProductResolver > >>

Detailed Description

retrieve lumi corrections and perrun parameters needed by the correction funcs

Description: A essource/esproducer for lumi correction factor and run parameters needed to deduce the corrections Author: Zhen Xie

Definition at line 25 of file LumiCorrectionSource.h.

Member Typedef Documentation

◆ ReturnParamType

typedef std::shared_ptr<const LumiCorrectionParam> LumiCorrectionSource::ReturnParamType

Definition at line 28 of file LumiCorrectionSource.h.

Constructor & Destructor Documentation

◆ LumiCorrectionSource()

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

Definition at line 170 of file LumiCorrectionSource.cc.

References l1RCTOmdsFedVectorProducer_cfi::authpath, edm::ParameterSet::exists(), edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), download_sqlite_cfg::globaltag, m_authfilename, m_cachesize, m_connectStr, m_datatag, m_globaltag, m_normtag, m_siteconfpath, castor_dqm_sourceclient_file_cfg::path, produceLumiCorrectionParam(), edm::ESProducer::setWhatProduced(), AlCaHLTBitMon_QueryRunRegistry::string, and translateFrontierConnect().

     : m_connectStr(""),
       m_authfilename(""),
       m_datatag(""),
       m_globaltag(""),
       m_normtag(""),
       m_paramcachedrun(0),
       m_cachesize(0) {
   setWhatProduced(this, &LumiCorrectionSource::produceLumiCorrectionParam);
   findingRecord<LumiCorrectionParamRcd>();
   std::string connectStr = iConfig.getParameter<std::string>("connect");
   std::string globaltag;
   if (iConfig.exists("globaltag")) {
     m_globaltag = iConfig.getUntrackedParameter<std::string>("globaltag", "");
   } else {
     m_normtag = iConfig.getUntrackedParameter<std::string>("normtag", "");
   }
   m_datatag = iConfig.getUntrackedParameter<std::string>("datatag", "");
   m_cachesize = iConfig.getUntrackedParameter<unsigned int>("ncacheEntries", 3);
   m_siteconfpath = iConfig.getUntrackedParameter<std::string>("siteconfpath", "");
   const std::string fproto("frontier://");
   if (connectStr.substr(0, fproto.length()) == fproto) {
     m_connectStr = translateFrontierConnect(connectStr);
   } else if (connectStr.substr(0, 11) == "sqlite_file") {
     m_connectStr = connectStr;
   } else {
     m_connectStr = connectStr;
     std::string authpath = iConfig.getUntrackedParameter<std::string>("authpath", "");
     std::filesystem::path boostAuthPath(authpath);
     if (std::filesystem::is_directory(boostAuthPath)) {
       boostAuthPath /= std::filesystem::path("authentication.xml");
     }
     m_authfilename = boostAuthPath.string();
   }
 }

◆ ~LumiCorrectionSource()

LumiCorrectionSource::~LumiCorrectionSource ( )

override

Definition at line 410 of file LumiCorrectionSource.cc.

410 {}

Member Function Documentation

◆ fetchIntglumi()

float LumiCorrectionSource::fetchIntglumi	(	coral::ISchema &	schema,
		unsigned int	runnumber
	)

private

Definition at line 386 of file LumiCorrectionSource.cc.

References lumi::LumiNames::intglumiv2TableName(), mps_fire::result, cond::runnumber, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by fillparamcache().

                                                                                       {
   float result = 0.;
   coral::IQuery* qHandle = schema.newQuery();
   qHandle->addToTableList(lumi::LumiNames::intglumiv2TableName());
   coral::AttributeList qResult;
   qResult.extend("INTGLUMI", typeid(float));
   std::string conditionStr("RUNNUM=:runnumber");
   coral::AttributeList qCondition;
   qCondition.extend("runnumber", typeid(unsigned int));
   qCondition["runnumber"].data<unsigned int>() = runnumber;
   qHandle->setCondition(conditionStr, qCondition);
   qHandle->addToOutputList("INTGLUMI");
   qHandle->defineOutput(qResult);
   coral::ICursor& intglumiCursor = qHandle->execute();
   while (intglumiCursor.next()) {
     const coral::AttributeList& row = intglumiCursor.currentRow();
     if (!row["INTGLUMI"].isNull()) {
       result = row["INTGLUMI"].data<float>();
     }
   }
   delete qHandle;
   return result;
 }

◆ fillparamcache()

void LumiCorrectionSource::fillparamcache ( unsigned int runnumber )

private

Definition at line 242 of file LumiCorrectionSource.cc.

References lumi::RevisionDML::currentHFDataTagId(), lumi::RevisionDML::dataIDForRun(), Exception, fetchIntglumi(), dqmdumpme::first, LumiCorrectionParam::HF, lumi::NormDML::HF, lumi::RevisionDML::HFDataTagIdByName(), instance, lumi::RevisionDML::DataID::lumi_id, cond::lumiid, m_authfilename, m_connectStr, m_datatag, m_globaltag, m_normtag, m_paramcache, m_paramcachedrun, eostools::move(), lumi::NormDML::normById(), lumi::NormDML::normIdByName(), lumi::NormDML::normIdByType(), parseGlobaltagForLumi(), reloadAuth(), mps_fire::result, cond::runnumber, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by produceLumiCorrectionParam().

                                                                 {
   m_paramcache.clear();
   m_paramcachedrun = runnumber;
   if (!m_authfilename.empty()) {
     coral::IHandle<coral::IAuthenticationService> authSvc =
         coral::Context::instance().query<coral::IAuthenticationService>();
     if (authSvc.isValid()) {
       try {
         authSvc->credentials(m_connectStr);
       } catch (const coral::UnknownConnectionException& er) {
         reloadAuth();
       }
     } else {
       reloadAuth();
     }
   }
   coral::ConnectionService* mydbservice = new coral::ConnectionService;
   if (!m_globaltag.empty()) {
     coral::ISessionProxy* gsession = mydbservice->connect(m_connectStr, coral::ReadOnly);
     gsession->transaction().start(true);
     parseGlobaltagForLumi(gsession->nominalSchema(), m_globaltag);
     gsession->transaction().commit();
     delete gsession;
   }
   coral::ISessionProxy* session = mydbservice->connect(m_connectStr, coral::ReadOnly);
   coral::ITypeConverter& tconverter = session->typeConverter();
   tconverter.setCppTypeForSqlType(std::string("float"), std::string("FLOAT(63)"));
   tconverter.setCppTypeForSqlType(std::string("unsigned int"), std::string("NUMBER(10)"));
   tconverter.setCppTypeForSqlType(std::string("unsigned short"), std::string("NUMBER(1)"));
   auto result = std::make_unique<LumiCorrectionParam>(LumiCorrectionParam::HF);
   try {
     session->transaction().start(true);
     coral::ISchema& schema = session->nominalSchema();
     lumi::RevisionDML dml;
     unsigned long long tagid = 0;
     if (m_datatag.empty()) {
       tagid = dml.currentHFDataTagId(schema);  //get datatag id
     } else {
       tagid = dml.HFDataTagIdByName(schema, m_datatag);
     }
     lumi::RevisionDML::DataID dataid = dml.dataIDForRun(schema, runnumber, tagid);  //get data id
     unsigned int lumiid = dataid.lumi_id;
     if (lumiid == 0) {
       result->setNBX(0);
       std::shared_ptr<const LumiCorrectionParam> const_result = std::move(result);
       m_paramcache.insert(std::make_pair(runnumber, const_result));
       session->transaction().commit();
       delete session;
       delete mydbservice;
       return;
     }
 
     coral::AttributeList lumidataBindVariables;
     lumidataBindVariables.extend("dataid", typeid(unsigned long long));
     lumidataBindVariables["dataid"].data<unsigned long long>() = lumiid;
     std::string conditionStr("DATA_ID=:dataid");
     coral::AttributeList lumiparamOutput;
     lumiparamOutput.extend("NCOLLIDINGBUNCHES", typeid(unsigned int));
     coral::IQuery* lumiparamQuery = schema.newQuery();
     lumiparamQuery->addToTableList(std::string("LUMIDATA"));
     lumiparamQuery->setCondition(conditionStr, lumidataBindVariables);
     lumiparamQuery->addToOutputList("NCOLLIDINGBUNCHES");
     lumiparamQuery->defineOutput(lumiparamOutput);
     coral::ICursor& lumiparamcursor = lumiparamQuery->execute();
     unsigned int ncollidingbx = 0;
     while (lumiparamcursor.next()) {
       const coral::AttributeList& row = lumiparamcursor.currentRow();
       if (!row["NCOLLIDINGBUNCHES"].isNull()) {
         ncollidingbx = row["NCOLLIDINGBUNCHES"].data<unsigned int>();
       }
       result->setNBX(ncollidingbx);
     }
     delete lumiparamQuery;
     lumi::NormDML normdml;
     unsigned long long normid = 0;
     std::map<std::string, unsigned long long> normidmap;
     if (m_normtag.empty()) {
       normdml.normIdByType(schema, normidmap, lumi::NormDML::HF, true);
       m_normtag = normidmap.begin()->first;
       normid = normidmap.begin()->second;
     } else {
       normid = normdml.normIdByName(schema, m_normtag);
     }
 
     std::map<unsigned int, lumi::NormDML::normData> normDataMap;
     normdml.normById(schema, normid, normDataMap);
 
     std::map<unsigned int, lumi::NormDML::normData>::iterator normIt = --normDataMap.end();
     if (runnumber < normIt->first) {
       normIt = normDataMap.upper_bound(runnumber);
       --normIt;
     }
     result->setNormtag(m_normtag);
     result->setcorrFunc(normIt->second.corrfunc);
     result->setnonlinearCoeff(normIt->second.coefficientmap);
     result->setafterglows(normIt->second.afterglows);
     result->setdescription(normIt->second.amodetag, normIt->second.beamegev);
     if (normIt->second.coefficientmap["DRIFT"] != 0.) {
       float intglumi = fetchIntglumi(schema, runnumber);
       result->setintglumi(intglumi);
     }
     m_paramcache.insert(std::make_pair(runnumber, std::shared_ptr<LumiCorrectionParam>(std::move(result))));
     session->transaction().commit();
   } catch (const coral::Exception& er) {
     session->transaction().rollback();
     delete session;
     delete mydbservice;
     throw cms::Exception("DatabaseError ") << er.what();
   }
   delete session;
   delete mydbservice;
 }

◆ parseGlobaltagForLumi()

void LumiCorrectionSource::parseGlobaltagForLumi	(	coral::ISchema &	schema,
		const std::string &	globaltag
	)

private

select i.pfn,i.tagname from TAGINVENTORY_TABLE i,TAGTREE_TABLE_GLOBALTAG v from i.tagid=v.tagid and i.recordname='LumiCorrectionParamRcd'

Definition at line 354 of file LumiCorrectionSource.cc.

References download_sqlite_cfg::globaltag, m_connectStr, m_normtag, AlCaHLTBitMon_QueryRunRegistry::string, and translateFrontierConnect().

Referenced by fillparamcache().

                                                                                                  {
   std::string tagtreetabname("TAGTREE_TABLE_");
   tagtreetabname += std::string(globaltag);
   coral::IQuery* qHandle = schema.newQuery();
   qHandle->addToTableList("TAGINVENTORY_TABLE", "i");
   qHandle->addToTableList(tagtreetabname, "v");
   coral::AttributeList qResult;
   qResult.extend("pfn", typeid(std::string));
   qResult.extend("tagname", typeid(std::string));
   std::string conditionStr("v.tagid=i.tagid and i.recordname=:recordname");
   coral::AttributeList qCondition;
   qCondition.extend("recordname", typeid(std::string));
   qCondition["recordname"].data<std::string>() = std::string("LumiCorrectionParamRcd");
   qHandle->setCondition(conditionStr, qCondition);
   qHandle->addToOutputList("i.pfn");
   qHandle->addToOutputList("i.tagname");
   qHandle->defineOutput(qResult);
   coral::ICursor& iCursor = qHandle->execute();
   while (iCursor.next()) {
     const coral::AttributeList& row = iCursor.currentRow();
     std::string connectStr = row["pfn"].data<std::string>();
     const std::string fproto("frontier://");
     if (connectStr.substr(0, fproto.length()) == fproto) {
       m_connectStr = translateFrontierConnect(connectStr);
     } else {
       m_connectStr = connectStr;
     }
     m_normtag = row["tagname"].data<std::string>();
   }
   delete qHandle;
 }

◆ produceLumiCorrectionParam()

LumiCorrectionSource::ReturnParamType LumiCorrectionSource::produceLumiCorrectionParam ( const LumiCorrectionParamRcd & )

Definition at line 206 of file LumiCorrectionSource.cc.

References dqmiodumpmetadata::currentrun, edm::IOVSyncValue::eventID(), fillparamcache(), m_paramcache, m_paramcachedrun, m_paramresult, m_pcurrentTime, and edm::EventID::run().

Referenced by LumiCorrectionSource().

                                                                                                                   {
   unsigned int currentrun = m_pcurrentTime->eventID().run();
   if (currentrun == 0 || currentrun == 4294967295) {
     return std::make_shared<const LumiCorrectionParam>();
   }
   if (m_paramcachedrun != currentrun) {                         //i'm in a new run
     fillparamcache(currentrun);                                 //fill cache
   } else {                                                      //i'm in an old run
     if (m_paramcache.find(currentrun) == m_paramcache.end()) {  //i'm not cached
       fillparamcache(currentrun);                               //
     }
   }
   if (m_paramcache.empty()) {
     return std::make_shared<const LumiCorrectionParam>();
   }
   m_paramresult = m_paramcache[currentrun];
   if (m_paramresult.get() == nullptr) {
     return std::make_shared<const LumiCorrectionParam>();
   }
   return m_paramresult;
 }

◆ reloadAuth()

void LumiCorrectionSource::reloadAuth ( )

private

Definition at line 236 of file LumiCorrectionSource.cc.

References instance, and m_authfilename.

Referenced by fillparamcache().

                                       {
   //std::cout<<"old authfile "<<coral::Context::instance().PropertyManager().property("AuthenticationFile")->get()<<std::endl;
   coral::Context::instance().PropertyManager().property("AuthenticationFile")->set(m_authfilename);
   coral::Context::instance().loadComponent("CORAL/Services/XMLAuthenticationService");
 }

◆ s2x()

XMLCh * LumiCorrectionSource::s2x ( const std::string & input ) const

private

Definition at line 72 of file LumiCorrectionSource.cc.

References groupFilesInBlocks::temp.

Referenced by servletTranslation().

                                                             {
   XMLCh* buff = xercesc::XMLString::transcode(temp.c_str());
   return buff;
 }

◆ servletTranslation()

const std::string LumiCorrectionSource::servletTranslation ( const std::string & servlet ) const

private

Definition at line 101 of file LumiCorrectionSource.cc.

References hcalRecHitTable_cff::doc, MillePedeFileConverter_cfg::e, m_siteconfpath, writedatasetfile::parser, s2x(), AlCaHLTBitMon_QueryRunRegistry::string, toParentString(), and cms::concurrency::xercesInitialize().

Referenced by translateFrontierConnect().

                                                                                        {
   std::string frontierConnect;
   std::string realconnect;
   cms::concurrency::xercesInitialize();
   std::unique_ptr<xercesc::XercesDOMParser> parser(new xercesc::XercesDOMParser);
   try {
     parser->setValidationScheme(xercesc::XercesDOMParser::Val_Auto);
     parser->setDoNamespaces(false);
     parser->parse(m_siteconfpath.c_str());
     xercesc::DOMDocument* doc = parser->getDocument();
     if (!doc) {
       return "";
     }
 
     xercesc::DOMNodeList* frontierConnectList = doc->getElementsByTagName(s2x("frontier-connect"));
     if (frontierConnectList->getLength() > 0) {
       xercesc::DOMElement* frontierConnectElement = static_cast<xercesc::DOMElement*>(frontierConnectList->item(0));
       frontierConnect = toParentString(*frontierConnectElement);
     }
     // Replace the last component of every "serverurl=" piece (up to the
     //   next close-paren) with the servlet
     std::string::size_type nextparen = 0;
     std::string::size_type serverurl, lastslash;
     std::string complexstr = "";
     while ((serverurl = frontierConnect.find("(serverurl=", nextparen)) != std::string::npos) {
       realconnect.append(frontierConnect, nextparen, serverurl - nextparen);
       nextparen = frontierConnect.find(')', serverurl);
       lastslash = frontierConnect.rfind('/', nextparen);
       realconnect.append(frontierConnect, serverurl, lastslash - serverurl + 1);
       realconnect.append(servlet);
     }
     realconnect.append(frontierConnect, nextparen, frontierConnect.length() - nextparen);
   } catch (xercesc::DOMException& e) {
   }
   return realconnect;
 }

◆ setIntervalFor()

void LumiCorrectionSource::setIntervalFor	(	const edm::eventsetup::EventSetupRecordKey &	iKey,
		const edm::IOVSyncValue &	iTime,
		edm::ValidityInterval &	oValidity
	)

overrideprotectedvirtual

Implements edm::EventSetupRecordIntervalFinder.

Definition at line 228 of file LumiCorrectionSource.cc.

References m_pcurrentTime, edm::ValidityInterval::setFirst(), and edm::ValidityInterval::setLast().

                                                                           {
   m_pcurrentTime = &iTime;
   oValidity.setFirst(iTime);
   oValidity.setLast(iTime);
 }

◆ toParentString()

std::string LumiCorrectionSource::toParentString ( const xercesc::DOMNode & nodeToConvert ) const

private

Definition at line 77 of file LumiCorrectionSource.cc.

References mps_fire::i, dqmiolumiharvest::j, and x2s().

Referenced by servletTranslation().

                                                                                         {
   std::ostringstream oss;
   xercesc::DOMNodeList* childList = nodeToConvert.getChildNodes();
 
   unsigned int numNodes = childList->getLength();
   for (unsigned int i = 0; i < numNodes; ++i) {
     xercesc::DOMNode* childNode = childList->item(i);
     if (childNode->getNodeType() != xercesc::DOMNode::ELEMENT_NODE)
       continue;
     xercesc::DOMElement* child = static_cast<xercesc::DOMElement*>(childNode);
     xercesc::DOMNamedNodeMap* attributes = child->getAttributes();
     unsigned int numAttributes = attributes->getLength();
     for (unsigned int j = 0; j < numAttributes; ++j) {
       xercesc::DOMNode* attributeNode = attributes->item(j);
       if (attributeNode->getNodeType() != xercesc::DOMNode::ATTRIBUTE_NODE)
         continue;
       xercesc::DOMAttr* attribute = static_cast<xercesc::DOMAttr*>(attributeNode);
 
       oss << "(" << x2s(child->getTagName()) << x2s(attribute->getName()) << "=" << x2s(attribute->getValue()) << ")";
     }
   }
   return oss.str();
 }

◆ translateFrontierConnect()

std::string LumiCorrectionSource::translateFrontierConnect ( const std::string & connectStr )

private

Definition at line 138 of file LumiCorrectionSource.cc.

References Exception, m_siteconfpath, castor_dqm_sourceclient_file_cfg::path, mps_fire::result, servletTranslation(), AlCaHLTBitMon_QueryRunRegistry::string, createJobs::tmp, and relmon_authenticated_wget::url.

Referenced by LumiCorrectionSource(), and parseGlobaltagForLumi().

                                                                                     {
   std::string result;
   const std::string fproto("frontier://");
   std::string::size_type startservlet = fproto.length();
   std::string::size_type endservlet = connectStr.find('(', startservlet);
   if (endservlet == std::string::npos) {
     endservlet = connectStr.rfind('/', connectStr.length());
   }
   std::string servlet = connectStr.substr(startservlet, endservlet - startservlet);
   if ((!servlet.empty()) && (servlet.find_first_of(":/)[]") == std::string::npos)) {
     if (servlet == "cms_conditions_data")
       servlet = "";
     if (m_siteconfpath.length() == 0) {
       std::string url = (std::filesystem::path("SITECONF") / std::filesystem::path("local") /
                          std::filesystem::path("JobConfig") / std::filesystem::path("site-local-config.xml"))
                             .string();
       char* tmp = std::getenv("CMS_PATH");
       if (tmp) {
         m_siteconfpath = (std::filesystem::path(tmp) / std::filesystem::path(url)).string();
       }
     } else {
       if (!std::filesystem::exists(std::filesystem::path(m_siteconfpath))) {
         throw cms::Exception("Non existing path ") << m_siteconfpath;
       }
       m_siteconfpath =
           (std::filesystem::path(m_siteconfpath) / std::filesystem::path("site-local-config.xml")).string();
     }
     result = fproto + servletTranslation(servlet) + connectStr.substr(endservlet);
   }
   return result;
 }

◆ x2s()

std::string LumiCorrectionSource::x2s ( const XMLCh * input ) const

private

Definition at line 67 of file LumiCorrectionSource.cc.

References AlCaHLTBitMon_QueryRunRegistry::string, and createJobs::tmp.

Referenced by toParentString().

                                                                   {
   std::string tmp(xercesc::XMLString::transcode(toTranscode));
   return tmp;
 }

Member Data Documentation

◆ m_authfilename

std::string LumiCorrectionSource::m_authfilename

private

Definition at line 47 of file LumiCorrectionSource.h.

Referenced by fillparamcache(), LumiCorrectionSource(), and reloadAuth().

◆ m_cachesize

unsigned int LumiCorrectionSource::m_cachesize

private

Definition at line 55 of file LumiCorrectionSource.h.

Referenced by LumiCorrectionSource().

◆ m_connectStr

std::string LumiCorrectionSource::m_connectStr

private

Definition at line 46 of file LumiCorrectionSource.h.

Referenced by fillparamcache(), LumiCorrectionSource(), and parseGlobaltagForLumi().

◆ m_datatag

std::string LumiCorrectionSource::m_datatag

private

Definition at line 48 of file LumiCorrectionSource.h.

Referenced by fillparamcache(), and LumiCorrectionSource().

◆ m_globaltag

std::string LumiCorrectionSource::m_globaltag

private

Definition at line 49 of file LumiCorrectionSource.h.

Referenced by fillparamcache(), and LumiCorrectionSource().

◆ m_isNullRun

bool LumiCorrectionSource::m_isNullRun

private

Definition at line 53 of file LumiCorrectionSource.h.

◆ m_normtag

std::string LumiCorrectionSource::m_normtag

private

Definition at line 50 of file LumiCorrectionSource.h.

Referenced by fillparamcache(), LumiCorrectionSource(), and parseGlobaltagForLumi().

◆ m_paramcache

std::map<unsigned int, std::shared_ptr<const LumiCorrectionParam> > LumiCorrectionSource::m_paramcache

private

Definition at line 52 of file LumiCorrectionSource.h.

Referenced by fillparamcache(), and produceLumiCorrectionParam().

◆ m_paramcachedrun

unsigned int LumiCorrectionSource::m_paramcachedrun

private

Definition at line 54 of file LumiCorrectionSource.h.

Referenced by fillparamcache(), and produceLumiCorrectionParam().

◆ m_paramresult

std::shared_ptr<const LumiCorrectionParam> LumiCorrectionSource::m_paramresult

private

Definition at line 56 of file LumiCorrectionSource.h.

Referenced by produceLumiCorrectionParam().

◆ m_pcurrentTime

const edm::IOVSyncValue* LumiCorrectionSource::m_pcurrentTime

private

Definition at line 57 of file LumiCorrectionSource.h.

Referenced by produceLumiCorrectionParam(), and setIntervalFor().

◆ m_siteconfpath

std::string LumiCorrectionSource::m_siteconfpath

private

Definition at line 51 of file LumiCorrectionSource.h.

Referenced by LumiCorrectionSource(), servletTranslation(), and translateFrontierConnect().

Public Types

Public Member Functions

Protected Member Functions

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Member Typedef Documentation

◆ ReturnParamType

Constructor & Destructor Documentation

◆ LumiCorrectionSource()

◆ ~LumiCorrectionSource()

Member Function Documentation

◆ fetchIntglumi()

◆ fillparamcache()

◆ parseGlobaltagForLumi()

◆ produceLumiCorrectionParam()

◆ reloadAuth()

◆ s2x()

◆ servletTranslation()

◆ setIntervalFor()

◆ toParentString()

◆ translateFrontierConnect()

◆ x2s()

Member Data Documentation

◆ m_authfilename

◆ m_cachesize

◆ m_connectStr

◆ m_datatag

◆ m_globaltag

◆ m_isNullRun

◆ m_normtag

◆ m_paramcache

◆ m_paramcachedrun

◆ m_paramresult

◆ m_pcurrentTime

◆ m_siteconfpath