l1t::DataWriterExt Class Reference

#include <DataWriterExt.h>

Public Member Functions
	DataWriterExt ()
	DataWriterExt (const std::string &)
bool	fillLastTriggerKeyList (L1TriggerKeyListExt &output)
WriterProxy *	getWriter ()
std::string	lastPayloadToken (const std::string &recordName)
std::string	payloadToken (const std::string &recordName, edm::RunNumber_t runNumber)
template<class T >
void	readObject (const std::string &payloadToken, T &outputObject)
bool	updateIOV (const std::string &esRecordName, const std::string &payloadToken, edm::RunNumber_t sinceRun, bool logTransactions=false)
void	writeKeyList (L1TriggerKeyListExt *keyList, edm::RunNumber_t sinceRun=0, bool logTransactions=false)
std::string	writePayload (const edm::EventSetup &setup)
std::string	writePayload (const edm::EventSetup &setup, const std::string &recordType)
	~DataWriterExt ()

Private Attributes
WriterProxyPtr	writer_

Detailed Description

Definition at line 37 of file DataWriterExt.h.

Constructor & Destructor Documentation

l1t::DataWriterExt::DataWriterExt

(

)

Definition at line 15 of file DataWriterExt.cc.

{}

l1t::DataWriterExt::DataWriterExt

(

const std::string &

recordType

)

Definition at line 19 of file DataWriterExt.cc.

References get, mergeVDriftHistosByStation::name, and writer_.

                                                          {
    WriterFactory* factory = WriterFactory::get();
    writer_ = factory->create(recordType + "@Writer");
    if (writer_.get() == nullptr) {
      throw cond::Exception("DataWriter: could not create WriterProxy with name " + recordType + "@Writer");
    }
    edm::LogVerbatim("L1-O2O DataWriterExt::DataWriterExt")
        << "Created new " << typeid(writer_).name() << "  | address " << writer_.get() << "  | rcd " << recordType;
  }

l1t::DataWriterExt::~DataWriterExt

(

)

Definition at line 29 of file DataWriterExt.cc.

{}

Member Function Documentation

bool l1t::DataWriterExt::fillLastTriggerKeyList

(

L1TriggerKeyListExt &

output

)

Definition at line 182 of file DataWriterExt.cc.

References lastPayloadToken(), readObject(), and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by L1O2OTestAnalyzerExt::analyze(), L1ConfigOnlineProdBaseExt< TRcd, TData >::getObjectKey(), and L1SubsystemKeysOnlineProdExt::produce().

                                                                        {
    std::string keyListToken = lastPayloadToken("L1TriggerKeyListExtRcd");
    if (keyListToken.empty()) {
      return false;
    } else {
      readObject(keyListToken, output);
      return true;
    }
  }

WriterProxy* l1t::DataWriterExt::getWriter ( )

inline

Definition at line 72 of file DataWriterExt.h.

References writer_.

{ return writer_.get(); }

std::string l1t::DataWriterExt::lastPayloadToken

(

const std::string &

recordName

)

Definition at line 171 of file DataWriterExt.cc.

References edm::Service< T >::isAvailable(), cond::TagInfo_t::lastInterval, cond::Iov_t::payloadId, dumpRecoGeometry_cfg::tagInfo, and cond::service::PoolDBOutputService::tagInfo().

Referenced by fillLastTriggerKeyList().

                                                                       {
    edm::Service<cond::service::PoolDBOutputService> poolDb;
    if (!poolDb.isAvailable()) {
      throw cond::Exception("DataWriter: PoolDBOutputService not available.");
    }

    cond::TagInfo_t tagInfo;
    poolDb->tagInfo(recordName, tagInfo);
    return tagInfo.lastInterval.payloadId;
  }

std::string l1t::DataWriterExt::payloadToken	(	const std::string &	recordName,
		edm::RunNumber_t	runNumber
	)

Definition at line 148 of file DataWriterExt.cc.

References cond::persistency::Transaction::commit(), run_AlCaRecoTriggerBitsUpdateWorkflow::iovs, edm::Service< T >::isAvailable(), cond::persistency::Session::readIov(), cond::persistency::IOVProxy::selectAll(), cond::service::PoolDBOutputService::session(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, cond::persistency::Transaction::start(), AlCaHLTBitMon_QueryRunRegistry::string, cond::service::PoolDBOutputService::tag(), and cond::persistency::Session::transaction().

Referenced by L1O2OTestAnalyzerExt::analyze(), readObject(), updateIOV(), writeKeyList(), and writePayload().

                                                                                             {
    edm::Service<cond::service::PoolDBOutputService> poolDb;
    if (!poolDb.isAvailable()) {
      throw cond::Exception("DataWriter: PoolDBOutputService not available.");
    }

    // Get tag corresponding to EventSetup record name.
    std::string iovTag = poolDb->tag(recordName);

    // Get IOV token for tag.
    cond::persistency::Session session = poolDb->session();
    cond::persistency::IOVProxy iov = session.readIov(iovTag);
    session.transaction().start();
    auto iovs = iov.selectAll();
    std::string payloadToken("");
    auto iP = iovs.find(runNumber);
    if (iP != iovs.end()) {
      payloadToken = (*iP).payloadId;
    }
    session.transaction().commit();
    return payloadToken;
  }

template<class T >

void l1t::DataWriterExt::readObject	(	const std::string &	payloadToken,
		T &	outputObject
	)

Definition at line 81 of file DataWriterExt.h.

References cond::persistency::Transaction::commit(), cond::persistency::Session::fetchPayload(), cond::service::PoolDBOutputService::forceInit(), edm::Service< T >::isAvailable(), payloadToken(), cond::service::PoolDBOutputService::session(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, cond::persistency::Transaction::start(), and cond::persistency::Session::transaction().

Referenced by L1CondDBIOVWriterExt::analyze(), and fillLastTriggerKeyList().

                                                                               {
    edm::Service<cond::service::PoolDBOutputService> poolDb;
    if (!poolDb.isAvailable()) {
      throw cond::Exception("DataWriter: PoolDBOutputService not available.");
    }

    poolDb->forceInit();
    cond::persistency::Session session = poolDb->session();
    session.transaction().start(true);

    // Get object from CondDB
    std::shared_ptr<T> ref = session.fetchPayload<T>(payloadToken);
    outputObject = *ref;
    session.transaction().commit();
  }

bool l1t::DataWriterExt::updateIOV	(	const std::string &	esRecordName,
		const std::string &	payloadToken,
		edm::RunNumber_t	sinceRun,
		bool	logTransactions = false
	)

Definition at line 107 of file DataWriterExt.cc.

References cond::service::PoolDBOutputService::appendSinceTime(), cond::service::PoolDBOutputService::beginOfTime(), cond::service::PoolDBOutputService::createNewIOV(), edm::Service< T >::isAvailable(), cond::service::PoolDBOutputService::isNewTagRequest(), cond::TagInfo_t::lastInterval, cond::Iov_t::payloadId, payloadToken(), cond::Iov_t::since, cond::service::PoolDBOutputService::tag(), dumpRecoGeometry_cfg::tagInfo, and cond::service::PoolDBOutputService::tagInfo().

Referenced by L1CondDBIOVWriterExt::analyze(), and writeKeyList().

                                                      {
    edm::LogVerbatim("L1-O2O") << esRecordName << " PAYLOAD TOKEN " << payloadToken;

    edm::Service<cond::service::PoolDBOutputService> poolDb;
    if (!poolDb.isAvailable()) {
      throw cond::Exception("DataWriter: PoolDBOutputService not available.");
    }

    bool iovUpdated = true;

    if (poolDb->isNewTagRequest(esRecordName)) {
      sinceRun = poolDb->beginOfTime();
      poolDb->createNewIOV(payloadToken, sinceRun, esRecordName);
    } else {
      cond::TagInfo_t tagInfo;
      poolDb->tagInfo(esRecordName, tagInfo);

      if (sinceRun == 0)  // find last since and add 1
      {
        sinceRun = tagInfo.lastInterval.since;
        ++sinceRun;
      }

      if (tagInfo.lastInterval.payloadId != payloadToken) {
        poolDb->appendSinceTime(payloadToken, sinceRun, esRecordName);
      } else {
        iovUpdated = false;
        edm::LogVerbatim("L1-O2O") << "IOV already up to date.";
      }
    }

    if (iovUpdated) {
      edm::LogVerbatim("L1-O2O") << esRecordName << " " << poolDb->tag(esRecordName) << " SINCE " << sinceRun;
    }

    return iovUpdated;
  }

void l1t::DataWriterExt::writeKeyList	(	L1TriggerKeyListExt *	keyList,
		edm::RunNumber_t	sinceRun = 0,
		bool	logTransactions = false
	)

Definition at line 84 of file DataWriterExt.cc.

References cond::persistency::Transaction::commit(), cond::service::PoolDBOutputService::forceInit(), cond::persistency::Transaction::isActive(), edm::Service< T >::isAvailable(), payloadToken(), cond::service::PoolDBOutputService::session(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, cond::persistency::Transaction::start(), cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::Session::transaction(), and updateIOV().

                                                                                                              {
    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);

    // Write L1TriggerKeyListExt payload and save payload token before committing
    std::shared_ptr<L1TriggerKeyListExt> pointer(keyList);
    std::string payloadToken = session.storePayload(*pointer);

    // Commit before calling updateIOV(), otherwise PoolDBOutputService gets
    // confused. ??? why?

    // Set L1TriggerKeyListExt IOV
    session.transaction().commit();
    updateIOV("L1TriggerKeyListExtRcd", payloadToken, sinceRun, logTransactions);
  }

std::string l1t::DataWriterExt::writePayload

(

const edm::EventSetup &

setup

)

Definition at line 31 of file DataWriterExt.cc.

References edm::Service< T >::isAvailable(), mergeVDriftHistosByStation::name, payloadToken(), AlCaHLTBitMon_QueryRunRegistry::string, and writer_.

                                                                  {
    edm::LogVerbatim("L1-O2O DataWriterExt::writePayload") << "Will use stored writer at " << writer_.get();

    edm::Service<cond::service::PoolDBOutputService> poolDb;
    if (!poolDb.isAvailable()) {
      throw cond::Exception("DataWriter: PoolDBOutputService not available.");
    }

    // 2010-02-16: Move session and transaction to WriterProxy::save().  Otherwise, if another transaction is
    // started while WriterProxy::save() is called (e.g. in a ESProducer like L1ConfigOnlineProdBase), the
    // transaction here will become read-only.
    std::string payloadToken = writer_->save(setup);
    auto& writerRef = *writer_.get();
    edm::LogVerbatim("L1-O2O") << typeid(writerRef).name() << " PAYLOAD TOKEN " << payloadToken;

    return payloadToken;
  }

std::string l1t::DataWriterExt::writePayload	(	const edm::EventSetup &	setup,
		const std::string &	recordType
	)

cond::persistency::TransactionScope tr(poolDb->session().transaction());

Definition at line 49 of file DataWriterExt.cc.

References get, edm::Service< T >::isAvailable(), eostools::move(), mergeVDriftHistosByStation::name, payloadToken(), AlCaHLTBitMon_QueryRunRegistry::string, and writer_.

                                                                                               {
    WriterFactory* factory = WriterFactory::get();
    WriterProxyPtr writer(factory->create(recordType + "@Writer"));
    if (writer.get() == nullptr) {
      throw cond::Exception("DataWriter: could not create WriterProxy with name " + recordType + "@Writer");
    }
    writer_ = std::move(writer);

    edm::Service<cond::service::PoolDBOutputService> poolDb;
    if (!poolDb.isAvailable()) {
      throw cond::Exception("DataWriter: PoolDBOutputService not available.");
    }

    // 2010-02-16: Move session and transaction to WriterProxy::save().  Otherwise, if another transaction is
    // started while WriterProxy::save() is called (e.g. in a ESProducer like L1ConfigOnlineProdBase), the
    // transaction here will become read-only.
    //   cond::DbSession session = poolDb->session();
    //   cond::DbScopedTransaction tr(session);

    //   // if throw transaction will unroll
    //   tr.start(false);

    // update key to have new payload registered for record-type pair.
    //  std::string payloadToken = writer->save( setup, session ) ;
    std::string payloadToken = writer_->save(setup);
    auto& writerRef = *writer_.get();
    edm::LogVerbatim("L1-O2O") << typeid(writerRef).name() << " PAYLOAD TOKEN " << payloadToken;

    //   tr.commit ();

    return payloadToken;
  }

Member Data Documentation

WriterProxyPtr l1t::DataWriterExt::writer_

private

Definition at line 75 of file DataWriterExt.h.

Referenced by DataWriterExt(), getWriter(), and writePayload().