Inheritance diagram for L1RCTOmdsFedVectorProducer:

Public Types
using	ReturnType = std::unique_ptr< RunInfo >

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

ReturnType	produce (const RunInfoRcd &)

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

Private Attributes
std::string	authpath

std::string	connectionString

std::string	tableToRead

edm::ESGetToken< RunInfo, RunInfoRcd >	token_

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

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)

Detailed Description

Description: [one line class summary]

Implementation: [Notes on implementation]

Definition at line 53 of file L1RCTOmdsFedVectorProducer.cc.

Member Typedef Documentation

◆ ReturnType

using L1RCTOmdsFedVectorProducer::ReturnType = std::unique_ptr<RunInfo>

Definition at line 58 of file L1RCTOmdsFedVectorProducer.cc.

Constructor & Destructor Documentation

◆ L1RCTOmdsFedVectorProducer()

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

Definition at line 82 of file L1RCTOmdsFedVectorProducer.cc.

References edm::ESProducer::setWhatProduced(), and token_.

     : connectionString(iConfig.getParameter<std::string>("connectionString")),
       authpath(iConfig.getParameter<std::string>("authpath")),
       tableToRead(iConfig.getParameter<std::string>("tableToRead")) {
   //the following line is needed to tell the framework what
   // data is being produced
   token_ = setWhatProduced(this, "OmdsFedVector").consumes();
 
   //now do what ever other initialization is needed
 }

◆ ~L1RCTOmdsFedVectorProducer()

L1RCTOmdsFedVectorProducer::~L1RCTOmdsFedVectorProducer ( )

override

Definition at line 93 of file L1RCTOmdsFedVectorProducer.cc.

                                                         {
   // do anything here that needs to be done at desctruction time
   // (e.g. close files, deallocate resources etc.)
 }

Member Function Documentation

◆ produce()

L1RCTOmdsFedVectorProducer::ReturnType L1RCTOmdsFedVectorProducer::produce ( const RunInfoRcd & iRecord )

Definition at line 103 of file L1RCTOmdsFedVectorProducer.cc.

References authpath, connectionString, cond::persistency::Session::coralSession(), edm::eventsetup::EventSetupRecordImplementation< T >::get(), python.rootplot.root2matplotlib::replace(), convertSQLiteXML::runNumber, cond::persistency::ConnectionPool::setAuthenticationPath(), contentValuesCheck::ss, cond::persistency::Transaction::start(), cms::cuda::stream, AlCaHLTBitMon_QueryRunRegistry::string, edmLumisInFiles::summary, tableToRead, token_, cond::persistency::Session::transaction(), and heppy_batch::val.

                                                                                                   {
   //  std::cout << "ENTERING L1RCTOmdsFedVectorProducer::produce()" << std::endl;
 
   //  std::cout << "GETTING FED VECTOR FROM OMDS" << std::endl;
 
   // GETTING ALREADY-EXISTING RUNINFO OUT OF ES TO FIND OUT RUN NUMBER
   const RunInfo* summary = &iRecord.get(token_);
   int runNumber = summary->m_run;
 
   // CREATING NEW RUNINFO WHICH WILL GET NEW FED VECTOR AND BE RETURNED
   auto pRunInfo = std::make_unique<RunInfo>();
 
   // DO THE DATABASE STUFF
 
   //make connection object
   cond::persistency::ConnectionPool connection;
 
   //set in configuration object authentication path
   connection.setAuthenticationPath(authpath);
   connection.configure();
 
   //create session object from connection
   cond::persistency::Session session = connection.createSession(connectionString, true);
 
   session.transaction().start(true);  // (true=readOnly)
 
   coral::ISchema& schema = session.coralSession().schema("CMS_RUNINFO");
 
   //condition
   coral::AttributeList conditionData;
   conditionData.extend<int>("n_run");
   conditionData[0].data<int>() = runNumber;
 
   std::string columnToRead_val = "VALUE";
 
   std::string tableToRead_fed = "RUNSESSION_STRING";
   coral::IQuery* queryV = schema.newQuery();
   queryV->addToTableList(tableToRead);
   queryV->addToTableList(tableToRead_fed);
   queryV->addToOutputList(tableToRead_fed + "." + columnToRead_val, columnToRead_val);
   //queryV->addToOutputList(tableToRead + "." + columnToRead, columnToRead);
   //condition
   std::string condition =
       tableToRead + ".RUNNUMBER=:n_run AND " + tableToRead +
       ".NAME='CMS.LVL0:FED_ENABLE_MASK' AND RUNSESSION_PARAMETER.ID = RUNSESSION_STRING.RUNSESSION_PARAMETER_ID";
   //std::string condition = tableToRead + ".runnumber=:n_run AND " + tableToRead + ".name='CMS.LVL0:FED_ENABLE_MASK'";
   queryV->setCondition(condition, conditionData);
   coral::ICursor& cursorV = queryV->execute();
   std::string fed;
   if (cursorV.next()) {
     //cursorV.currentRow().toOutputStream(std::cout) << std::endl;
     const coral::AttributeList& row = cursorV.currentRow();
     fed = row[columnToRead_val].data<std::string>();
   } else {
     fed = "null";
   }
   //std::cout << "string fed emask == " << fed << std::endl;
   delete queryV;
 
   std::replace(fed.begin(), fed.end(), '%', ' ');
   std::stringstream stream(fed);
   for (;;) {
     std::string word;
     if (!(stream >> word)) {
       break;
     }
     std::replace(word.begin(), word.end(), '&', ' ');
     std::stringstream ss(word);
     int fedNumber;
     int val;
     ss >> fedNumber >> val;
     //std::cout << "fed:: " << fed << "--> val:: " << val << std::endl;
     //val bit 0 represents the status of the SLINK, but 5 and 7 means the SLINK/TTS is ON but NA or BROKEN (see mail of alex....)
     if ((val & 0001) == 1 && (val != 5) && (val != 7))
       pRunInfo->m_fed_in.push_back(fedNumber);
   }
   //   std::cout << "feds in run:--> ";
   //   std::copy(pRunInfo->m_fed_in.begin(), pRunInfo->m_fed_in.end(), std::ostream_iterator<int>(std::cout, ", "));
   //   std::cout << std::endl;
   /*
     for (size_t i =0; i<pRunInfo->m_fed_in.size() ; ++i)
     {
     std::cout << "fed in run:--> " << pRunInfo->m_fed_in[i] << std::endl;
     }
   */
 
   return pRunInfo;
 }