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

                      :
      m_data(),
      m_session(){
    }

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

explicit

Definition at line 114 of file IOVProxy.cc.

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

IOVProxy::IOVProxy

(

const IOVProxy &

rhs

)

Definition at line 119 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 257 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->groupHigherIov, m_data->endOfValidity );
      } 
      return Iterator();
    }

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

private

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

References m_data.

Referenced by cond::persistency::copyIov(), Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), find(), 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->groupHigherIov, m_data->endOfValidity );
      } 
      return Iterator();
    }

cond::Time_t IOVProxy::endOfValidity

(

)

const

Definition at line 203 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 230 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();
      if( m_data->snapshotTime.is_not_a_date_time() ){
    m_session->iovSchema().iovTable().selectLatestByGroup( m_data->tag, lowerGroup, higherGroup, m_data->iovSequence );
      } else {
    m_session->iovSchema().iovTable().selectSnapshotByGroup( 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 288 of file IOVProxy.cc.

References checkTransaction(), end(), fetchSequence(), m_data, cond::time::MAX_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" );
      // 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 317 of file IOVProxy.cc.

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

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

References checkTransaction(), m_data, m_session, cond::time::MAX_VAL(), convertSQLiteXML::ok, 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;
      bool ok = false;
      if( m_data->snapshotTime.is_not_a_date_time() ){
    ok = m_session->iovSchema().iovTable().getLastIov( m_data->tag, ret.since, ret.payloadId );
      } else {
    ok = m_session->iovSchema().iovTable().getSnapshotLastIov( 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 211 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 221 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 207 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 130 of file IOVProxy.cc.

Referenced by MatrixToProcess.MatrixToProcess::getProcess(), MatrixToProcess.MatrixToProcess::listAll(), 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 136 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(), and MatrixToProcess.MatrixToProcess::listAll().

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

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

(

)

const

Definition at line 357 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 338 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 353 of file IOVProxy.cc.

References m_data.

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

IOVProxy & IOVProxy::operator=

(

const IOVProxy &

rhs

)

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

References load(), and m_data.

Referenced by cond::persistency::BasePayloadProxy::reload().

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

void IOVProxy::reset

(

void

)

Definition at line 177 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 342 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;
      if( m_data->snapshotTime.is_not_a_date_time() ){
    m_session->iovSchema().iovTable().getSize( m_data->tag, ret );
      } else {
    m_session->iovSchema().iovTable().getSnapshotSize( m_data->tag, m_data->snapshotTime, ret );
      }
      return ret;
    }

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

(

)

const

Definition at line 361 of file IOVProxy.cc.

References m_session.

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

                                                              {
      return m_session;
    }

cond::SynchronizationType IOVProxy::synchronizationType

(

)

const

Definition at line 199 of file IOVProxy.cc.

References m_data, and cond::SYNCH_ANY.

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

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

std::string IOVProxy::tag

(

)

const

Definition at line 187 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 191 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 146 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 147 of file IOVProxy.h.

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