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)
std::pair< cond::Time_t, cond::Time_t >	loadedGroup () const
int	loadedSize () const
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 103 of file IOVProxy.cc.

                      :
      m_data(),
      m_session(){
    }

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

explicit

Definition at line 108 of file IOVProxy.cc.

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

IOVProxy::IOVProxy

(

const IOVProxy &

rhs

)

Definition at line 113 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 228 of file IOVProxy.cc.

References m_data.

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

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

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

private

Definition at line 200 of file IOVProxy.cc.

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

Referenced by find(), getLast(), getMetadata(), load(), 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 236 of file IOVProxy.cc.

References m_data.

Referenced by cond::persistency::copyIov(), Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), getInterval(), cond::persistency::importIovs(), cond::persistency::KeyList::load(), l1t::DataWriter::payloadToken(), and cond::persistency::BasePayloadProxy::setIntervalFor().

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

cond::Time_t IOVProxy::endOfValidity

(

)

const

Definition at line 178 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 205 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().selectLatestByGroup( m_data->tag, lowerGroup, higherGroup, 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 = std::get<0>(m_data->iovSequence.back());
    } else {
      m_data->groupHigherIov = cond::time::MAX_VAL;
    }
      }
      
      m_data->numberOfQueries++;
    }

IOVProxy::Iterator IOVProxy::find

(

cond::Time_t

time

)

      Pageing switched off temporarily 
  if( m_data->groupLowerIov == cond::time::MAX_VAL ||

case 1 : target outside time < m_data->groupLowerIov || time >= m_data->groupHigherIov ){

a new query required! first determine the groups auto iGLow = search( time, m_data->sinceGroups ); if( iGLow == m_data->sinceGroups.end() ){ so suitable group=no iov at all! exiting... return end(); } auto iGHigh = iGLow; cond::Time_t lowG = 0; unless the low group is the first one available, move the previous one to fully cover the interval if( iGLow != m_data->sinceGroups.begin() ){ iGLow–; lowG = *iGLow; } the upper group will be also extended to the next (covering in total up to three groups ) iGHigh++; cond::Time_t highG = cond::time::MAX_VAL; if( iGHigh != m_data->sinceGroups.end() ) { iGHigh++; if( iGHigh != m_data->sinceGroups.end() ) highG = *iGHigh; } finally, get the iovs for the selected group interval!! fetchSequence( lowG, highG ); }

Definition at line 258 of file IOVProxy.cc.

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

Referenced by BeautifulSoup.Tag::__getattr__(), cond::persistency::copyIov(), BeautifulSoup.Tag::firstText(), getInterval(), cond::persistency::importIovs(), cond::persistency::KeyList::load(), l1t::DataWriter::payloadToken(), and cond::persistency::BasePayloadProxy::setIntervalFor().

                                                   {
      checkTransaction( "IOVProxy::find" );
      // first check the available iov cache:
      // case 0 empty cache ( the first request )
      
      // only one page...
      if( m_data->groupLowerIov == cond::time::MAX_VAL ){
    fetchSequence( cond::time::MIN_VAL, cond::time::MAX_VAL );
      }
      
      // 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->endOfValidity );
    }

cond::Iov_t IOVProxy::getInterval

(

cond::Time_t

time

)

Definition at line 303 of file IOVProxy.cc.

References end(), find(), cond::persistency::throwException(), and TrackValidation_HighPurity_cff::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 311 of file IOVProxy.cc.

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

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

                               {
      checkTransaction( "IOVProxy::getLast" );
      cond::Iov_t ret;
      if( m_session->iovSchema().iovTable().getLastIov( m_data->tag, ret.since, ret.payloadId ) ){
    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 186 of file IOVProxy.cc.

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

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

                                                                                                 {
      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 196 of file IOVProxy.cc.

References m_data.

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

cond::Time_t IOVProxy::lastValidatedTime

(

)

const

Definition at line 182 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 124 of file IOVProxy.cc.

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

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

                                                        {
      // 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_session->iovSchema().iovTable().selectLatest( m_data->tag, m_data->iovSequence );
    m_data->groupLowerIov = cond::time::MIN_VAL;
    m_data->groupHigherIov = cond::time::MAX_VAL;
      } else {
    m_session->iovSchema().iovTable().selectGroups( m_data->tag, m_data->sinceGroups );
      }
    }

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

(

)

const

Definition at line 335 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 320 of file IOVProxy.cc.

References m_data.

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

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

size_t IOVProxy::numberOfQueries

(

)

const

Definition at line 331 of file IOVProxy.cc.

References m_data.

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

IOVProxy & IOVProxy::operator=

(

const IOVProxy &

rhs

)

Definition at line 118 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 170 of file IOVProxy.cc.

References m_data, and AlCaHLTBitMon_QueryRunRegistry::string.

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

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

void IOVProxy::reload

(

)

Definition at line 148 of file IOVProxy.cc.

References load(), and m_data.

                         {
      if(m_data.get() && !m_data->tag.empty()) load( m_data->tag );
    }

void IOVProxy::reset

(

void

)

Definition at line 152 of file IOVProxy.cc.

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

Referenced by MatrixReader.MatrixReader::__init__(), load(), 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;
      }
    }

int IOVProxy::sequenceSize

(

)

const

Definition at line 324 of file IOVProxy.cc.

References checkTransaction(), m_data, m_session, and run_regression::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, ret );
      return ret;
    }

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

(

)

const

Definition at line 339 of file IOVProxy.cc.

References m_session.

Referenced by cond::persistency::KeyList::load().

                                                              {
      return m_session;
    }

cond::SynchronizationType IOVProxy::synchronizationType

(

)

const

Definition at line 174 of file IOVProxy.cc.

References m_data, and cond::SYNCHRONIZATION_UNKNOWN.

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

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

std::string IOVProxy::tag

(

)

const

Definition at line 162 of file IOVProxy.cc.

References m_data, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by load(), cond::persistency::BasePayloadProxy::reload(), and Inspector.Inspector::SetTag().

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

cond::TimeType IOVProxy::timeType

(

)

const

Definition at line 166 of file IOVProxy.cc.

References cond::invalid, and m_data.

Referenced by cond::persistency::copyIov(), cond::persistency::copyTag(), cond::persistency::importIovs(), cond::persistency::migrateTag(), and cond::persistency::BasePayloadProxy::timeType().

                                          {
      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 142 of file IOVProxy.h.

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

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

private

Definition at line 143 of file IOVProxy.h.

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