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 ()
	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
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 102 of file IOVProxy.cc.

                      :
      m_data(),
      m_session(){
    }

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

explicit

Definition at line 107 of file IOVProxy.cc.

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

IOVProxy::IOVProxy

(

const IOVProxy &

rhs

)

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

References m_data.

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

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

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

References m_data.

Referenced by Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), find(), getInterval(), 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 173 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 190 of file IOVProxy.cc.

References m_data, and m_session.

Referenced by find().

                                                                               {
      m_data->iovSequence.clear();
      m_session->iovSchema().iovTable().selectLatestByGroup( m_data->tag, lowerGroup, higherGroup, m_data->iovSequence );
      
      m_data->lowerGroup = lowerGroup;
      m_data->higherGroup = higherGroup;
      
      m_data->numberOfQueries++;
    }

IOVProxy::Iterator IOVProxy::find

(

cond::Time_t

time

)

Definition at line 230 of file IOVProxy.cc.

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

Referenced by BeautifulSoup.Tag::__getattr__(), BeautifulSoup.Tag::firstText(), getInterval(), 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 )
      
      if( m_data->lowerGroup==cond::time::MAX_VAL ||
      // case 1 : target outside
      time < m_data->lowerGroup || time>= m_data->higherGroup ){
    
    // 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 );
      }
      
      // 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 269 of file IOVProxy.cc.

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

                                                    {
      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 277 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 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;
    }

bool IOVProxy::isEmpty

(

)

const

Definition at line 181 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 177 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 123 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->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->lowerGroup = cond::time::MIN_VAL;
    m_data->higherGroup = 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 301 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->lowerGroup, m_data->higherGroup ): std::make_pair( cond::time::MAX_VAL, cond::time::MIN_VAL );
    }

int IOVProxy::loadedSize

(

)

const

Definition at line 286 of file IOVProxy.cc.

References m_data.

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

size_t IOVProxy::numberOfQueries

(

)

const

Definition at line 297 of file IOVProxy.cc.

References m_data.

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

IOVProxy & IOVProxy::operator=

(

const IOVProxy &

rhs

)

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

References m_data, and AlCaHLTBitMon_QueryRunRegistry::string.

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

void IOVProxy::reload

(

)

Definition at line 147 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 151 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->lowerGroup = cond::time::MAX_VAL;
    m_data->higherGroup = cond::time::MIN_VAL;
    m_data->sinceGroups.clear();
    m_data->iovSequence.clear();
    m_data->numberOfQueries = 0;
      }
    }

int IOVProxy::sequenceSize

(

)

const

Definition at line 290 of file IOVProxy.cc.

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

Referenced by 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 305 of file IOVProxy.cc.

References m_session.

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

                                                              {
      return m_session;
    }

std::string IOVProxy::tag

(

)

const

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

References cond::invalid, and m_data.

Referenced by 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 138 of file IOVProxy.h.

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

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

private

Definition at line 139 of file IOVProxy.h.

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