l1t::DataWriter Class Reference

#include <DataWriter.h>

Public Member Functions
	DataWriter ()
bool	fillLastTriggerKeyList (L1TriggerKeyList &output)
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 (L1TriggerKeyList *keyList, edm::RunNumber_t sinceRun=0, bool logTransactions=false)
std::string	writePayload (const edm::EventSetup &setup, const std::string &recordType)
	~DataWriter ()

Detailed Description

Definition at line 35 of file DataWriter.h.

Constructor & Destructor Documentation

DataWriter()

l1t::DataWriter::DataWriter

(

)

Definition at line 12 of file DataWriter.cc.

{}

~DataWriter()

l1t::DataWriter::~DataWriter

(

)

Definition at line 13 of file DataWriter.cc.

{}

Member Function Documentation

fillLastTriggerKeyList()

bool l1t::DataWriter::fillLastTriggerKeyList

(

L1TriggerKeyList &

output

)

Definition at line 147 of file DataWriter.cc.

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

Referenced by L1CondDBIOVWriter::analyze(), L1CondDBPayloadWriter::analyze(), L1O2OTestAnalyzer::analyze(), L1GtRunSettingsViewer::analyze(), L1ConfigOnlineProdBase< L1HtMissScaleRcd, L1CaloEtScale >::getObjectKey(), and L1SubsystemKeysOnlineProd::produce().

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

lastPayloadToken()

std::string l1t::DataWriter::lastPayloadToken

(

const std::string &

recordName

)

Definition at line 136 of file DataWriter.cc.

References edm::Service< T >::isAvailable(), align_cfg::recordName, 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;
  }

payloadToken()

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

Definition at line 113 of file DataWriter.cc.

References run_AlCaRecoTriggerBitsUpdateWorkflow::iovs, edm::Service< T >::isAvailable(), align_cfg::recordName, convertSQLiteXML::runNumber, cond::persistency::IOVProxy::selectAll(), cond::service::PoolDBOutputService::session(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, AlCaHLTBitMon_QueryRunRegistry::string, and cond::service::PoolDBOutputService::tag().

Referenced by 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;
  }

readObject()

template<class T >

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

Definition at line 72 of file DataWriter.h.

References edm::Service< T >::isAvailable(), payloadToken(), cond::service::PoolDBOutputService::session(), and run_AlCaRecoTriggerBitsUpdateWorkflow::session.

Referenced by L1CondDBIOVWriter::analyze(), L1GtRunSettingsViewer::analyze(), and fillLastTriggerKeyList().

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

    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();
  }

updateIOV()

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

Definition at line 72 of file DataWriter.cc.

References cond::service::PoolDBOutputService::appendSinceTime(), cond::service::PoolDBOutputService::beginOfTime(), cond::service::PoolDBOutputService::createNewIOV(), edm::Service< T >::isAvailable(), cond::service::PoolDBOutputService::isNewTagRequest(), payloadToken(), RPCCPPFLinkMapPopConAnalyzer_cfi::sinceRun, cond::service::PoolDBOutputService::tag(), dumpRecoGeometry_cfg::tagInfo, and cond::service::PoolDBOutputService::tagInfo().

Referenced by L1TCaloParamsWriter::analyze(), CaloParamsWriter::analyze(), CaloConfigWriter::analyze(), L1CondDBIOVWriter::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;
  }

writeKeyList()

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

tr.start( false );

Definition at line 49 of file DataWriter.cc.

References edm::Service< T >::isAvailable(), payloadToken(), cond::service::PoolDBOutputService::session(), run_AlCaRecoTriggerBitsUpdateWorkflow::session, RPCCPPFLinkMapPopConAnalyzer_cfi::sinceRun, AlCaHLTBitMon_QueryRunRegistry::string, and updateIOV().

Referenced by L1CondDBPayloadWriter::analyze().

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

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

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

    // Commit before calling updateIOV(), otherwise PoolDBOutputService gets
    // confused.
    //tr.commit ();
    tr.close();

    // Set L1TriggerKeyList IOV
    updateIOV("L1TriggerKeyListRcd", payloadToken, sinceRun, logTransactions);
  }

writePayload()

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

Definition at line 15 of file DataWriter.cc.

References get, edm::Service< T >::isAvailable(), payloadToken(), cond::service::PoolDBOutputService::session(), singleTopDQM_cfi::setup, AlCaHLTBitMon_QueryRunRegistry::string, cond::persistency::Session::transaction(), and convertToRaw::writer.

Referenced by L1TCaloParamsWriter::analyze(), CaloConfigWriter::analyze(), CaloParamsWriter::analyze(), and L1CondDBPayloadWriter::analyze().

                                                                                            {
    WriterFactory* factory = WriterFactory::get();
    std::unique_ptr<WriterProxy> writer(factory->create(recordType + "@Writer"));
    if (writer.get() == nullptr) {
      throw cond::Exception("DataWriter: could not create WriterProxy with name " + recordType + "@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);

    cond::persistency::TransactionScope tr(poolDb->session().transaction());
    //   // 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);

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

    tr.close();
    //   tr.commit ();

    return payloadToken;
  }