#include <PopConBTransitionSourceHandler.h>

Inheritance diagram for popcon::PopConBTransitionSourceHandler< T >:

Public Member Functions
bool	checkBOn ()

void	getNewObjects () final

virtual void	getObjectsForBTransition (bool isBOn)

std::string	id () const final

	PopConBTransitionSourceHandler (edm::ParameterSet const &pset)

	~PopConBTransitionSourceHandler () 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

unsigned long long	m_run

std::string	m_tagForBOff

std::string	m_tagForBOn

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::PopConBTransitionSourceHandler< T >

Definition at line 14 of file PopConBTransitionSourceHandler.h.

Constructor & Destructor Documentation

template<class T >

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

inline

Definition at line 16 of file PopConBTransitionSourceHandler.h.

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

                                                                   :
       m_run( pset.getParameter<edm::ParameterSet>( "BTransition" ).getParameter<unsigned long long>( "runNumber" ) ),
       m_currentThreshold( pset.getParameter<edm::ParameterSet>( "BTransition" ).getUntrackedParameter<double>( "currentThreshold", 18000. ) ),
       m_tagForRunInfo( pset.getParameter<edm::ParameterSet>( "BTransition" ).getParameter<std::string>( "tagForRunInfo" ) ),
       m_tagForBOff( pset.getParameter<edm::ParameterSet>( "BTransition" ).getParameter<std::string>( "tagForBOff" ) ),
       m_tagForBOn( pset.getParameter<edm::ParameterSet>( "BTransition" ).getParameter<std::string>( "tagForBOn" ) ),
       m_connectionString( pset.getParameter<edm::ParameterSet>( "BTransition" ).getParameter<std::string>( "connect" ) ),
       m_connectionPset( pset.getParameter<edm::ParameterSet>( "BTransition" ).getParameter<edm::ParameterSet>( "DBParameters" ) ) {
       edm::LogInfo( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler:" << __func__ << "]: "
                                                        << "Initialising Connection Pool" << std::endl;
       m_connection.setParameters( m_connectionPset );
       m_connection.configure();
   }

template<class T >

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

inlineoverride

Definition at line 30 of file PopConBTransitionSourceHandler.h.

30 {}

Member Function Documentation

template<class T >

bool popcon::PopConBTransitionSourceHandler< T >::checkBOn ( )

inline

Definition at line 34 of file PopConBTransitionSourceHandler.h.

References popcon::PopConSourceHandler< T >::dbSession(), cond::persistency::Session::fetchPayload(), cond::persistency::IOVProxy::find(), cond::persistency::IOVProxy::loadedSize(), LogDebug, popcon::PopConBTransitionSourceHandler< T >::m_currentThreshold, popcon::PopConBTransitionSourceHandler< T >::m_run, popcon::PopConBTransitionSourceHandler< 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::PopConBTransitionSourceHandler< T >::getNewObjects().

                     {
       //the output boolean is set to true as default
       bool isBOn = true;
       cond::persistency::Session& session = PopConSourceHandler<T>::dbSession();
       //reading RunInfo from Conditions
       cond::persistency::TransactionScope trans( session.transaction() );
       edm::LogInfo( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __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( "PopConBTransitionSourceHandler" ) << "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( "PopConBTransitionSourceHandler" ) << "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 ) isBOn = false;
       edm::LogInfo( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __func__ << "]: "
                                                        << "The magnet was " << ( isBOn ? "ON" : "OFF" )
                                << " during run " << m_run << std::endl;
       trans.close();          
       return isBOn;
     }

template<class T >

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

inlinefinalvirtual

Implements popcon::PopConSourceHandler< T >.

Definition at line 110 of file PopConBTransitionSourceHandler.h.

References popcon::PopConBTransitionSourceHandler< T >::checkBOn(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, popcon::PopConBTransitionSourceHandler< 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( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __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( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __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 isBOn = checkBOn();
       getObjectsForBTransition( isBOn );
       edm::LogInfo( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __func__ << "]: "
                                                        << "END." << std::endl;
     }

template<class T >

virtual void popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition ( bool isBOn )

inlinevirtual

Definition at line 65 of file PopConBTransitionSourceHandler.h.

Referenced by popcon::PopConBTransitionSourceHandler< 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( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __func__ << "]: "
                                                        << "Loading tag for B " << ( isBOn ? "ON" : "OFF" ) << ": "
                                                        << ( isBOn ? m_tagForBOn : m_tagForBOff )
                                                        << " and IOV valid for run number: " << m_run << std::endl;
       cond::persistency::IOVProxy iov = session.readIov( isBOn ? m_tagForBOn : m_tagForBOff, true );
       cond::Iov_t currentIov = *(iov.find( m_run ));
       LogDebug( "PopConBTransitionSourceHandler" ) << "Loaded IOV sequence from tag " << ( isBOn ? m_tagForBOn : m_tagForBOff )
                                                    << " 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 calibrations for magnetic field "
            << ( isBOn ? "ON" : "OFF" );
         edm::LogInfo( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __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 PopConBTransitionSourceHandler" );
     }
         editor.insert( m_run, currentIov.payloadId );
         editor.flush();
         this->m_userTextLog = ss.str();
       } else {
         edm::LogInfo( "PopConBTransitionSourceHandler" ) << "[" << "PopConBTransitionSourceHandler::" << __func__ << "]: "
                                                          << "The payload with hash " << currentIov.payloadId
                                                          << " corresponding to the calibrations for magnetic field "
                                                          << ( isBOn ? "ON" : "OFF" )
                                                          << " is still valid for run " << m_run
                                                          << " in the destination tag " << destTag
                                                          << ".\nNo transfer needed." <<std::endl;
       }
       trans.close();     
     }