#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 (const boost::posix_time::ptime &target) const

Iterator	find (Time_t target) const

cond::RunInfo_t	get (const boost::posix_time::ptime &target) const

cond::RunInfo_t	get (Time_t target) const

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

void	load (Time_t low, Time_t up)

RunInfoProxy &	operator= (const RunInfoProxy &rhs)

void	reset ()

	RunInfoProxy ()

	RunInfoProxy (const RunInfoProxy &rhs)

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

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

◆ RunInfoData

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() [1/3]

RunInfoProxy::RunInfoProxy ( )

Definition at line 52 of file RunInfoProxy.cc.

52 : m_data(), m_session() {}

◆ RunInfoProxy() [2/3]

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

explicit

Definition at line 54 of file RunInfoProxy.cc.

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

◆ RunInfoProxy() [3/3]

RunInfoProxy::RunInfoProxy ( const RunInfoProxy & rhs )

Definition at line 57 of file RunInfoProxy.cc.

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

Member Function Documentation

◆ begin()

RunInfoProxy::Iterator RunInfoProxy::begin ( void ) const

Definition at line 112 of file RunInfoProxy.cc.

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

References m_data.

◆ checkTransaction()

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

private

Definition at line 105 of file RunInfoProxy.cc.

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

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

Referenced by load().

◆ end()

RunInfoProxy::Iterator RunInfoProxy::end ( void ) const

Definition at line 119 of file RunInfoProxy.cc.

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

References m_data.

Referenced by Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), and get().

◆ find() [1/2]

RunInfoProxy::Iterator RunInfoProxy::find ( const boost::posix_time::ptime & target ) const

Definition at line 150 of file RunInfoProxy.cc.

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

References pfDeepBoostedJetPreprocessParams_cfi::lower_bound, m_data, AlCaHLTBitMon_ParallelJobs::p, and filterCSVwithJSON::target.

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

◆ find() [2/2]

RunInfoProxy::Iterator RunInfoProxy::find ( Time_t target ) const

Definition at line 142 of file RunInfoProxy.cc.

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

References pfDeepBoostedJetPreprocessParams_cfi::lower_bound, m_data, AlCaHLTBitMon_ParallelJobs::p, and filterCSVwithJSON::target.

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

◆ get() [1/2]

cond::RunInfo_t RunInfoProxy::get ( const boost::posix_time::ptime & target ) const

Definition at line 169 of file RunInfoProxy.cc.

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

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

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), submitPVValidationJobs.BetterConfigParser::__updateDict(), data_sources.json_list::as_dicts(), data_sources.json_list::as_table(), util.rrapi.RRApi::columns(), 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(), submitPVValidationJobs.BetterConfigParser::getResultingSection(), data_sources.json_list::indices(), data_sources.json_list::last(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), util.rrapi.RRApi::reports(), rrapi.RRApi::reports(), rrapi.RRApi::tables(), util.rrapi.RRApi::tables(), util.rrapi.RRApi::tags(), rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

◆ get() [2/2]

cond::RunInfo_t RunInfoProxy::get ( Time_t target ) const

Definition at line 159 of file RunInfoProxy.cc.

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

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

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), submitPVValidationJobs.BetterConfigParser::__updateDict(), data_sources.json_list::as_dicts(), data_sources.json_list::as_table(), util.rrapi.RRApi::columns(), 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(), submitPVValidationJobs.BetterConfigParser::getResultingSection(), data_sources.json_list::indices(), data_sources.json_list::last(), util.rrapi.RRApi::report(), rrapi.RRApi::report(), util.rrapi.RRApi::reports(), rrapi.RRApi::reports(), rrapi.RRApi::tables(), util.rrapi.RRApi::tables(), util.rrapi.RRApi::tags(), rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

◆ load() [1/2]

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

Definition at line 82 of file RunInfoProxy.cc.

                                                                                            {
       if (!m_data.get())
         return;
  
       // clear
       reset();
  
       checkTransaction("RunInfoProxy::load(const boost::posix_time::ptime&,const boost::posix_time::ptime&)");
  
       std::string dummy;
       if (!m_session->runInfoSchema().runInfoTable().getInclusiveTimeRange(low, up, m_data->runList)) {
         throwException("No runs have been found in the interval (" + boost::posix_time::to_simple_string(low) + "," +
                            boost::posix_time::to_simple_string(up) + ")",
                        "RunInfoProxy::load(boost::posix_time::ptime&,const boost::posix_time::ptime&)");
       }
     }

References checkTransaction(), LaserClient_cfi::low, m_data, m_session, reset(), AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::throwException(), and up.

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

◆ load() [2/2]

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

Definition at line 66 of file RunInfoProxy.cc.

                                                  {
       if (!m_data.get())
         return;
  
       // clear
       reset();
  
       checkTransaction("RunInfoProxy::load(Time_t,Time_t)");
  
       std::string dummy;
       if (!m_session->runInfoSchema().runInfoTable().getInclusiveRunRange(low, up, m_data->runList)) {
         throwException("No runs have been found in the range (" + std::to_string(low) + "," + std::to_string(up) + ")",
                        "RunInfoProxy::load(Time_t,Time_t)");
       }
     }

References checkTransaction(), LaserClient_cfi::low, m_data, m_session, reset(), AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::throwException(), and up.

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

◆ operator=()

RunInfoProxy & RunInfoProxy::operator= ( const RunInfoProxy & rhs )

Definition at line 59 of file RunInfoProxy.cc.

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

References m_data, and m_session.

◆ reset()

void RunInfoProxy::reset ( void )

Definition at line 99 of file RunInfoProxy.cc.

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

References m_data.

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

◆ size()

int RunInfoProxy::size ( void ) const

Definition at line 179 of file RunInfoProxy.cc.

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

References m_data.

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

Member Data Documentation

◆ m_data

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

private

Definition at line 103 of file RunInfoProxy.h.

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

◆ m_session

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

private

Definition at line 104 of file RunInfoProxy.h.

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

Classes

Public Types

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Member Typedef Documentation

◆ RunInfoData

Constructor & Destructor Documentation

◆ RunInfoProxy() [1/3]

◆ RunInfoProxy() [2/3]

◆ RunInfoProxy() [3/3]

Member Function Documentation

◆ begin()

◆ checkTransaction()

◆ end()

◆ find() [1/2]

◆ find() [2/2]

◆ get() [1/2]

◆ get() [2/2]

◆ load() [1/2]

◆ load() [2/2]

◆ operator=()

◆ reset()

◆ size()

Member Data Documentation

◆ m_data

◆ m_session