l1t::DataWriterExt Class Reference

#include <DataWriterExt.h>

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

Detailed Description

Definition at line 36 of file DataWriterExt.h.

Constructor & Destructor Documentation

l1t::DataWriterExt::DataWriterExt

(

)

Definition at line 13 of file DataWriterExt.cc.

{}

l1t::DataWriterExt::~DataWriterExt

(

)

Definition at line 14 of file DataWriterExt.cc.

References AlCaHLTBitMon_QueryRunRegistry::string.

{}

Member Function Documentation

bool l1t::DataWriterExt::fillLastTriggerKeyList

(

L1TriggerKeyListExt &

output

)

Definition at line 199 of file DataWriterExt.cc.

References funct::false, lastPayloadToken(), readObject(), AlCaHLTBitMon_QueryRunRegistry::string, and funct::true.

Referenced by L1CondDBPayloadWriterExt::analyze(), L1CondDBIOVWriterExt::analyze(), 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 ;
    }
}

std::string l1t::DataWriterExt::lastPayloadToken

(

const std::string &

recordName

)

Definition at line 184 of file DataWriterExt.cc.

References edm::Service< T >::isAvailable(), cond::TagInfo_t::lastPayloadToken, 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 tagInfo ;
  poolDb->tagInfo( recordName, tagInfo ) ;
  return tagInfo.lastPayloadToken ;
}

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

Definition at line 156 of file DataWriterExt.cc.

References cond::persistency::Transaction::commit(), cond::persistency::IOVProxy::end(), cond::persistency::IOVProxy::find(), edm::Service< T >::isAvailable(), cond::persistency::Session::readIov(), cond::service::PoolDBOutputService::session(), dataDML::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();

  std::string payloadToken("");
  auto iP = iov.find( runNumber );
  if( iP != iov.end() ){
    payloadToken = (*iP).payloadId; 
  }
  session.transaction().commit() ;
  return payloadToken ;
}

template<class T >

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

session.transaction().start(true);

session.transaction().commit ();

Definition at line 79 of file DataWriterExt.h.

References cond::persistency::Session::fetchPayload(), cond::service::PoolDBOutputService::forceInit(), edm::Service< T >::isAvailable(), payloadToken(), cond::service::PoolDBOutputService::session(), and dataDML::session.

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();
 
  // Get object from CondDB
  std::shared_ptr<T> ref = session.fetchPayload<T>(payloadToken) ;
  outputObject = *ref ;
}

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

Definition at line 94 of file DataWriterExt.cc.

References cond::service::PoolDBOutputService::appendSinceTime(), cond::service::PoolDBOutputService::beginOfTime(), cond::service::PoolDBOutputService::createNewIOV(), cond::service::PoolDBOutputService::endOfTime(), funct::false, edm::Service< T >::isAvailable(), cond::service::PoolDBOutputService::isNewTagRequest(), cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, payloadToken(), AlCaHLTBitMon_QueryRunRegistry::string, cond::service::PoolDBOutputService::tag(), cond::service::PoolDBOutputService::tagInfo(), and funct::true.

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,
                poolDb->endOfTime(),
                esRecordName,
                logTransactions ) ;
    }
  else
    {   
      cond::TagInfo tagInfo ;
      poolDb->tagInfo( esRecordName, tagInfo ) ;

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

      if( tagInfo.lastPayloadToken != payloadToken )
    {
      poolDb->appendSinceTime( payloadToken,
                   sinceRun,
                   esRecordName,
                   logTransactions ) ;
    }
      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
	)

tr.start( false );

tr.commit ();

Definition at line 61 of file DataWriterExt.cc.

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

Referenced by L1CondDBPayloadWriterExt::analyze().

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

  // 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.
  tr.close ();
  
  // Set L1TriggerKeyListExt IOV
  updateIOV( "L1TriggerKeyListExtRcd",
         payloadToken,
         sinceRun,
         logTransactions ) ;
}

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

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

Definition at line 19 of file DataWriterExt.cc.

References reco::get(), edm::Service< T >::isAvailable(), nullptr, payloadToken(), AlCaHLTBitMon_QueryRunRegistry::string, and cscNeutronWriter_cfi::writer.

Referenced by L1CondDBPayloadWriterExt::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);

//   // 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.commit ();

  return payloadToken ;
}