RunInfoProxy.cc

Go to the documentation of this file.

#include "CondCore/CondDB/interface/RunInfoProxy.h"
#include "SessionImpl.h"

namespace cond {

  namespace persistency {

    // implementation details...
    // only hosting data in this case
    class RunInfoProxyData {
    public: 
      
      RunInfoProxyData():
    runList(){
      }
      
      // the data loaded
      RunInfoProxy::RunInfoData runList;
    };

    RunInfoProxy::Iterator::Iterator():
      m_current(){
    }

    RunInfoProxy::Iterator::Iterator( RunInfoData::const_iterator current ):
      m_current( current ){
    }
    
    RunInfoProxy::Iterator::Iterator( const Iterator& rhs ):
      m_current( rhs.m_current ){
    }
    
    RunInfoProxy::Iterator& RunInfoProxy::Iterator::operator=( const Iterator& rhs ){
      if( this != &rhs ){
    m_current = rhs.m_current;
      }
      return *this;
    }

    cond::RunInfo_t RunInfoProxy::Iterator::operator*() {
      return cond::RunInfo_t( *m_current );
    }
    
    RunInfoProxy::Iterator& RunInfoProxy::Iterator::operator++(){
      m_current++;
      return *this;
    }
    
    RunInfoProxy::Iterator RunInfoProxy::Iterator::operator++(int){
      Iterator tmp( *this );
      operator++();
      return tmp;
    }
    
    bool RunInfoProxy::Iterator::operator==( const Iterator& rhs ) const {
      if( m_current != rhs.m_current ) return false;
      return true;
    }
    
    bool RunInfoProxy::Iterator::operator!=( const Iterator& rhs ) const {
      return !operator==( rhs );
    }
    
    RunInfoProxy::RunInfoProxy():
      m_data(),
      m_session(){
    }
    
    RunInfoProxy::RunInfoProxy( const std::shared_ptr<SessionImpl>& session ):
      m_data( new RunInfoProxyData ),
      m_session( session ){
    }
    
    RunInfoProxy::RunInfoProxy( const RunInfoProxy& rhs ):
      m_data( rhs.m_data ),
      m_session( rhs.m_session ){
    }
    
    RunInfoProxy& RunInfoProxy::operator=( const RunInfoProxy& rhs ){
      m_data = rhs.m_data;
      m_session = rhs.m_session;
      return *this;
    }
    
    //
    void RunInfoProxy::load( Time_t low, Time_t up ){
      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 );
       std::cout <<"Min="<<std::get<0>(m_data->runList.front())<<" max="<<std::get<0>(m_data->runList.back())<<std::endl;
    }

    void RunInfoProxy::load( const boost::posix_time::ptime& low, const boost::posix_time::ptime& up ){
      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 );
    }

    void RunInfoProxy::reset(){
      if( m_data.get() ){
    m_data->runList.clear();
      }
    }
    
    void RunInfoProxy::checkTransaction( const std::string& ctx ){
      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::begin() const {
      if( m_data.get() ){
    return Iterator( m_data->runList.begin() );
      } 
      return Iterator();
    }
    
    RunInfoProxy::Iterator RunInfoProxy::end() const {
      if( m_data.get() ){
    return Iterator( m_data->runList.end() );
      } 
      return Iterator();
    }

    // comparison functor for iov tuples: Time_t
    struct IOVRunComp {
      
      bool operator()( const std::tuple<cond::Time_t,boost::posix_time::ptime,boost::posix_time::ptime>& x, const cond::Time_t& y ){ return ( y > std::get<0>(x) ); }
      
    };
    
    // comparison functor for iov tuples: boost::posix_time::ptime
    struct IOVTimeComp {
      
      bool operator()( const std::tuple<cond::Time_t,boost::posix_time::ptime,boost::posix_time::ptime>& x, const boost::posix_time::ptime& y ){ return ( y > std::get<2>(x) ); }
      
    };

    RunInfoProxy::Iterator RunInfoProxy::find( Time_t target ) const {
      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 {
      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{
      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 {
      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;
    }


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

  }
}