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

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::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::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 34 of file PopConBTransitionSourceHandler.h.

34 {}

Member Function Documentation

template<class T >

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

inline

Definition at line 38 of file PopConBTransitionSourceHandler.h.

References popcon::PopConSourceHandler< T >::dbSession(), cond::persistency::Session::fetchPayload(), cond::persistency::IOVProxy::getInterval(), cond::persistency::IOVProxy::loadedSize(), LogDebug, RunInfoPI::m_avg_current, popcon::PopConBTransitionSourceHandler< T >::m_currentThreshold, popcon::PopConBTransitionSourceHandler< T >::m_run, popcon::PopConBTransitionSourceHandler< 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::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.getInterval(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 118 of file PopConBTransitionSourceHandler.h.

References popcon::PopConBTransitionSourceHandler< T >::checkBOn(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), cond::TagInfo_t::lastInterval, popcon::PopConBTransitionSourceHandler< 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("PopConBTransitionSourceHandler")
           << "["
           << "PopConBTransitionSourceHandler::" << __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("PopConBTransitionSourceHandler")
             << "["
             << "PopConBTransitionSourceHandler::" << __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 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 72 of file PopConBTransitionSourceHandler.h.

References cond::persistency::Session::createIov(), popcon::PopConSourceHandler< T >::dbSession(), cond::persistency::Session::editIov(), cond::persistency::Session::existsIov(), cond::persistency::IOVEditor::flush(), cond::persistency::IOVProxy::getInterval(), cond::persistency::IOVEditor::insert(), cond::persistency::IOVProxy::loadedSize(), LogDebug, popcon::PopConBTransitionSourceHandler< T >::m_run, popcon::PopConBTransitionSourceHandler< T >::m_tagForBOff, popcon::PopConBTransitionSourceHandler< T >::m_tagForBOn, popcon::PopConSourceHandler< T >::m_userTextLog, cond::TagInfo_t::name, cond::Iov_t::payloadId, cond::persistency::Session::readIov(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, cond::persistency::IOVEditor::setDescription(), cond::Iov_t::since, contentValuesCheck::ss, AlCaHLTBitMon_QueryRunRegistry::string, popcon::PopConSourceHandler< T >::tagInfo(), cond::persistency::IOVProxy::tagInfo(), cond::Tag_t::timeType, and cond::persistency::Session::transaction().

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);
       cond::Iov_t currentIov = iov.getInterval(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().lastInterval.payloadId) {
         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.tagInfo().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();
     }