PayloadProxy.cc

Go to the documentation of this file.

#include "CondCore/CondDB/interface/PayloadProxy.h"

namespace cond {

  namespace persistency {

    BasePayloadProxy::BasePayloadProxy() :
      m_iovProxy(),m_session() {
    }

    BasePayloadProxy::~BasePayloadProxy(){}

    void BasePayloadProxy::setUp( Session dbSession ){
      m_session = dbSession;
      invalidateCache();    
    }
    
    void BasePayloadProxy::loadTag( const std::string& tag ){
      m_session.transaction().start(true);
      m_iovProxy = m_session.readIov( tag );
      m_session.transaction().commit();
      invalidateCache();
    }
    
    void BasePayloadProxy::loadTag( const std::string& tag, const boost::posix_time::ptime& snapshotTime ){
      m_session.transaction().start(true);
      m_iovProxy = m_session.readIov( tag, snapshotTime );
      m_session.transaction().commit();
      invalidateCache();
    }

    void BasePayloadProxy::reload(){
      std::string tag = m_iovProxy.tag();
      if( !tag.empty() ) m_iovProxy.reload();
    }
    
    ValidityInterval BasePayloadProxy::setIntervalFor(cond::Time_t time, bool load) {
      if( !m_currentIov.isValidFor( time ) ){
    m_currentIov.clear();
    m_session.transaction().start(true);
    auto it = m_iovProxy.find( time );
    if( it != m_iovProxy.end() ) {
      m_currentIov = *it;
      if(load) loadPayload();
    }
    m_session.transaction().commit();
      }
      return ValidityInterval( m_currentIov.since, m_currentIov.till );
    }
    
    bool BasePayloadProxy::isValid() const {
      return m_currentIov.isValid();
    }

    IOVProxy BasePayloadProxy::iov() {
      return m_iovProxy;
    }

  }
}