Inheritance diagram for L1RCTOmdsFedVectorProducer:

Public Types
typedef boost::shared_ptr < RunInfo >	ReturnType
Public Member Functions
	L1RCTOmdsFedVectorProducer (const edm::ParameterSet &)
ReturnType	produce (const RunInfoRcd &)
	~L1RCTOmdsFedVectorProducer ()
Private Attributes
std::string	authpath
std::string	connectionString
std::string	tableToRead

Detailed Description

Description: [one line class summary]

Implementation: [Notes on implementation]

Definition at line 59 of file L1RCTOmdsFedVectorProducer.cc.

Member Typedef Documentation

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

Definition at line 64 of file L1RCTOmdsFedVectorProducer.cc.

Constructor & Destructor Documentation

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

Definition at line 86 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 99 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 114 of file L1RCTOmdsFedVectorProducer.cc.

References authpath, cond::DbConnection::configuration(), connectionString, edm::eventsetup::EventSetupRecord::get(), linker::replace(), convertSQLiteXML::runNumber, python::IdGenerator::schema, python::CommonUtils::session, summarizeEdmComparisonLogfiles::summary, and tableToRead.

{
  //  std::cout << "ENTERING L1RCTOmdsFedVectorProducer::produce()" << std::endl;

  using namespace edm::es;
  boost::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 = boost::shared_ptr<RunInfo>( new RunInfo() ); 
  
  
  // DO THE DATABASE STUFF
  
  //make connection object
  cond::DbConnection         connection;
  
  //set in configuration object authentication path
  connection.configuration().setAuthenticationPath(authpath);
  connection.configure();
  
  //create session object from connection
  cond::DbSession session = connection.createSession();
  
  session.open(connectionString,true);

  session.transaction().start(true); // (true=readOnly)

  coral::ISchema& schema = session.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 ;
}