cond::persistency::IOVProxy Class Reference

#include <IOVProxy.h>

Classes
class	Iterator

Public Types
typedef std::vector< std::tuple< cond::Time_t, cond::Hash > >	IOVContainer

Public Member Functions
Iterator	begin () const
Iterator	end () const
cond::Time_t	endOfValidity () const
Iterator	find (cond::Time_t time)
cond::Iov_t	getInterval (cond::Time_t time)
cond::Iov_t	getLast ()
std::tuple< std::string, boost::posix_time::ptime, boost::posix_time::ptime >	getMetadata () const
	IOVProxy ()
	IOVProxy (const std::shared_ptr< SessionImpl > &session)
	IOVProxy (const IOVProxy &rhs)
bool	isEmpty () const
cond::Time_t	lastValidatedTime () const
void	load (const std::string &tag, bool full=false)
void	load (const std::string &tag, const boost::posix_time::ptime &snapshottime, bool full=false)
std::pair< cond::Time_t, cond::Time_t >	loadedGroup () const
int	loadedSize () const
void	loadRange (const std::string &tag, const cond::Time_t &begin, const cond::Time_t &end)
void	loadRange (const std::string &tag, const cond::Time_t &begin, const cond::Time_t &end, const boost::posix_time::ptime &snapshottime)
size_t	numberOfQueries () const
IOVProxy &	operator= (const IOVProxy &rhs)
std::string	payloadObjectType () const
void	reload ()
void	reset ()
int	sequenceSize () const
const std::shared_ptr< SessionImpl > &	session () const
cond::SynchronizationType	synchronizationType () const
std::string	tag () const
cond::TimeType	timeType () const

Private Member Functions
void	checkTransaction (const std::string &ctx) const
void	fetchSequence (cond::Time_t lowerGroup, cond::Time_t higherGroup)

Private Attributes
std::shared_ptr< IOVProxyData >	m_data
std::shared_ptr< SessionImpl >	m_session

Detailed Description

Definition at line 28 of file IOVProxy.h.

Member Typedef Documentation

typedef std::vector<std::tuple<cond::Time_t, cond::Hash> > cond::persistency::IOVProxy::IOVContainer

Definition at line 30 of file IOVProxy.h.

Constructor & Destructor Documentation

IOVProxy::IOVProxy

(

)

Definition at line 104 of file IOVProxy.cc.

: m_data(), m_session() {}

IOVProxy::IOVProxy ( const std::shared_ptr< SessionImpl > &  session )

explicit

Definition at line 106 of file IOVProxy.cc.

: m_data(new IOVProxyData), m_session(session) {}

IOVProxy::IOVProxy

(

const IOVProxy &

rhs

)

Definition at line 108 of file IOVProxy.cc.

: m_data(rhs.m_data), m_session(rhs.m_session) {}

Member Function Documentation

IOVProxy::Iterator IOVProxy::begin

(

void

)

const

Definition at line 282 of file IOVProxy.cc.

References m_data.

Referenced by RunInfoUpdate::import(), cond::persistency::importIovs(), and loadRange().

                                           {
      if (m_data.get()) {
        return Iterator(m_data->iovSequence.begin(),
                        m_data->iovSequence.end(),
                        m_data->timeType,
                        m_data->groupHigherIov,
                        m_data->endOfValidity);
      }
      return Iterator();
    }

void IOVProxy::checkTransaction ( const std::string &  ctx ) const

private

Definition at line 251 of file IOVProxy.cc.

References m_session, and cond::persistency::throwException().

Referenced by find(), getLast(), getMetadata(), load(), loadRange(), and sequenceSize().

                                                              {
      if (!m_session.get())
        throwException("The session is not active.", ctx);
      if (!m_session->isTransactionActive(false))
        throwException("The transaction is not active.", ctx);
    }

IOVProxy::Iterator IOVProxy::end

(

void

)

const

Definition at line 293 of file IOVProxy.cc.

References m_data.

Referenced by SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), cond::persistency::copyIov(), Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), find(), getInterval(), RunInfoUpdate::import(), cond::persistency::importIovs(), cond::persistency::KeyList::loadFromDB(), loadRange(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::payloadToken(), cond::DataProxyWrapperBase::setIntervalFor(), and cond::persistency::KeyList::setKeys().

                                         {
      if (m_data.get()) {
        return Iterator(m_data->iovSequence.end(),
                        m_data->iovSequence.end(),
                        m_data->timeType,
                        m_data->groupHigherIov,
                        m_data->endOfValidity);
      }
      return Iterator();
    }

cond::Time_t IOVProxy::endOfValidity

(

)

const

Definition at line 228 of file IOVProxy.cc.

References m_data, and cond::time::MIN_VAL().

{ return m_data.get() ? m_data->endOfValidity : cond::time::MIN_VAL; }

void IOVProxy::fetchSequence ( cond::Time_t  lowerGroup, cond::Time_t  higherGroup  )

private

Definition at line 258 of file IOVProxy.cc.

References m_data, m_session, cond::time::MAX_VAL(), and cond::time::MIN_VAL().

Referenced by find().

                                                                              {
      m_data->iovSequence.clear();
      m_session->iovSchema().iovTable().select(
          m_data->tag, lowerGroup, higherGroup, m_data->snapshotTime, m_data->iovSequence);

      if (m_data->iovSequence.empty()) {
        m_data->groupLowerIov = cond::time::MAX_VAL;
        m_data->groupHigherIov = cond::time::MIN_VAL;
      } else {
        if (lowerGroup > cond::time::MIN_VAL) {
          m_data->groupLowerIov = std::get<0>(m_data->iovSequence.front());
        } else {
          m_data->groupLowerIov = cond::time::MIN_VAL;
        }
        if (higherGroup < cond::time::MAX_VAL) {
          m_data->groupHigherIov = higherGroup - 1;
        } else {
          m_data->groupHigherIov = cond::time::MAX_VAL;
        }
      }

      m_data->numberOfQueries++;
    }

IOVProxy::Iterator IOVProxy::find

(

cond::Time_t

time

)

Definition at line 322 of file IOVProxy.cc.

References checkTransaction(), end(), fetchSequence(), m_data, cond::time::MAX_VAL(), and cond::persistency::search().

Referenced by BeautifulSoup.Tag::__getattr__(), SiStripDetVOffTkMapPlotter::analyze(), SiStripDetVOffPrinter::analyze(), SiStripDetVOffTrendPlotter::analyze(), BeamSpotRcdPrinter::analyze(), popcon::PopConBTransitionSourceHandler< T >::checkBOn(), popcon::PopConESTransitionSourceHandler< T >::checkLowGain(), cond::persistency::copyIov(), BeautifulSoup.Tag::firstText(), getInterval(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), RunInfoUpdate::import(), cond::persistency::importIovs(), cond::persistency::KeyList::loadFromDB(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::payloadToken(), cond::DataProxyWrapperBase::setIntervalFor(), and cond::persistency::KeyList::setKeys().

                                                   {
      checkTransaction("IOVProxy::find");
      // organize iovs in pages...
      // first check the available iov cache:
      if (m_data->groupLowerIov == cond::time::MAX_VAL ||  // case 0 : empty cache ( the first request )
          time < m_data->groupLowerIov || time >= m_data->groupHigherIov) {  // case 1 : target outside

        // a new query required!
        // first determine the groups
        auto iGLow = search(time, m_data->sinceGroups);
        if (iGLow == m_data->sinceGroups.end()) {
          // no suitable group=no iov at all! exiting...
          return end();
        }
        auto iGHigh = iGLow;
        cond::Time_t lowG = *iGLow;
        iGHigh++;
        cond::Time_t highG = cond::time::MAX_VAL;
        if (iGHigh != m_data->sinceGroups.end())
          highG = *iGHigh;

        // finally, get the iovs for the selected group interval!!
        fetchSequence(lowG, highG);
      }

      // the current iov set is a good one...
      auto iIov = search(time, m_data->iovSequence);
      return Iterator(iIov, m_data->iovSequence.end(), m_data->timeType, m_data->groupHigherIov, m_data->endOfValidity);
    }

cond::Iov_t IOVProxy::getInterval

(

cond::Time_t

time

)

Definition at line 352 of file IOVProxy.cc.

References end(), find(), cond::persistency::throwException(), and validateGeometry_cfg::valid.

Referenced by cond::persistency::importIovs().

                                                   {
      Iterator valid = find(time);
      if (valid == end()) {
        throwException("Can't find a valid interval for the specified time.", "IOVProxy::getInterval");
      }
      return *valid;
    }

cond::Iov_t IOVProxy::getLast

(

)

Definition at line 360 of file IOVProxy.cc.

References checkTransaction(), m_data, m_session, cond::time::MAX_VAL(), convertSQLiteXML::ok, cond::Iov_t::payloadId, runTheMatrix::ret, cond::Iov_t::since, and cond::Iov_t::till.

Referenced by SiStripDetVOffHandler::analyze(), SiStripPayloadHandler< SiStripPayload >::analyze(), popcon::PopCon::initialize(), and cond::service::PoolDBOutputService::tagInfo().

                                {
      checkTransaction("IOVProxy::getLast");
      cond::Iov_t ret;
      bool ok =
          m_session->iovSchema().iovTable().getLastIov(m_data->tag, m_data->snapshotTime, ret.since, ret.payloadId);

      if (ok)
        ret.till = cond::time::MAX_VAL;
      return ret;
    }

std::tuple< std::string, boost::posix_time::ptime, boost::posix_time::ptime > IOVProxy::getMetadata

(

)

const

Definition at line 234 of file IOVProxy.cc.

References checkTransaction(), m_data, m_session, runTheMatrix::ret, and cond::persistency::throwException().

                                                                                                {
      if (!m_data.get())
        throwException("No tag has been loaded.", "IOVProxy::getMetadata()");
      checkTransaction("IOVProxy::getMetadata");
      std::tuple<std::string, boost::posix_time::ptime, boost::posix_time::ptime> ret;
      if (!m_session->iovSchema().tagTable().getMetadata(
              m_data->tag, std::get<0>(ret), std::get<1>(ret), std::get<2>(ret))) {
        throwException("Metadata for tag \"" + m_data->tag + "\" have not been found in the database.",
                       "IOVProxy::getMetadata()");
      }
      return ret;
    }

bool IOVProxy::isEmpty

(

)

const

Definition at line 247 of file IOVProxy.cc.

References m_data.

Referenced by plotting.Plot::clone().

                                 {
      return m_data.get() ? (m_data->sinceGroups.empty() && m_data->iovSequence.empty()) : true;
    }

cond::Time_t IOVProxy::lastValidatedTime

(

)

const

Definition at line 230 of file IOVProxy.cc.

References m_data, and cond::time::MIN_VAL().

                                                 {
      return m_data.get() ? m_data->lastValidatedTime : cond::time::MIN_VAL;
    }

void IOVProxy::load	(	const std::string &	tag,
		bool	full = false
	)

Definition at line 116 of file IOVProxy.cc.

Referenced by MatrixToProcess.MatrixToProcess::getProcess(), MatrixToProcess.MatrixToProcess::listAll(), ConfigBuilder.ConfigBuilder::prepare_FILTER(), cond::persistency::Session::readIov(), and reload().

                                                       {
      boost::posix_time::ptime notime;
      load(tag, notime, full);
    }

void IOVProxy::load	(	const std::string &	tag,
		const boost::posix_time::ptime &	snapshottime,
		bool	full = false
	)

Definition at line 121 of file IOVProxy.cc.

References checkTransaction(), m_data, m_session, cond::time::MAX_VAL(), cond::time::MIN_VAL(), reset(), cond::time::sinceGroupSize(), loadRecoTauTagMVAsFromPrepDB_cfi::snapshotTime, AlCaHLTBitMon_QueryRunRegistry::string, tag(), and cond::persistency::throwException().

Referenced by MatrixToProcess.MatrixToProcess::getProcess(), MatrixToProcess.MatrixToProcess::listAll(), and ConfigBuilder.ConfigBuilder::prepare_FILTER().

                                                                                                 {
      if (!m_data.get())
        return;

      // clear
      reset();

      checkTransaction("IOVProxy::load");

      std::string dummy;
      if (!m_session->iovSchema().tagTable().select(tag,
                                                    m_data->timeType,
                                                    m_data->payloadType,
                                                    m_data->synchronizationType,
                                                    m_data->endOfValidity,
                                                    dummy,
                                                    m_data->lastValidatedTime)) {
        throwException("Tag \"" + tag + "\" has not been found in the database.", "IOVProxy::load");
      }
      m_data->tag = tag;

      // now get the iov sequence when required
      if (full) {
        // load the full iov sequence in this case!
        m_data->groupLowerIov = cond::time::MIN_VAL;
        m_data->groupHigherIov = cond::time::MAX_VAL;
        m_session->iovSchema().iovTable().select(
            m_data->tag, m_data->groupLowerIov, m_data->groupHigherIov, snapshotTime, m_data->iovSequence);
        m_data->full = true;
      } else {
        m_session->iovSchema().iovTable().getGroups(
            m_data->tag, snapshotTime, cond::time::sinceGroupSize(m_data->timeType), m_data->sinceGroups);
        m_data->full = false;
      }
      m_data->range = false;
      m_data->snapshotTime = snapshotTime;
    }

std::pair< cond::Time_t, cond::Time_t > IOVProxy::loadedGroup

(

)

const

Definition at line 383 of file IOVProxy.cc.

References m_data, cond::time::MAX_VAL(), and cond::time::MIN_VAL().

                                                                {
      return m_data.get() ? std::make_pair(m_data->groupLowerIov, m_data->groupHigherIov)
                          : std::make_pair(cond::time::MAX_VAL, cond::time::MIN_VAL);
    }

int IOVProxy::loadedSize

(

)

const

Definition at line 371 of file IOVProxy.cc.

References m_data.

Referenced by popcon::PopConBTransitionSourceHandler< T >::checkBOn(), popcon::PopConESTransitionSourceHandler< T >::checkLowGain(), cond::persistency::copyIov(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), and cond::persistency::importIovs().

{ return m_data.get() ? m_data->iovSequence.size() : 0; }

void IOVProxy::loadRange	(	const std::string &	tag,
		const cond::Time_t &	begin,
		const cond::Time_t &	end
	)

Definition at line 159 of file IOVProxy.cc.

Referenced by cond::persistency::importIovs(), and reload().

                                                                                                 {
      boost::posix_time::ptime no_time;
      loadRange(tag, begin, end, no_time);
    }

void IOVProxy::loadRange	(	const std::string &	tag,
		const cond::Time_t &	begin,
		const cond::Time_t &	end,
		const boost::posix_time::ptime &	snapshottime
	)

Definition at line 164 of file IOVProxy.cc.

References begin(), checkTransaction(), end(), m_data, m_session, reset(), AlCaHLTBitMon_QueryRunRegistry::string, tag(), and cond::persistency::throwException().

                                                                       {
      if (!m_data.get())
        return;

      // clear
      reset();

      checkTransaction("IOVProxy::loadRange");

      std::string dummy;
      if (!m_session->iovSchema().tagTable().select(tag,
                                                    m_data->timeType,
                                                    m_data->payloadType,
                                                    m_data->synchronizationType,
                                                    m_data->endOfValidity,
                                                    dummy,
                                                    m_data->lastValidatedTime)) {
        throwException("Tag \"" + tag + "\" has not been found in the database " + m_session->connectionString,
                       "IOVProxy::loadRange");
      }
      m_data->tag = tag;

      m_session->iovSchema().iovTable().getRange(m_data->tag, begin, end, snapshotTime, m_data->iovSequence);

      m_data->full = false;
      m_data->range = true;
      m_data->groupLowerIov = begin;
      m_data->groupHigherIov = end;
    }

size_t IOVProxy::numberOfQueries

(

)

const

Definition at line 381 of file IOVProxy.cc.

References m_data.

{ return m_data.get() ? m_data->numberOfQueries : 0; }

IOVProxy & IOVProxy::operator=

(

const IOVProxy &

rhs

)

Definition at line 110 of file IOVProxy.cc.

References m_data, and m_session.

                                                     {
      m_data = rhs.m_data;
      m_session = rhs.m_session;
      return *this;
    }

std::string IOVProxy::payloadObjectType

(

)

const

Definition at line 222 of file IOVProxy.cc.

References m_data, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by cond::persistency::copyIov(), and cond::persistency::importIovs().

{ return m_data.get() ? m_data->payloadType : std::string(""); }

void IOVProxy::reload

(

)

Definition at line 197 of file IOVProxy.cc.

References load(), loadRange(), and m_data.

                          {
      if (m_data.get() && !m_data->tag.empty()) {
        if (m_data->range)
          loadRange(m_data->tag, m_data->groupLowerIov, m_data->groupHigherIov, m_data->snapshotTime);
        else
          load(m_data->tag, m_data->snapshotTime, m_data->full);
      }
    }

void IOVProxy::reset

(

void

)

Definition at line 206 of file IOVProxy.cc.

References m_data, cond::time::MAX_VAL(), and cond::time::MIN_VAL().

Referenced by MatrixReader.MatrixReader::__init__(), load(), loadRange(), data_sources.json_list::next(), and MatrixReader.MatrixReader::showRaw().

                         {
      if (m_data.get()) {
        m_data->groupLowerIov = cond::time::MAX_VAL;
        m_data->groupHigherIov = cond::time::MIN_VAL;
        m_data->sinceGroups.clear();
        m_data->iovSequence.clear();
        m_data->numberOfQueries = 0;
        m_data->full = false;
        m_data->range = false;
      }
    }

int IOVProxy::sequenceSize

(

)

const

Definition at line 373 of file IOVProxy.cc.

References checkTransaction(), m_data, m_session, and runTheMatrix::ret.

Referenced by popcon::PopCon::initialize(), and cond::service::PoolDBOutputService::tagInfo().

                                     {
      checkTransaction("IOVProxy::sequenceSize");
      size_t ret = 0;
      m_session->iovSchema().iovTable().getSize(m_data->tag, m_data->snapshotTime, ret);

      return ret;
    }

const std::shared_ptr< SessionImpl > & IOVProxy::session

(

)

const

Definition at line 388 of file IOVProxy.cc.

References m_session.

Referenced by cond::persistency::KeyList::loadFromDB(), and cond::persistency::KeyList::setKeys().

{ return m_session; }

cond::SynchronizationType IOVProxy::synchronizationType

(

)

const

Definition at line 224 of file IOVProxy.cc.

References m_data, and cond::SYNCH_ANY.

Referenced by cond::persistency::copyIov(), and cond::persistency::importIovs().

                                                                {
      return m_data.get() ? m_data->synchronizationType : cond::SYNCH_ANY;
    }

std::string IOVProxy::tag

(

)

const

Definition at line 218 of file IOVProxy.cc.

References m_data, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by load(), loadRange(), and cond::DataProxyWrapperBase::reload().

{ return m_data.get() ? m_data->tag : std::string(""); }

cond::TimeType IOVProxy::timeType

(

)

const

Definition at line 220 of file IOVProxy.cc.

References cond::invalid, and m_data.

Referenced by cond::persistency::copyIov(), popcon::PopConBTransitionSourceHandler< T >::getObjectsForBTransition(), popcon::PopConESTransitionSourceHandler< T >::getObjectsForESTransition(), and cond::persistency::importIovs().

{ return m_data.get() ? m_data->timeType : cond::invalid; }

Member Data Documentation

std::shared_ptr<IOVProxyData> cond::persistency::IOVProxy::m_data

private

Definition at line 158 of file IOVProxy.h.

Referenced by begin(), end(), endOfValidity(), fetchSequence(), find(), getLast(), getMetadata(), isEmpty(), lastValidatedTime(), load(), loadedGroup(), loadedSize(), loadRange(), numberOfQueries(), operator=(), payloadObjectType(), reload(), reset(), sequenceSize(), synchronizationType(), tag(), and timeType().

std::shared_ptr<SessionImpl> cond::persistency::IOVProxy::m_session

private

Definition at line 159 of file IOVProxy.h.

Referenced by checkTransaction(), fetchSequence(), getLast(), getMetadata(), load(), loadRange(), operator=(), sequenceSize(), and session().