Inheritance diagram for L1RCTOmdsFedVectorProducer:

Public Types
typedef std::shared_ptr< RunInfo >	ReturnType

Public Types inherited from edm::eventsetup::DataProxyProvider
typedef std::vector< std::pair< DataKey, edm::propagate_const< std::shared_ptr< DataProxy > > > >	KeyedProxies

typedef std::vector< EventSetupRecordKey >	Keys

typedef std::map< EventSetupRecordKey, KeyedProxies >	RecordProxies

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

ReturnType	produce (const RunInfoRcd &)

	~L1RCTOmdsFedVectorProducer ()

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

virtual	~ESProducer ()(false)

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

virtual void	newInterval (const eventsetup::EventSetupRecordKey &iRecordType, const ValidityInterval &iInterval)
	overrides DataProxyProvider method More...

virtual	~ESProxyFactoryProducer () noexcept(false)

Public Member Functions inherited from edm::eventsetup::DataProxyProvider
	DataProxyProvider ()

const ComponentDescription &	description () const

bool	isUsingRecord (const EventSetupRecordKey &) const

const KeyedProxies &	keyedProxies (const EventSetupRecordKey &iRecordKey) const

void	resetProxies (const EventSetupRecordKey &iRecordType)

void	resetProxiesIfTransient (const EventSetupRecordKey &iRecordType)

void	setAppendToDataLabel (const edm::ParameterSet &)

void	setDescription (const ComponentDescription &iDescription)

std::set< EventSetupRecordKey >	usingRecords () const

virtual	~DataProxyProvider () noexcept(false)

Private Attributes
std::string	authpath

std::string	connectionString

std::string	tableToRead

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

Protected Member Functions inherited from edm::ESProducer
template<typename T >
void	setWhatProduced (T *iThis, const es::Label &iLabel=es::Label())

template<typename T >
void	setWhatProduced (T iThis, const char iLabel)

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

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

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

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

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 eventsetup::EventSetupRecordKey &iRecord, std::unique_ptr< eventsetup::ProxyFactoryBase > iFactory, const std::string &iLabel=std::string())

virtual void	registerProxies (const eventsetup::EventSetupRecordKey &iRecord, KeyedProxies &aProxyList)
	override DataProxyProvider method More...

Protected Member Functions inherited from edm::eventsetup::DataProxyProvider
void	eraseAll (const EventSetupRecordKey &iRecordKey)
	deletes all the Proxies in aStream More...

void	invalidateProxies (const EventSetupRecordKey &iRecordKey)

template<class T >
void	usingRecord ()

void	usingRecordWithKey (const EventSetupRecordKey &)

Detailed Description

Description: [one line class summary]

Implementation: [Notes on implementation]

Definition at line 55 of file L1RCTOmdsFedVectorProducer.cc.

Member Typedef Documentation

typedef std::shared_ptr<RunInfo> L1RCTOmdsFedVectorProducer::ReturnType

Definition at line 60 of file L1RCTOmdsFedVectorProducer.cc.

Constructor & Destructor Documentation

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

Definition at line 82 of file L1RCTOmdsFedVectorProducer.cc.

References edm::ESProducer::setWhatProduced().

                                                                                      : 
   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
   setWhatProduced(this,"OmdsFedVector");
 
   //now do what ever other initialization is needed
 }

L1RCTOmdsFedVectorProducer::~L1RCTOmdsFedVectorProducer ( )

Definition at line 95 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

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

Definition at line 110 of file L1RCTOmdsFedVectorProducer.cc.

References authpath, connectionString, cond::persistency::Session::coralSession(), DEFINE_FWK_EVENTSETUP_MODULE, edm::eventsetup::EventSetupRecord::get(), RunInfo::m_run, edm::ESHandle< T >::product(), python.rootplot.root2matplotlib::replace(), convertSQLiteXML::runNumber, dataDML::schema, dataDML::session, cond::persistency::ConnectionPool::setAuthenticationPath(), cond::persistency::Transaction::start(), AlCaHLTBitMon_QueryRunRegistry::string, heppy_report::summary, tableToRead, cond::persistency::Session::transaction(), and heppy_batch::val.

 {
   //  std::cout << "ENTERING L1RCTOmdsFedVectorProducer::produce()" << std::endl;
 
   using namespace edm::es;
   std::shared_ptr<RunInfo> pRunInfo ;
 
   //  std::cout << "GETTING FED VECTOR FROM OMDS" << std::endl;
   
   // GETTING ALREADY-EXISTING RUNINFO OUT OF ES TO FIND OUT RUN NUMBER
   edm::ESHandle<RunInfo> sum;
   iRecord.get(sum);
   const RunInfo* summary=sum.product();
   int runNumber = summary->m_run; 
   
   // CREATING NEW RUNINFO WHICH WILL GET NEW FED VECTOR AND BE RETURNED
   pRunInfo = std::make_shared<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 ;
 }