l1t::WriterProxyT< Record, Type > Class Template Reference

#include <WriterProxy.h>

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

Public Member Functions
std::string	save (const edm::EventSetup &setup) const override
	~WriterProxyT () override
Public Member Functions inherited from l1t::WriterProxy
virtual	~WriterProxy ()

Detailed Description

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

Definition at line 44 of file WriterProxy.h.

Constructor & Destructor Documentation

template<class Record , class Type >

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

inlineoverride

Definition at line 46 of file WriterProxy.h.

{}

Member Function Documentation

template<class Record , class Type >

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

inlineoverridevirtual

tr.start(false);

tr.commit();

Implements l1t::WriterProxy.

Definition at line 49 of file WriterProxy.h.

References cond::service::PoolDBOutputService::forceInit(), edm::EventSetup::get(), patZpeak::handle, edm::Service< T >::isAvailable(), edm::ESHandle< class >::product(), cond::service::PoolDBOutputService::session(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, 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 {
        setup.get<Record>().get(handle);
      } 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();
      cond::persistency::TransactionScope tr(session.transaction());
      // if throw transaction will unroll

      std::shared_ptr<Type> pointer = std::make_shared<Type>(*(handle.product()));
      std::string payloadToken = session.storePayload(*pointer);
      tr.close();
      return payloadToken;
    }