RunSummaryHandler Class Reference

#include <RunSummaryHandler.h>

Inheritance diagram for RunSummaryHandler:

Public Member Functions
void	getNewObjects () override
std::string	id () const override
	RunSummaryHandler (const edm::ParameterSet &pset)
	~RunSummaryHandler () override
Public Member Functions inherited from popcon::PopConSourceHandler< RunSummary >
void	convertFromOld ()
Summary *	dummySummary (typename OldContainer::value_type const &) const
void	initialize (const cond::persistency::Session &dbSession, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry)
Ref	lastPayload () const
cond::LogDBEntry_t const &	logDBEntry () const
std::pair< Container const *, std::string const >	operator() (const cond::persistency::Session &session, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry) const
	PopConSourceHandler ()
Container const &	returnData ()
void	sort ()
cond::TagInfo_t const &	tagInfo () const
std::string const &	userTextLog () const
virtual	~PopConSourceHandler ()

Private Attributes
std::string	m_authpath
std::string	m_connectionString
std::string	m_host
std::string	m_name
std::string	m_pass
int	m_port
std::string	m_sid
unsigned long long	m_since
std::string	m_user

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< RunSummary >
typedef std::vector< Triplet >	Container
typedef std::vector< std::pair< RunSummary *, cond::Time_t > >	OldContainer
typedef PopConSourceHandler< RunSummary >	self
typedef cond::Summary	Summary
typedef cond::Time_t	Time_t
typedef RunSummary	value_type
Protected Member Functions inherited from popcon::PopConSourceHandler< RunSummary >
int	add (value_type *payload, Summary *summary, Time_t time)
cond::persistency::Session &	dbSession () const
Protected Attributes inherited from popcon::PopConSourceHandler< RunSummary >
OldContainer	m_to_transfer
std::string	m_userTextLog

Detailed Description

Definition at line 10 of file RunSummaryHandler.h.

Constructor & Destructor Documentation

~RunSummaryHandler()

RunSummaryHandler::~RunSummaryHandler ( )

override

Definition at line 20 of file RunSummaryHandler.cc.

{}

RunSummaryHandler()

RunSummaryHandler::RunSummaryHandler

(

const edm::ParameterSet &

pset

)

Definition at line 9 of file RunSummaryHandler.cc.

    : m_name(pset.getUntrackedParameter<std::string>("name", "RunSummaryHandler")),
      // m_connect(pset.getUntrackedParameter<std::string>("OnlineConn","")),
 
      m_user(pset.getUntrackedParameter<std::string>("OnlineDBUser", "CMS_RUNINFO")),
      m_pass(pset.getUntrackedParameter<std::string>("OnlineDBPass", "********"))
 
{
  m_connectionString = "oracle://cms_omds_lb/CMS_RUNINFO";
}

References m_connectionString.

Member Function Documentation

getNewObjects()

void RunSummaryHandler::getNewObjects ( )

overridevirtual

Implements popcon::PopConSourceHandler< RunSummary >.

Definition at line 22 of file RunSummaryHandler.cc.

                                      {
  edm::LogInfo("RunSummaryHandler") << "------- " << m_name << " - > getNewObjects\n"
                                    <<
      //check whats already inside of database
      "got offlineInfo" << tagInfo().name << ", size " << tagInfo().size << ", last object valid since "
                                    << tagInfo().lastInterval.since << " token " << tagInfo().lastInterval.payloadId
                                    << std::endl;
 
  /*
     if (tagInfo().size>0) {
     Ref payload = lastPayload();
     //edm::LogInfo   ("RunSummaryHandler")<<"size of last payload  "<< 
     //   payload->..........size()<<std::endl;
     }
   */
  unsigned int snc;
 
  std::cerr << "Source implementation test ::getNewObjects : enter runnumber as a first since !  \n";
  std::cin >> snc;
 
  std::cout << "runnumber/first since = " << snc << std::endl;
 
  RunSummary* r = new RunSummary();
 
  //fill with null runsummary if empty run are found beetween the two last validones
 
  size_t n_empty_run = 0;
  if (tagInfo().size > 0 && (tagInfo().lastInterval.since + 1) < snc) {
    n_empty_run = snc - tagInfo().lastInterval.since - 1;
    edm::LogInfo("RunSummaryHandler") << "------- "
                                      << "entering fake run from " << tagInfo().lastInterval.since + 1 << "to "
                                      << snc - 1 << "- > getNewObjects" << std::endl;
    n_empty_run = snc - tagInfo().lastInterval.since - 1;
    // for (size_t i=1; i<= n_empty_run ; i++){
 
    // r->summary.push_back(empty->fake_Run());
    // }
  }
 
  // transfer fake run for 1 to since for the first time
  if (tagInfo().size == 0) {
    m_to_transfer.push_back(std::make_pair((RunSummary*)(r->Fake_RunSummary()), 1));
  }
 
  // transfer also empty run if tag already existing
  if (n_empty_run != 0) {
    m_to_transfer.push_back(std::make_pair((RunSummary*)(r->Fake_RunSummary()), tagInfo().lastInterval.since + 1));
  }
 
  // reading from omds
  RunSummaryRead rn(m_connectionString, m_user, m_pass);
 
  *r = rn.readData("RUNSESSION_PARAMETER", "STRING_VALUE", (int)snc);
  m_to_transfer.push_back(std::make_pair((RunSummary*)r, snc));
  std::ostringstream ss;
  ss << "since =" << snc;
 
  m_userTextLog = ss.str() + ";";
 
  edm::LogInfo("RunSummaryHandler") << "------- " << m_name << " - > getNewObjects" << std::endl;
}

References beam_dqm_sourceclient-live_cfg::cerr, gather_cfg::cout, cond::TagInfo_t::lastInterval, m_connectionString, m_name, m_pass, popcon::PopConSourceHandler< RunSummary >::m_to_transfer, m_user, popcon::PopConSourceHandler< RunSummary >::m_userTextLog, cond::TagInfo_t::name, cond::Iov_t::payloadId, alignCSCRings::r, RunSummaryRead::readData(), cond::Iov_t::since, cond::TagInfo_t::size, findQualityFiles::size, contentValuesCheck::ss, and popcon::PopConSourceHandler< RunSummary >::tagInfo().

id()

std::string RunSummaryHandler::id ( ) const

inlineoverridevirtual

Implements popcon::PopConSourceHandler< RunSummary >.

Definition at line 13 of file RunSummaryHandler.h.

{ return m_name; }

References m_name.

Member Data Documentation

m_authpath

std::string RunSummaryHandler::m_authpath

private

Definition at line 25 of file RunSummaryHandler.h.

m_connectionString

std::string RunSummaryHandler::m_connectionString

private

Definition at line 23 of file RunSummaryHandler.h.

Referenced by getNewObjects(), and RunSummaryHandler().

m_host

std::string RunSummaryHandler::m_host

private

Definition at line 26 of file RunSummaryHandler.h.

m_name

std::string RunSummaryHandler::m_name

private

Definition at line 18 of file RunSummaryHandler.h.

Referenced by getNewObjects(), and id().

m_pass

std::string RunSummaryHandler::m_pass

private

Definition at line 29 of file RunSummaryHandler.h.

Referenced by getNewObjects().

m_port

int RunSummaryHandler::m_port

private

Definition at line 30 of file RunSummaryHandler.h.

m_sid

std::string RunSummaryHandler::m_sid

private

Definition at line 27 of file RunSummaryHandler.h.

m_since

unsigned long long RunSummaryHandler::m_since

private

Definition at line 19 of file RunSummaryHandler.h.

m_user

std::string RunSummaryHandler::m_user

private

Definition at line 28 of file RunSummaryHandler.h.

Referenced by getNewObjects().