L1RCTOmdsFedVectorProducer Class Reference

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
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
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 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 edm::ESProducer
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 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)

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

override

Definition at line 91 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 101 of file L1RCTOmdsFedVectorProducer.cc.

References authpath, connectionString, cond::persistency::Session::coralSession(), edm::eventsetup::EventSetupRecordImplementation< T >::get(), edm::ESHandle< T >::product(), 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, 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
  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
  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;
}

Member Data Documentation

authpath

std::string L1RCTOmdsFedVectorProducer::authpath

private

Definition at line 65 of file L1RCTOmdsFedVectorProducer.cc.

Referenced by produce().

connectionString

std::string L1RCTOmdsFedVectorProducer::connectionString

private

Definition at line 64 of file L1RCTOmdsFedVectorProducer.cc.

Referenced by produce().

tableToRead

std::string L1RCTOmdsFedVectorProducer::tableToRead

private

Definition at line 66 of file L1RCTOmdsFedVectorProducer.cc.

Referenced by produce().