#include <RunInfoHandler.h>

Inheritance diagram for RunInfoHandler:

Public Member Functions
void	getNewObjects ()

std::string	id () const

	RunInfoHandler (const edm::ParameterSet &pset)

	~RunInfoHandler ()

Public Member Functions inherited from popcon::PopConSourceHandler< RunInfo >
void	convertFromOld ()

Summary *	dummySummary (typename OldContainer::value_type const &) const

void	initialize (const cond::persistency::Session &dbSession, cond::TagInfo_t const &tagInfo, cond::LogDBEntry const &logDBEntry)

Ref	lastPayload () const

cond::LogDBEntry const &	logDBEntry () const

std::pair< Container const *, std::string const >	operator() (const cond::persistency::Session &session, cond::TagInfo_t const &tagInfo, cond::LogDBEntry 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_name

std::string	m_pass

unsigned long long	m_since

std::string	m_user

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< RunInfo >
typedef std::vector< Triplet >	Container

typedef std::vector< std::pair < RunInfo *, cond::Time_t > >	OldContainer

typedef PopConSourceHandler < RunInfo >	self

typedef cond::Summary	Summary

typedef cond::Time_t	Time_t

typedef RunInfo	value_type

Protected Member Functions inherited from popcon::PopConSourceHandler< RunInfo >
int	add (value_type payload, Summary summary, Time_t time)

Protected Attributes inherited from popcon::PopConSourceHandler< RunInfo >
OldContainer	m_to_transfer

std::string	m_userTextLog

Detailed Description

Definition at line 10 of file RunInfoHandler.h.

Constructor & Destructor Documentation

RunInfoHandler::~RunInfoHandler ( )

Definition at line 17 of file RunInfoHandler.cc.

17 {}

RunInfoHandler::RunInfoHandler ( const edm::ParameterSet & pset )

Definition at line 8 of file RunInfoHandler.cc.

                                                           :
    m_name( pset.getUntrackedParameter<std::string>( "name", "RunInfoHandler") )
   ,m_since( pset.getParameter<unsigned long long>( "runNumber" ) )
   ,m_connectionString( pset.getUntrackedParameter<std::string>( "connectionString", "oracle://cms_omds_adg/CMS_RUNINFO") )
   ,m_authpath( pset.getUntrackedParameter<std::string>( "authenticationPath", "." ) )
   ,m_user( pset.getUntrackedParameter<std::string>( "OnlineDBUser", "CMS_RUNINFO_R" ) )
   ,m_pass( pset.getUntrackedParameter<std::string>( "OnlineDBPass", "PASSWORD") ) {
 }

Member Function Documentation

void RunInfoHandler::getNewObjects ( )

virtual

Implements popcon::PopConSourceHandler< RunInfo >.

Definition at line 19 of file RunInfoHandler.cc.

References RunInfo::Fake_RunInfo(), cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, m_connectionString, m_name, m_pass, m_since, popcon::PopConSourceHandler< RunInfo >::m_to_transfer, m_user, popcon::PopConSourceHandler< RunInfo >::m_userTextLog, cond::TagInfo_t::name, alignCSCRings::r, RunInfoRead::readData(), cond::TagInfo_t::size, findQualityFiles::size, contentValuesCheck::ss, and popcon::PopConSourceHandler< RunInfo >::tagInfo().

                                    {
   //check whats already inside of database
   edm::LogInfo( "RunInfoHandler" ) << "------- " << m_name
                                    << " - > getNewObjects\n"
                                    << "got offlineInfo " << tagInfo().name
                                    << ", size " << tagInfo().size
                                    << ", last object valid since " << tagInfo().lastInterval.first
                                    << " token " << tagInfo().lastPayloadToken << std::endl;
   edm::LogInfo( "RunInfoHandler" ) << "runnumber/first since = " << m_since << std::endl;
   RunInfo* r = new RunInfo();
   
   //fill with null runinfo if empty run are found beetween the two last valid ones 
   size_t n_empty_run = 0;
   if( tagInfo().size > 0  && (tagInfo().lastInterval.first + 1) < m_since ) {
     n_empty_run = m_since - tagInfo().lastInterval.first - 1;
     edm::LogInfo( "RunInfoHandler" ) << "------- " << "entering fake run from "
                                      << tagInfo().lastInterval.first + 1
                                      <<  "to " << m_since - 1 << "- > getNewObjects"
                                      << std::endl;
   } 
   // transfer fake run for 1 to since for the first time
   if( tagInfo().size == 0 && m_since != 1 ) {
     m_to_transfer.push_back( std::make_pair( (RunInfo*)(r->Fake_RunInfo()), 1 ) );
   }
   if ( n_empty_run != 0 ) {
     m_to_transfer.push_back(std::make_pair( (RunInfo*)(r->Fake_RunInfo()), tagInfo().lastInterval.first + 1 ) );
   }
   
   //reading from omds
   RunInfoRead rn( m_connectionString, m_user, m_pass );
   *r = rn.readData( "RUNSESSION_PARAMETER", "STRING_VALUE",(int)m_since );
   m_to_transfer.push_back( std::make_pair( (RunInfo*)r, m_since) );
   std::ostringstream ss;
   ss << "since =" << m_since;
   m_userTextLog = ss.str() + ";";
   edm::LogInfo( "RunInfoHandler" ) << "------- " << m_name << " - > getNewObjects" << std::endl;
 }