cond::persistency::RunInfoProxy Class Reference

#include <RunInfoProxy.h>

Classes
class	Iterator

Public Types
typedef std::vector< std::tuple< Time_t, boost::posix_time::ptime, boost::posix_time::ptime > >	RunInfoData

Public Member Functions
Iterator	begin () const
Iterator	end () const
Iterator	find (Time_t target) const
Iterator	find (const boost::posix_time::ptime &target) const
cond::RunInfo_t	get (Time_t target) const
cond::RunInfo_t	get (const boost::posix_time::ptime &target) const
void	load (Time_t low, Time_t up)
void	load (const boost::posix_time::ptime &low, const boost::posix_time::ptime &up)
RunInfoProxy &	operator= (const RunInfoProxy &rhs)
void	reset ()
	RunInfoProxy ()
	RunInfoProxy (const std::shared_ptr< SessionImpl > &session)
	RunInfoProxy (const RunInfoProxy &rhs)
int	size () const

Private Member Functions
void	checkTransaction (const std::string &ctx)

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

Detailed Description

Definition at line 26 of file RunInfoProxy.h.

Member Typedef Documentation

typedef std::vector<std::tuple<Time_t,boost::posix_time::ptime,boost::posix_time::ptime> > cond::persistency::RunInfoProxy::RunInfoData

Definition at line 28 of file RunInfoProxy.h.

Constructor & Destructor Documentation

RunInfoProxy::RunInfoProxy

(

)

Definition at line 64 of file RunInfoProxy.cc.

                              :
      m_data(),
      m_session(){
    }

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

explicit

Definition at line 69 of file RunInfoProxy.cc.

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

RunInfoProxy::RunInfoProxy

(

const RunInfoProxy &

rhs

)

Definition at line 74 of file RunInfoProxy.cc.

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

Member Function Documentation

RunInfoProxy::Iterator RunInfoProxy::begin

(

void

)

const

Definition at line 121 of file RunInfoProxy.cc.

References m_data.

                                                   {
      if( m_data.get() ){
    return Iterator( m_data->runList.begin() );
      } 
      return Iterator();
    }

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

private

Definition at line 116 of file RunInfoProxy.cc.

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

Referenced by load().

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

RunInfoProxy::Iterator RunInfoProxy::end

(

void

)

const

Definition at line 128 of file RunInfoProxy.cc.

References m_data.

Referenced by Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), cond::payloadInspector::TimeHistoryPlot< PayloadType, Y >::fill(), and get().

                                                 {
      if( m_data.get() ){
    return Iterator( m_data->runList.end() );
      } 
      return Iterator();
    }

RunInfoProxy::Iterator RunInfoProxy::find

(

Time_t

target

)

const

Definition at line 149 of file RunInfoProxy.cc.

References m_data, AlCaHLTBitMon_ParallelJobs::p, and edmPickEvents::target.

Referenced by BeautifulSoup.Tag::__getattr__(), cond::payloadInspector::TimeHistoryPlot< PayloadType, Y >::fill(), BeautifulSoup.Tag::firstText(), and get().

                                                                 {
      if( m_data.get() ){
    auto p = std::lower_bound( m_data->runList.begin(), m_data->runList.end(), target, IOVRunComp() );
        return Iterator( p );
      } 
      return Iterator();
    }

RunInfoProxy::Iterator RunInfoProxy::find

(

const boost::posix_time::ptime &

target

)

const

Definition at line 157 of file RunInfoProxy.cc.

References m_data, AlCaHLTBitMon_ParallelJobs::p, and edmPickEvents::target.

Referenced by BeautifulSoup.Tag::__getattr__(), and BeautifulSoup.Tag::firstText().

                                                                                       {
      if( m_data.get() ){
    auto p = std::lower_bound( m_data->runList.begin(), m_data->runList.end(), target, IOVTimeComp() );
        return Iterator( p );
      } 
      return Iterator();
    }

cond::RunInfo_t RunInfoProxy::get

(

Time_t

target

)

const

Definition at line 166 of file RunInfoProxy.cc.

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

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), data_sources.json_list::as_dicts(), data_sources.json_list::as_table(), rrapi.RRApi::columns(), util.rrapi.RRApi::columns(), util.rrapi.RRApi::count(), rrapi.RRApi::count(), util.rrapi.RRApi::data(), rrapi.RRApi::data(), data_sources.json_list::first(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), data_sources.json_list::indices(), data_sources.json_list::last(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), rrapi.RRApi::reports(), util.rrapi.RRApi::reports(), rrapi.RRApi::tables(), util.rrapi.RRApi::tables(), rrapi.RRApi::tags(), util.rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

                                                        {
      Iterator it = find( target );
      if( it == Iterator() ) throwException("No data has been found.","RunInfoProxy::get(Time_t)" );
      if( it == end() ) throwException("The target run has not been found in the selected run range.","RunInfoProxy::get(Time_t)" );
      return *it;
    }

cond::RunInfo_t RunInfoProxy::get

(

const boost::posix_time::ptime &

target

)

const

Definition at line 174 of file RunInfoProxy.cc.

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

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), data_sources.json_list::as_dicts(), data_sources.json_list::as_table(), rrapi.RRApi::columns(), util.rrapi.RRApi::columns(), util.rrapi.RRApi::count(), rrapi.RRApi::count(), util.rrapi.RRApi::data(), rrapi.RRApi::data(), data_sources.json_list::first(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), data_sources.json_list::indices(), data_sources.json_list::last(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), rrapi.RRApi::reports(), util.rrapi.RRApi::reports(), rrapi.RRApi::tables(), util.rrapi.RRApi::tables(), rrapi.RRApi::tags(), util.rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

                                                                               {
      Iterator it = find( target );
      if( it == Iterator() ) throwException("No data has been found.","RunInfoProxy::get(const boost::posix_time::ptime&)" );
      if( it == end() ) throwException("The target time has not been found in the selected time range.","RunInfoProxy::get(const boost::posix_time::ptime&)" );
      return *it;
    }

void RunInfoProxy::load	(	Time_t	low,
		Time_t	up
	)

Definition at line 86 of file RunInfoProxy.cc.

References checkTransaction(), m_data, m_session, reset(), and AlCaHLTBitMon_QueryRunRegistry::string.

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

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

      // clear
      reset();
      
      checkTransaction( "RunInfoProxy::load(Time_t,Time_t)" );
      
       std::string dummy;
       m_session->runInfoSchema().runInfoTable().getInclusiveRunRange( low, up, m_data->runList );
    }

void RunInfoProxy::load	(	const boost::posix_time::ptime &	low,
		const boost::posix_time::ptime &	up
	)

Definition at line 98 of file RunInfoProxy.cc.

References checkTransaction(), m_data, m_session, reset(), and AlCaHLTBitMon_QueryRunRegistry::string.

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

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

      // clear
      reset();
      
      checkTransaction( "RunInfoProxy::load(const boost::posix_time::ptime&,const boost::posix_time::ptime&)" );
      
       std::string dummy;
       m_session->runInfoSchema().runInfoTable().getInclusiveTimeRange( low, up, m_data->runList );
    }

RunInfoProxy & RunInfoProxy::operator=

(

const RunInfoProxy &

rhs

)

Definition at line 79 of file RunInfoProxy.cc.

References m_data, and m_session.

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

void RunInfoProxy::reset

(

void

)

Definition at line 110 of file RunInfoProxy.cc.

References m_data.

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

                            {
      if( m_data.get() ){
    m_data->runList.clear();
      }
    }

int RunInfoProxy::size

(

void

)

const

Definition at line 183 of file RunInfoProxy.cc.

References m_data.

Referenced by ntupleDataFormat._Collection::__iter__(), and ntupleDataFormat._Collection::__len__().

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

Member Data Documentation

std::shared_ptr<RunInfoProxyData> cond::persistency::RunInfoProxy::m_data

private

Definition at line 102 of file RunInfoProxy.h.

Referenced by begin(), end(), find(), load(), operator=(), reset(), and size().

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

private

Definition at line 103 of file RunInfoProxy.h.

Referenced by checkTransaction(), load(), and operator=().