#include <PopConESTransitionSourceHandler.h>

Inheritance diagram for popcon::PopConESTransitionSourceHandler< T >:

Public Member Functions
bool	checkLowGain ()

void	getNewObjects () final

virtual void	getObjectsForESTransition (bool isLowGain)

std::string	id () const final

	PopConESTransitionSourceHandler (edm::ParameterSet const &pset)

	~PopConESTransitionSourceHandler () override

Public Member Functions inherited from popcon::PopConSourceHandler< T >
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
cond::persistency::ConnectionPool	m_connection

edm::ParameterSet	m_connectionPset

std::string	m_connectionString

double	m_currentThreshold

std::string	m_ESGain

unsigned long long	m_run

std::string	m_tagForHighGain

std::string	m_tagForLowGain

std::string	m_tagForRunInfo

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

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

typedef PopConSourceHandler< T >	self

typedef cond::Summary	Summary

typedef cond::Time_t	Time_t

typedef T	value_type

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

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

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

std::string	m_userTextLog

Detailed Description

template<class T>
class popcon::PopConESTransitionSourceHandler< T >

Definition at line 14 of file PopConESTransitionSourceHandler.h.

Constructor & Destructor Documentation

template<class T >

popcon::PopConESTransitionSourceHandler< T >::PopConESTransitionSourceHandler ( edm::ParameterSet const & pset )

inline

Definition at line 16 of file PopConESTransitionSourceHandler.h.

References cond::persistency::ConnectionPool::configure(), popcon::PopConESTransitionSourceHandler< T >::m_connection, popcon::PopConESTransitionSourceHandler< T >::m_connectionPset, and cond::persistency::ConnectionPool::setParameters().

                                                                    :
       m_run( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getParameter<unsigned long long>( "runNumber" ) ),
     //      m_currentThreshold( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getUntrackedParameter<double>( "currentThreshold", 18000. ) ),
       m_tagForRunInfo( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getParameter<std::string>( "tagForRunInfo" ) ),
       m_ESGain( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getParameter<std::string>( "ESGain" ) ),
       m_tagForLowGain( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getParameter<std::string>( "ESLowGainTag" ) ),
       m_tagForHighGain( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getParameter<std::string>( "ESHighGainTag" ) ),
       m_connectionString( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getParameter<std::string>( "connect" ) ),
       m_connectionPset( pset.getParameter<edm::ParameterSet>( "ESTransition" ).getParameter<edm::ParameterSet>( "DBParameters" ) ) {
       edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler:" << __func__ << "]: "
                                                        << "Initialising Connection Pool" << std::endl;
       m_connection.setParameters( m_connectionPset );
       m_connection.configure();
   }

template<class T >

popcon::PopConESTransitionSourceHandler< T >::~PopConESTransitionSourceHandler ( )

inlineoverride

Definition at line 31 of file PopConESTransitionSourceHandler.h.

31 {}

Member Function Documentation

template<class T >

bool popcon::PopConESTransitionSourceHandler< T >::checkLowGain ( )

inline

Definition at line 35 of file PopConESTransitionSourceHandler.h.

References popcon::PopConSourceHandler< T >::dbSession(), cond::persistency::IOVProxy::find(), cond::persistency::IOVProxy::loadedSize(), LogDebug, popcon::PopConESTransitionSourceHandler< T >::m_ESGain, popcon::PopConESTransitionSourceHandler< T >::m_run, popcon::PopConESTransitionSourceHandler< T >::m_tagForRunInfo, cond::Iov_t::payloadId, cond::persistency::Session::readIov(), dataDML::session, cond::Iov_t::since, and cond::persistency::Session::transaction().

Referenced by popcon::PopConESTransitionSourceHandler< T >::getNewObjects().

                         {
       //the output boolean is set to true as default
       bool isLowGain = true;
       cond::persistency::Session& session = PopConSourceHandler<T>::dbSession();
       //reading RunInfo from Conditions
       cond::persistency::TransactionScope trans( session.transaction() );
       edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                        << "Loading tag for RunInfo " << m_tagForRunInfo
                                                        << " and IOV valid for run number: " << m_run << std::endl;
       cond::persistency::IOVProxy iov = session.readIov( m_tagForRunInfo );
       cond::Iov_t currentIov = *(iov.find( m_run ));
       LogDebug( "PopConESTransitionSourceHandler" ) << "Loaded IOV sequence from tag " << m_tagForRunInfo
                                                    << " with size: "<< iov.loadedSize()
                                                    << ", IOV valid for run number " << m_run << " starting from: " << currentIov.since
                                                    << ", with corresponding payload hash: " << currentIov.payloadId << std::endl;
                                /*    accessing the average magnet current for the run
             double current_default = -1;
            double avg_current = current_default;
            avg_current = session.fetchPayload<RunInfo>( currentIov.payloadId )->m_avg_current;
             LogDebug( "PopConESTransitionSourceHandler" ) << "Comparing value of magnet current: " << avg_current << " A for run: " << m_run
                                                    << " with the corresponding threshold: "<< m_currentThreshold << " A." << std::endl;
       comparing the magnet current with the user defined threshold
       if( avg_current != current_default && avg_current <= m_currentThreshold ) isLowGain = false;
       edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                        << "The magnet was " << ( isBOn ? "ON" : "OFF" )
                                << " during run " << m_run << std::endl;   */
       if (m_ESGain=="HIGH") {
     isLowGain=false;}
       else   {
         isLowGain = true;}
       trans.close();          
       return isLowGain;
     }

template<class T >

void popcon::PopConESTransitionSourceHandler< T >::getNewObjects ( )

inlinefinalvirtual

Implements popcon::PopConSourceHandler< T >.

Definition at line 114 of file PopConESTransitionSourceHandler.h.

References popcon::PopConESTransitionSourceHandler< T >::checkLowGain(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, popcon::PopConESTransitionSourceHandler< T >::m_run, cond::TagInfo_t::name, cond::TagInfo_t::size, findQualityFiles::size, and popcon::PopConSourceHandler< T >::tagInfo().

                                {
       //check whats already inside of database
        edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                         << "Destination Tag Info: name " << this->tagInfo().name
                                                         << ", size " << this->tagInfo().size
                                                         << ", last object valid since " << this->tagInfo().lastInterval.first
                                                         << ", hash " << this->tagInfo().lastPayloadToken << 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( this->tagInfo().size > 0  && this->tagInfo().lastInterval.first >= m_run ) {
         edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                          << "last IOV " << this->tagInfo().lastInterval.first
                                                          << ( this->tagInfo().lastInterval.first == m_run ? " is equal to" : " is larger than" )
                                                          << " the run proposed for insertion " << m_run
                                                          << ". No transfer needed." << std::endl;
         return;
       }
       bool isLowGain = checkLowGain();
       getObjectsForESTransition( isLowGain );
       edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                        << "END." << std::endl;
     }

template<class T >

virtual void popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition ( bool isLowGain )

inlinevirtual

Definition at line 69 of file PopConESTransitionSourceHandler.h.

Referenced by popcon::PopConESTransitionSourceHandler< T >::getNewObjects().

                                                              {
       //reading payloads for 0T and 3.8T from Conditions
       cond::persistency::Session& session = PopConSourceHandler<T>::dbSession();
       cond::persistency::TransactionScope trans( session.transaction() );
       edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                        << "Loading tag for ES " << ( isLowGain ? "LowGain" : "HighGain" ) << ": "
                                                        << ( isLowGain ? m_tagForLowGain : m_tagForHighGain )
                                                        << " and IOV valid for run number: " << m_run << std::endl;
       cond::persistency::IOVProxy iov = session.readIov( isLowGain ? m_tagForLowGain : m_tagForHighGain, true );
       cond::Iov_t currentIov = *(iov.find( m_run ));
       LogDebug( "PopConESTransitionSourceHandler" ) << "Loaded IOV sequence from tag " << ( isLowGain ? m_tagForLowGain : m_tagForHighGain )
                                                    << " with size: "<< iov.loadedSize()
                                                    << ", IOV valid for run number " << m_run << " starting from: " << currentIov.since
                                                    << ", with corresponding payload hash: " << currentIov.payloadId
                                                    << std::endl;
       std::string destTag = this->tagInfo().name;
       if( currentIov.payloadId != this->tagInfo().lastPayloadToken ) {
         std::ostringstream ss;
         ss << "Adding iov with since "<<m_run<<" pointing to hash " << currentIov.payloadId
            << " corresponding to the ES Gain "
            << ( isLowGain ? "LOW" : "HIGH" );
         edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                          << ss.str() << std::endl;
     cond::persistency::IOVEditor editor;
         if( session.existsIov( destTag ) ){
       editor = session.editIov( destTag );
     } else {
       editor = session.createIov<T>( destTag, iov.timeType() );
           editor.setDescription( "Tag created by PopConESTransitionSourceHandler" );
     }
         editor.insert( m_run, currentIov.payloadId );
         editor.flush();
         this->m_userTextLog = ss.str();
       } else {
         edm::LogInfo( "PopConESTransitionSourceHandler" ) << "[" << "PopConESTransitionSourceHandler::" << __func__ << "]: "
                                                          << "The payload with hash " << currentIov.payloadId
                                                          << " corresponding to ES Gain"
                                                          << ( isLowGain ? "LOW" : "HIGH" )
                                                          << " is still valid for run " << m_run
                                                          << " in the destination tag " << destTag
                                                          << ".\nNo transfer needed." <<std::endl;
       }
       trans.close();     
     }