#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	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 ()

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::map< Time_t, std::shared_ptr< T > >	Container

typedef std::unique_ptr< T >	Ref

typedef PopConSourceHandler< T >	self

typedef cond::Time_t	Time_t

typedef T	value_type

Protected Member Functions inherited from popcon::PopConSourceHandler< T >
cond::persistency::Session &	dbSession () const

Protected Attributes inherited from popcon::PopConSourceHandler< T >
Container	m_iovs

std::vector< std::pair< T *, Time_t > >	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 36 of file PopConESTransitionSourceHandler.h.

36 {}

Member Function Documentation

template<class T >

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

inline

Definition at line 40 of file PopConESTransitionSourceHandler.h.

References popcon::PopConSourceHandler< T >::dbSession(), cond::persistency::IOVProxy::getInterval(), 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(), run_AlCaRecoTriggerBitsUpdateWorkflow::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.getInterval(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 121 of file PopConESTransitionSourceHandler.h.

References popcon::PopConESTransitionSourceHandler< T >::checkLowGain(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), cond::TagInfo_t::lastInterval, popcon::PopConESTransitionSourceHandler< T >::m_run, cond::TagInfo_t::name, cond::Iov_t::payloadId, cond::Iov_t::since, 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.since << ", hash "
           << this->tagInfo().lastInterval.payloadId << 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.since >= m_run) {
         edm::LogInfo("PopConESTransitionSourceHandler")
             << "["
             << "PopConESTransitionSourceHandler::" << __func__ << "]: "
             << "last IOV " << this->tagInfo().lastInterval.since
             << (this->tagInfo().lastInterval.since == 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 76 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);
       cond::Iov_t currentIov = iov.getInterval(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().lastInterval.payloadId) {
         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.tagInfo().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();
     }