cond::persistency::KeyList Class Reference

#include <KeyList.h>

Public Member Functions
template<typename T >
std::shared_ptr< T >	get (size_t n) const
void	init (IOVProxy iovProxy)
void	load (const std::vector< unsigned long long > &keys)
size_t	size () const

Private Attributes
std::map< size_t, std::pair< std::string, std::pair< cond::Binary, cond::Binary > > >	m_data
std::vector< std::shared_ptr< void > >	m_objects
IOVProxy	m_proxy

Detailed Description

Definition at line 32 of file KeyList.h.

Member Function Documentation

template<typename T >

std::shared_ptr<T> cond::persistency::KeyList::get ( size_t  n ) const

inline

Definition at line 40 of file KeyList.h.

References mps_fire::i, m_data, m_objects, gen::n, size(), and cond::persistency::throwException().

Referenced by Options.Options::__getitem__(), betterConfigParser.BetterConfigParser::__updateDict(), DTUserKeyedConfigPopConAnalyzer::analyze(), DTKeyedConfigPopConAnalyzer::analyze(), DTKeyedConfigDBDump::analyze(), data_sources.json_list::as_dicts(), data_sources.json_list::as_table(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), util.rrapi.RRApi::columns(), rrapi.RRApi::columns(), util.rrapi.RRApi::count(), rrapi.RRApi::count(), rrapi.RRApi::data(), util.rrapi.RRApi::data(), data_sources.json_list::first(), DTKeyedConfigCache::get(), betterConfigParser.BetterConfigParser::getCompares(), betterConfigParser.BetterConfigParser::getGeneral(), betterConfigParser.BetterConfigParser::getResultingSection(), data_sources.json_list::indices(), data_sources.json_list::last(), rrapi.RRApi::report(), util.rrapi.RRApi::report(), util.rrapi.RRApi::reports(), rrapi.RRApi::reports(), util.rrapi.RRApi::tables(), rrapi.RRApi::tables(), rrapi.RRApi::tags(), util.rrapi.RRApi::tags(), rrapi.RRApi::templates(), util.rrapi.RRApi::templates(), util.rrapi.RRApi::workspaces(), and rrapi.RRApi::workspaces().

                                           {
    if( n >= size() ) throwException( "Index outside the bounds of the key array.", 
                      "KeyList::get");
    if( !m_objects[n] ){
      auto i = m_data.find( n );
      if( i != m_data.end() ){
        m_objects[n] = deserialize<T>( i->second.first, i->second.second.first, i->second.second.second );
        m_data.erase( n );
      } else {
        throwException( "Payload for index "+std::to_string(n)+" has not been found.",
                "KeyList::get");
      }
    }
    return std::static_pointer_cast<T>( m_objects[n] );
      }

void cond::persistency::KeyList::init

(

IOVProxy

iovProxy

)

Definition at line 8 of file KeyList.cc.

References m_data, m_objects, and m_proxy.

                                          {
      m_proxy = iovProxy;
      m_data.clear();
      m_objects.clear();
    }

void cond::persistency::KeyList::load

(

const std::vector< unsigned long long > &

keys

)

Definition at line 14 of file KeyList.cc.

References cond::persistency::Transaction::commit(), cond::persistency::IOVProxy::end(), cond::persistency::Session::fetchPayloadData(), cond::persistency::IOVProxy::find(), mps_fire::i, m_data, m_objects, m_proxy, AlCaHLTBitMon_ParallelJobs::p, alignCSCRings::s, cond::persistency::IOVProxy::session(), cond::persistency::Transaction::start(), cond::throwException(), and cond::persistency::Session::transaction().

Referenced by DTKeyedConfigDBDump::analyze(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), DTKeyedConfigCache::get(), MatrixToProcess.MatrixToProcess::getProcess(), MatrixToProcess.MatrixToProcess::listAll(), and ConfigBuilder.ConfigBuilder::prepare_FILTER().

                                                                 {
      std::shared_ptr<SessionImpl> simpl = m_proxy.session();
      if( !simpl.get() ) cond::throwException("The KeyList has not been initialized.","KeyList::load");
      Session s( simpl );
      s.transaction().start( true );
      m_data.clear();
      m_objects.resize(keys.size());
      for (size_t i=0; i<keys.size(); ++i) {
    m_objects[i].reset();
    if (keys[i]!=0) {
      auto p = m_proxy.find(keys[i]);
      if ( p!= m_proxy.end()) {
        auto item = m_data.insert( std::make_pair( i, std::make_pair("",std::make_pair(cond::Binary(),cond::Binary()) ) ) );
                       if( ! s.fetchPayloadData( (*p).payloadId, item.first->second.first, 
                                 item.first->second.second.first, item.first->second.second.second ) )
          cond::throwException("The Iov contains a broken payload reference.","KeyList::load");    
      }
    }
      }
      s.transaction().commit();
    }

size_t cond::persistency::KeyList::size ( void  ) const

inline

Definition at line 56 of file KeyList.h.

References m_objects.

Referenced by ntupleDataFormat._Collection::__iter__(), ntupleDataFormat._Collection::__len__(), DTUserKeyedConfigPopConAnalyzer::analyze(), DTKeyedConfigPopConAnalyzer::analyze(), and get().

{ return m_objects.size();}

Member Data Documentation

std::map<size_t,std::pair<std::string,std::pair<cond::Binary,cond::Binary> > > cond::persistency::KeyList::m_data

mutableprivate

Definition at line 62 of file KeyList.h.

Referenced by get(), init(), and load().

std::vector<std::shared_ptr<void> > cond::persistency::KeyList::m_objects

mutableprivate

Definition at line 63 of file KeyList.h.

Referenced by get(), init(), load(), and size().

IOVProxy cond::persistency::KeyList::m_proxy

private

Definition at line 60 of file KeyList.h.

Referenced by init(), and load().