#include <PayloadProxy.h>

Inheritance diagram for cond::BasePayloadProxy:

Classes
struct	ObjId
struct	Stats
Public Types
typedef std::vector< ObjId >	ObjIds
Public Member Functions
	BasePayloadProxy (cond::DbSession &session, const std::string &token, bool errorPolicy)
virtual void	invalidateCache ()=0
IOVProxy const &	iov () const
bool	isValid () const
cond::ValidityInterval	loadFor (cond::Time_t time)
cond::ValidityInterval	loadFor (size_t n)
virtual void	loadMore (CondGetter const &)
void	make ()
bool	refresh ()
cond::ValidityInterval	setIntervalFor (cond::Time_t time)
TimeType	timetype () const
std::string const &	token () const
virtual	~BasePayloadProxy ()
Public Attributes
Stats	stats
Static Public Attributes
static Stats	gstats = {0,0,0}
Protected Attributes
bool	m_doThrow
IOVElementProxy	m_element
IOVProxy	m_iov
std::string	m_token
Private Member Functions
virtual bool	load (cond::DbSession &session, std::string const &token)=0

Detailed Description

Definition at line 23 of file PayloadProxy.h.

Member Typedef Documentation

typedef std::vector<ObjId> cond::BasePayloadProxy::ObjIds

Definition at line 31 of file PayloadProxy.h.

Constructor & Destructor Documentation

cond::BasePayloadProxy::BasePayloadProxy	(	cond::DbSession &	session,
		const std::string &	token,
		bool	errorPolicy
	)

Definition at line 24 of file PayloadProxy.cc.

References gstats, cond::BasePayloadProxy::Stats::nProxy, asciidump::s, and stats.

                                                       :
    m_doThrow(errorPolicy), m_iov(session,token,true,false) {
    ++gstats.nProxy;
    BasePayloadProxy::Stats s = {0,0,0,ObjIds()};
    stats = s;
  }

cond::BasePayloadProxy::~BasePayloadProxy ( ) [virtual]

Definition at line 34 of file PayloadProxy.cc.

{}

Member Function Documentation

virtual void cond::BasePayloadProxy::invalidateCache ( ) [pure virtual]

Implemented in cond::PayloadProxy< cond::KeyList >, cond::PayloadProxy< DataT >, and cond::PayloadProxy< std::vector< cond::Time_t > >.

IOVProxy const& cond::BasePayloadProxy::iov ( ) const [inline]

Definition at line 72 of file PayloadProxy.h.

References m_iov.

{ return m_iov;}

bool cond::BasePayloadProxy::isValid ( void ) const

Definition at line 89 of file PayloadProxy.cc.

References cond::invalidTime(), m_element, cond::IOVElementProxy::since(), cond::IOVElementProxy::till(), and cond::IOVElementProxy::token().

Referenced by make().

                                       {
    return m_element.since()!=cond::invalidTime && m_element.till()!=cond::invalidTime
      &&  !m_element.token().empty();
  }

virtual bool cond::BasePayloadProxy::load	(	cond::DbSession &	session,
		std::string const &	token
	)		`[private, pure virtual]`

Implemented in cond::PayloadProxy< cond::KeyList >, cond::PayloadProxy< DataT >, and cond::PayloadProxy< std::vector< cond::Time_t > >.

Referenced by make().

cond::ValidityInterval cond::BasePayloadProxy::loadFor ( size_t n )

Definition at line 42 of file PayloadProxy.cc.

References cond::IOVProxy::iov(), m_element, m_iov, make(), n, cond::IOVElementProxy::set(), cond::IOVElementProxy::since(), and cond::IOVElementProxy::till().

                                                         {
    m_element.set(m_iov.iov(),n);
    make();
    return cond::ValidityInterval(m_element.since(),m_element.till());
  }

cond::ValidityInterval cond::BasePayloadProxy::loadFor ( cond::Time_t time )

Definition at line 36 of file PayloadProxy.cc.

References cond::IOVProxy::find(), m_element, m_iov, make(), cond::IOVElementProxy::since(), and cond::IOVElementProxy::till().

                                                                {
    m_element = *m_iov.find(time);
    make();
    return cond::ValidityInterval(m_element.since(),m_element.till());
  }

virtual void cond::BasePayloadProxy::loadMore ( CondGetter const & ) [inline, virtual]

Reimplemented in cond::PayloadProxy< cond::KeyList >.

Definition at line 74 of file PayloadProxy.h.

{}

void cond::BasePayloadProxy::make ( )

Definition at line 49 of file PayloadProxy.cc.

References cond::DbTransaction::commit(), cond::IOVElementProxy::db(), ExpressReco_HICollisions_FallBack::e, Exception, gstats, cond::BasePayloadProxy::Stats::ids, cond::invalidTime(), isValid(), load(), m_doThrow, m_element, m_token, cond::BasePayloadProxy::Stats::nLoad, cond::BasePayloadProxy::Stats::nMake, convertSQLiteXML::ok, cond::IOVElementProxy::set(), cond::IOVElementProxy::since(), cond::DbTransaction::start(), stats, cond::IOVElementProxy::token(), token(), cond::DbSession::transaction(), and cms::Exception::what().

Referenced by loadFor().

                               {
    ++gstats.nMake;
    ++stats.nMake;
    bool ok = false;
    if ( isValid()) {
      // check if (afterall) the payload is still the same...
      if (m_element.token()==token()) return;
      cond::DbTransaction& trans = m_element.db().transaction();
      trans.start(true);
      try {
        ok = load( m_element.db(),m_element.token());
        if (ok) m_token = m_element.token();
      } catch( const ora::Exception& e) {
        if (m_doThrow) throw cond::Exception(std::string("Condition Payload loader: ")+ e.what());
        ok = false;
      }
      trans.commit();
    }

    if (!ok) {
      m_element.set(cond::invalidTime,cond::invalidTime,"");
      m_token.clear();
      if (m_doThrow)
        throw cond::Exception("Condition Payload loader: invalid data");
    }
    if (ok) { 
      ++gstats.nLoad; ++stats.nLoad;
      stats.ids.push_back(ObjId());
      fillIt(stats.ids.back(),m_token, m_element.since());
    }
  }

bool cond::BasePayloadProxy::refresh ( )

Definition at line 95 of file PayloadProxy.cc.

References m_element, m_iov, and cond::IOVProxy::refresh().

                                  {
    bool anew = m_iov.refresh();
    if (anew)  m_element = IOVElementProxy();
    return anew;
  }

cond::ValidityInterval cond::BasePayloadProxy::setIntervalFor ( cond::Time_t time )

Definition at line 82 of file PayloadProxy.cc.

References cond::IOVProxy::find(), m_element, m_iov, cond::IOVElementProxy::since(), and cond::IOVElementProxy::till().

                                                                       {
    //FIXME: shall handle truncation...
    if ( (!(time<m_element.till())) || time<m_element.since() )
      m_element = *m_iov.find(time);
    return cond::ValidityInterval(m_element.since(),m_element.till());
  }