#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_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
edm::ParameterSet	m_connectionPset

std::string	m_connectionString

std::string	m_dcsenv_schema

std::string	m_name

std::string	m_runinfo_schema

unsigned long long	m_since

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)

cond::persistency::Session &	dbSession () const

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.

Referenced by id().

17 {}

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

Definition at line 8 of file RunInfoHandler.cc.

Referenced by id().

                                                             :
    m_since( pset.getParameter<unsigned long long>( "runNumber" ) )
   ,m_name( pset.getUntrackedParameter<std::string>( "name", "RunInfoHandler" ) )
   ,m_runinfo_schema( pset.getUntrackedParameter<std::string>( "RunInfoSchema", "CMS_RUNINFO" ) )
   ,m_dcsenv_schema( pset.getUntrackedParameter<std::string>( "DCSEnvSchema", "CMS_DCS_ENV_PVSS_COND") )
   ,m_connectionString( pset.getParameter<std::string>( "connect" ) )
   ,m_connectionPset( pset.getParameter<edm::ParameterSet>( "DBParameters" ) ) {
 }

Member Function Documentation

void RunInfoHandler::getNewObjects ( )

virtual

Implements popcon::PopConSourceHandler< RunInfo >.

Definition at line 19 of file RunInfoHandler.cc.

References RunInfoUpdate::appendNewRun(), popcon::PopConSourceHandler< RunInfo >::dbSession(), RunInfo::Fake_RunInfo(), cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, m_connectionPset, m_connectionString, m_dcsenv_schema, m_name, m_runinfo_schema, m_since, popcon::PopConSourceHandler< RunInfo >::m_to_transfer, popcon::PopConSourceHandler< RunInfo >::m_userTextLog, cond::TagInfo_t::name, alignCSCRings::r, RunInfoRead::readData(), cond::TagInfo_t::size, findQualityFiles::size, and popcon::PopConSourceHandler< RunInfo >::tagInfo().

                                    {
   //check whats already inside of database
   edm::LogInfo( "RunInfoHandler" ) << "[" << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                    << "Destination Tag Info: name " << tagInfo().name
                                    << ", size " << tagInfo().size
                                    << ", last object valid since " << tagInfo().lastInterval.first
                                    << ", hash " << tagInfo().lastPayloadToken << std::endl;
   edm::LogInfo( "RunInfoHandler" ) << "[" << "RunInfoHandler::" << __func__ << "]:" << m_name << ": runnumber/first since = " << m_since << std::endl;
 
   //check if a transfer is needed:
   //if the new run number is smaller than or equal to the latest IOV, exit.
   //This is needed as now the IOV Editor does not always protect for insertions:
   //ANY and VALIDATION sychronizations are allowed to write in the past.
   if( tagInfo().size > 0  && tagInfo().lastInterval.first >= m_since ) {
     edm::LogWarning( "RunInfoHandler" ) << "[" << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                         << "last IOV " << tagInfo().lastInterval.first
                                         << ( tagInfo().lastInterval.first == m_since ? " is equal to" : " is larger than" )
                                         << " the run proposed for insertion " << m_since
                                         << ". No transfer needed." << std::endl;
     return;
   }
 
   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" ) << "[" << "RunInfoHandler::" << __func__ << "]:" << m_name << ": "
                                      << "entering fake run from "
                                      << tagInfo().lastInterval.first + 1
                                      <<  " to " << m_since - 1
                                      << std::endl;
   } 
   std::ostringstream ss;
   // 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 ) );
     ss << "fake run number: " << 1 << ", ";
   }
   if ( n_empty_run != 0 ) {
     m_to_transfer.push_back(std::make_pair( (RunInfo*)(r->Fake_RunInfo()), tagInfo().lastInterval.first + 1 ) );
     ss << "fake run number: " << tagInfo().lastInterval.first + 1 << ", ";
   }
   
   //reading from omds
   RunInfoRead rn( m_connectionString, m_connectionPset );
   *r = rn.readData( m_runinfo_schema, m_dcsenv_schema, (int)m_since );
   m_to_transfer.push_back( std::make_pair( (RunInfo*)r, m_since) );
   ss << "run number: " << m_since << ";";
   m_userTextLog = ss.str();
   edm::LogInfo( "RunInfoHandler" ) << "[" << "RunInfoHandler::" << __func__ << "]:" << m_name << ": END." << std::endl;
   // update runinfo table in conditions db
   RunInfoUpdate updater( dbSession() );
   updater.appendNewRun( *r );
 }