#include <WriterProxy.h>

Inheritance diagram for l1t::WriterProxyT< Record, Type >:

Public Member Functions
std::string	save (const edm::EventSetup &setup) const override

void	setToken (edm::ConsumesCollector cc) override

	~WriterProxyT () override

Public Member Functions inherited from l1t::WriterProxy
virtual	~WriterProxy ()

Private Attributes
edm::ESGetToken< Type, Record >	rcdToken

Detailed Description

template<class Record, class Type>
class l1t::WriterProxyT< Record, Type >

Definition at line 47 of file WriterProxy.h.

Constructor & Destructor Documentation

template<class Record , class Type >

l1t::WriterProxyT< Record, Type >::~WriterProxyT ( )

inlineoverride

Definition at line 52 of file WriterProxy.h.

52 {}

Member Function Documentation

template<class Record , class Type >

std::string l1t::WriterProxyT< Record, Type >::save ( const edm::EventSetup & setup ) const

inlineoverridevirtual

Implements l1t::WriterProxy.

Definition at line 57 of file WriterProxy.h.

References cond::persistency::Transaction::commit(), cond::service::PoolDBOutputService::forceInit(), edm::EventSetup::getHandle(), patZpeak::handle, cond::persistency::Transaction::isActive(), edm::Service< T >::isAvailable(), edm::ESHandle< class >::product(), l1t::WriterProxyT< Record, Type >::rcdToken, cond::service::PoolDBOutputService::session(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, cond::persistency::Transaction::start(), cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::Session::transaction().

Referenced by SpecificationBuilder_cfi.Specification::saveAll().

                                                               {
       // load record and type from EventSetup and save them in db
       edm::ESHandle<Type> handle;
 
       try {
         handle = setup.getHandle(rcdToken);
       } catch (l1t::DataAlreadyPresentException& ex) {
         return std::string();
       }
       // If handle is invalid, then data is already in DB
 
       edm::Service<cond::service::PoolDBOutputService> poolDb;
       if (!poolDb.isAvailable()) {
         throw cond::Exception("DataWriter: PoolDBOutputService not available.");
       }
       poolDb->forceInit();
       cond::persistency::Session session = poolDb->session();
       if (not session.transaction().isActive())
         session.transaction().start(false);  // true: read only, false: read-write
 
       std::shared_ptr<Type> pointer = std::make_shared<Type>(*(handle.product()));
       std::string payloadToken = session.storePayload(*pointer);
 
       session.transaction().commit();
       return payloadToken;
     }