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

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.

: m_data(), m_session() {}

RunInfoProxy() [2/3]

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

explicit

Definition at line 54 of file RunInfoProxy.cc.

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

RunInfoProxy() [3/3]

RunInfoProxy::RunInfoProxy

(

const RunInfoProxy &

rhs

)

Definition at line 57 of file RunInfoProxy.cc.

: 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.

References m_data.

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

checkTransaction()

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

private

Definition at line 105 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);
    }

end()

RunInfoProxy::Iterator RunInfoProxy::end

(

void

)

const

Definition at line 119 of file RunInfoProxy.cc.

References m_data.

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

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

find() [1/2]

RunInfoProxy::Iterator RunInfoProxy::find

(

Time_t

target

)

const

Definition at line 142 of file RunInfoProxy.cc.

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

Referenced by 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();
    }

find() [2/2]

RunInfoProxy::Iterator RunInfoProxy::find

(

const boost::posix_time::ptime &

target

)

const

Definition at line 150 of file RunInfoProxy.cc.

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

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

get() [1/2]

cond::RunInfo_t RunInfoProxy::get

(

Time_t

target

)

const

Definition at line 159 of file RunInfoProxy.cc.

References end(), find(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, 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().

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

get() [2/2]

cond::RunInfo_t RunInfoProxy::get

(

const boost::posix_time::ptime &

target

)

const

Definition at line 169 of file RunInfoProxy.cc.

References end(), find(), ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, 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().

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

load() [1/2]

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

Definition at line 66 of file RunInfoProxy.cc.

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

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;
      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)");
      }
    }

load() [2/2]

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

Definition at line 82 of file RunInfoProxy.cc.

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().

                                                                                           {
      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&)");
      }
    }

operator=()

RunInfoProxy & RunInfoProxy::operator=

(

const RunInfoProxy &

rhs

)

Definition at line 59 of file RunInfoProxy.cc.

References m_data, and m_session.

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

reset()

void RunInfoProxy::reset

(

void

)

Definition at line 99 of file RunInfoProxy.cc.

References m_data.

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

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

size()

int RunInfoProxy::size

(

void

)

const

Definition at line 179 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

m_data

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

private

Definition at line 110 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 111 of file RunInfoProxy.h.

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