#include <PoolDBOutputService.h>

Classes
struct	Record

Public Member Functions
template<typename T >
void	appendSinceTime (T *payloadObj, cond::Time_t sinceTime, const std::string &recordName, bool withlogging=false)

void	appendSinceTime (const std::string &payloadId, cond::Time_t sinceTime, const std::string &recordName, bool withlogging=false)

cond::Time_t	beginOfTime () const

void	closeIOV (Time_t lastTill, const std::string &recordName, bool withlogging=false)

template<typename T >
void	createNewIOV (T *firstPayloadObj, cond::Time_t firstSinceTime, cond::Time_t firstTillTime, const std::string &recordName, bool withlogging=false)

void	createNewIOV (const std::string &firstPayloadId, const std::string payloadType, cond::Time_t firstSinceTime, cond::Time_t firstTillTime, const std::string &recordName, bool withlogging=false)

void	createNewIOV (const std::string &firstPayloadId, cond::Time_t firstSinceTime, cond::Time_t firstTillTime, const std::string &recordName, bool withlogging=false)

cond::Time_t	currentTime () const

cond::Time_t	endOfTime () const

void	forceInit ()

bool	isNewTagRequest (const std::string &recordName)

	PoolDBOutputService (const edm::ParameterSet &iConfig, edm::ActivityRegistry &iAR)

void	postEndJob ()

cond::persistency::Session	session () const

void	setLogHeaderForRecord (const std::string &recordName, const std::string &provenance, const std::string &usertext)

std::string	tag (const std::string &recordName)

void	tagInfo (const std::string &recordName, cond::TagInfo_t &result)

template<typename T >
void	writeOne (T *payload, Time_t time, const std::string &recordName, bool withlogging=false)

virtual	~PoolDBOutputService ()

Private Member Functions
void	connect ()

void	disconnect ()

void	fillRecord (edm::ParameterSet &pset)

void	initDB (bool dummy=false)

Record &	lookUpRecord (const std::string &recordName)

cond::UserLogInfo &	lookUpUserLogInfo (const std::string &recordName)

void	postModuleEvent (edm::StreamContext const &, edm::ModuleCallingContext const &)

void	preEventProcessing (edm::StreamContext const &)

void	preGlobalBeginLumi (edm::GlobalContext const &)

void	preGlobalBeginRun (edm::GlobalContext const &)

void	preModuleEvent (edm::StreamContext const &, edm::ModuleCallingContext const &)

Private Attributes
std::map< std::string, Record >	m_callbacks

bool	m_closeIOV

std::vector< cond::Time_t >	m_currentTimes

bool	m_dbstarted

std::map< std::string, cond::UserLogInfo >	m_logheaders

std::recursive_mutex	m_mutex

std::vector< std::pair< std::string, std::string > >	m_newtags

cond::persistency::Session	m_session

cond::TimeType	m_timetype

std::string	m_timetypestr

Detailed Description

Definition at line 36 of file PoolDBOutputService.h.

Constructor & Destructor Documentation

PoolDBOutputService::PoolDBOutputService	(	const edm::ParameterSet &	iConfig,
		edm::ActivityRegistry &	iAR
	)

Definition at line 39 of file PoolDBOutputService.cc.

References fillRecord(), edm::ParameterSet::getParameter(), cond::lumiid, m_callbacks, m_closeIOV, m_currentTimes, m_dbstarted, m_logheaders, m_session, m_timetype, m_timetypestr, edm::service::SystemBounds::maxNumberOfStreams(), postEndJob(), postModuleEvent(), preEventProcessing(), preGlobalBeginLumi(), preGlobalBeginRun(), preModuleEvent(), cond::runnumber, s_streamIndex, cond::persistency::ConnectionPool::setParameters(), AlCaHLTBitMon_QueryRunRegistry::string, cond::timestamp, cond::time::timeTypeFromName(), and DBConfiguration_cff::toPut.

                                                                                                              : 
   m_timetypestr(""),
   m_currentTimes{},
   m_session(),
   m_dbstarted( false ),
   m_callbacks(),
   m_closeIOV(false),
   m_logheaders()
 {
   m_closeIOV=iConfig.getUntrackedParameter<bool>("closeIOV",m_closeIOV);
 
   m_timetypestr=iConfig.getUntrackedParameter< std::string >("timetype","runnumber");
   m_timetype = cond::time::timeTypeFromName( m_timetypestr );
   
   edm::ParameterSet connectionPset = iConfig.getParameter<edm::ParameterSet>("DBParameters");
   cond::persistency::ConnectionPool connection;
   connection.setParameters( connectionPset );
   connection.configure();
   std::string connectionString = iConfig.getParameter<std::string>("connect");
   m_session = connection.createSession( connectionString, true ); 
   
   typedef std::vector< edm::ParameterSet > Parameters;
   Parameters toPut=iConfig.getParameter<Parameters>("toPut");
   for(Parameters::iterator itToPut = toPut.begin(); itToPut != toPut.end(); ++itToPut)
     fillRecord( *itToPut);
 
 
   iAR.watchPostEndJob(this,&cond::service::PoolDBOutputService::postEndJob);
   iAR.watchPreallocate([this](edm::service::SystemBounds const& iBounds) {
       m_currentTimes.resize(iBounds.maxNumberOfStreams());
     });
   if( m_timetype == cond::timestamp ){ //timestamp
     iAR.watchPreEvent(this,&cond::service::PoolDBOutputService::preEventProcessing);
     iAR.watchPreModuleEvent(this, &cond::service::PoolDBOutputService::preModuleEvent);
     iAR.watchPostModuleEvent(this, &cond::service::PoolDBOutputService::postModuleEvent);
   } else if( m_timetype == cond::runnumber ){//runnumber
     //NOTE: this assumes only one run is being processed at a time.
     // This is true for 7_1_X but plan are to allow multiple in flight at a time
     s_streamIndex = 0;
     iAR.watchPreGlobalBeginRun(this,&cond::service::PoolDBOutputService::preGlobalBeginRun);
   } else if( m_timetype == cond::lumiid ){
     //NOTE: this assumes only one lumi is being processed at a time.
     // This is true for 7_1_X but plan are to allow multiple in flight at a time
     s_streamIndex = 0;
     iAR.watchPreGlobalBeginLumi(this,&cond::service::PoolDBOutputService::preGlobalBeginLumi);
   }
 }

PoolDBOutputService::~PoolDBOutputService ( )

virtual

Definition at line 158 of file PoolDBOutputService.cc.

References m_dbstarted, m_session, cond::persistency::Transaction::rollback(), and cond::persistency::Session::transaction().

                                                     {
   if( m_dbstarted) {
     m_session.transaction().rollback();
   }
 }

Member Function Documentation

template<typename T >

void cond::service::PoolDBOutputService::appendSinceTime	(	T *	payloadObj,
		cond::Time_t	sinceTime,
		const std::string &	recordName,
		bool	withlogging = `false`
	)

inline

Definition at line 104 of file PoolDBOutputService.h.

References align_cfg::recordName, mps_fire::result, AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

                                                                         {
         if( !payloadObj ) throwException( "Provided payload pointer is invalid.","PoolDBOutputService::appendSinceTime");
         appendSinceTime( m_session.storePayload( *payloadObj ),
              sinceTime,
              recordName,
              withlogging);
       }

void PoolDBOutputService::appendSinceTime	(	const std::string &	payloadId,
		cond::Time_t	sinceTime,
		const std::string &	recordName,
		bool	withlogging = `false`
	)

Definition at line 247 of file PoolDBOutputService.cc.

References a, cond::persistency::Session::editIov(), idDealer::editor, cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), lookUpRecord(), lookUpUserLogInfo(), m_mutex, m_session, SiPixelClusterizer_cfi::payloadType, cond::persistency::IOVEditor::payloadType(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), cond::persistency::Session::transaction(), and cond::UserLogInfo::usertext.

                                                {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   cond::persistency::TransactionScope scope( m_session.transaction() );
   Record& myrecord=this->lookUpRecord(recordName);
   if( myrecord.m_isNewTag ) {
     cond::throwException(std::string("Cannot append to non-existing tag ") + myrecord.m_tag,
            "PoolDBOutputService::appendSinceTime");  
   }
   std::string payloadType("");
   try{
     cond::persistency::IOVEditor editor = m_session.editIov( myrecord.m_tag ); 
     payloadType = editor.payloadType();
     editor.insert( time, payloadId );
     cond::UserLogInfo a=this->lookUpUserLogInfo(recordName);
     editor.flush( a.usertext );
 
   }catch(const std::exception& er){
     cond::throwException(std::string(er.what()),
            "PoolDBOutputService::appendSinceTime");
   }
   scope.close();
 }

cond::Time_t PoolDBOutputService::beginOfTime ( ) const

Definition at line 175 of file PoolDBOutputService.cc.

References cond::TimeTypeSpecs::beginValue, m_timetype, and cond::timeTypeSpecs.

                                                  {
   return timeTypeSpecs[m_timetype].beginValue;
 }

void PoolDBOutputService::closeIOV	(	Time_t	lastTill,
		const std::string &	recordName,
		bool	withlogging = `false`
	)

Definition at line 299 of file PoolDBOutputService.cc.

References cond::persistency::Session::editIov(), idDealer::editor, cond::persistency::IOVEditor::flush(), CommonMethods::lock(), lookUpRecord(), cond::service::PoolDBOutputService::Record::m_isNewTag, m_mutex, m_session, cond::service::PoolDBOutputService::Record::m_tag, cond::persistency::IOVEditor::setEndOfValidity(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by popcon::PopCon::finalize().

                                            {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   // not fully working.. not be used for now...
   Record & myrecord  = lookUpRecord(recordName);
   cond::persistency::TransactionScope scope( m_session.transaction() );
 
   if( myrecord.m_isNewTag ) {
     cond::throwException(std::string("Cannot close non-existing tag ") + myrecord.m_tag,
              "PoolDBOutputService::closeIOV");
   }
   cond::persistency::IOVEditor editor = m_session.editIov( myrecord.m_tag ); 
   editor.setEndOfValidity( lastTill );
   editor.flush("Tag closed.");
   scope.close();
 }

void cond::service::PoolDBOutputService::connect ( )

private

template<typename T >

void cond::service::PoolDBOutputService::createNewIOV	(	T *	firstPayloadObj,
		cond::Time_t	firstSinceTime,
		cond::Time_t	firstTillTime,
		const std::string &	recordName,
		bool	withlogging = `false`
	)

inline

Definition at line 73 of file PoolDBOutputService.h.

References CommonMethods::lock(), SiPixelClusterizer_cfi::payloadType, align_cfg::recordName, AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

Referenced by SiStripBadChannelBuilder::algoAnalyze(), DBWriter::analyze(), EcalPFRecHitThresholdsMaker::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), BTagCalibrationDbCreator::beginJob(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload_IOV::beginJob(), QGLikelihoodSystematicsDBWriter::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), JetCorrectorDBWriter::beginJob(), XMLGeometryBuilder::beginJob(), QGLikelihoodDBWriter::beginJob(), SiStripFedCablingBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), GEMRecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), GeometricDetLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), RPCRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), PGeometricDetExtraBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), EcalTPGDBCopy::copyToDB(), EcalDBCopy::copyToDB(), ESDBCopy::copyToDB(), CocoaDBMgr::DumpCocoaResults(), PhysicsTools::MVATrainerSave::endJob(), PhysicsTools::MVATrainerContainerSave::endJob(), BeamSpotWrite2DB::endJob(), CentralityTableProducer::endJob(), StoreESCondition::endJob(), BeamProfile2DB::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), HLTPrescaleRecorder::endRun(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), and CaloGeometryDBWriter::writeIndexed().

                                                 {
         if( !firstPayloadObj ) throwException( "Provided payload pointer is invalid.","PoolDBOutputService::createNewIOV");
     std::lock_guard<std::recursive_mutex> lock(m_mutex);
     if (!m_dbstarted) this->initDB();
         createNewIOV( m_session.storePayload( *firstPayloadObj ),
               cond::demangledName(typeid(T)),
                       firstSinceTime,
                       firstTillTime,
                       recordName,
                       withlogging); 
       }

void PoolDBOutputService::createNewIOV	(	const std::string &	firstPayloadId,
		const std::string	payloadType,
		cond::Time_t	firstSinceTime,
		cond::Time_t	firstTillTime,
		const std::string &	recordName,
		bool	withlogging = `false`
	)

Definition at line 186 of file PoolDBOutputService.cc.

References a, cond::persistency::Session::createIov(), idDealer::editor, cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), lookUpRecord(), lookUpUserLogInfo(), m_mutex, m_session, cond::persistency::IOVEditor::setDescription(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::throwException(), cond::persistency::Session::transaction(), and cond::UserLogInfo::usertext.

                                                                    {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
 
   cond::persistency::TransactionScope scope( m_session.transaction() );
   Record& myrecord=this->lookUpRecord(recordName);
   if(!myrecord.m_isNewTag) {
     cond::throwException( myrecord.m_tag + " is not a new tag", "PoolDBOutputService::createNewIOV");
   }
   std::string iovToken;
 
   try{
     // FIX ME: synchronization type and description have to be passed as the other parameters?
     cond::persistency::IOVEditor editor = m_session.createIov( payloadType, myrecord.m_tag, myrecord.m_timetype, cond::SYNCH_ANY ); 
     editor.setDescription( "New Tag" );
     editor.insert( firstSinceTime, firstPayloadId );
     cond::UserLogInfo a=this->lookUpUserLogInfo(recordName);
     editor.flush( a.usertext );
     myrecord.m_isNewTag=false;
   }catch(const std::exception& er){ 
     cond::throwException(std::string(er.what()) + " from PoolDBOutputService::createNewIOV ",
              "PoolDBOutputService::createNewIOV");
   }
   scope.close();
 }

void PoolDBOutputService::createNewIOV	(	const std::string &	firstPayloadId,
		cond::Time_t	firstSinceTime,
		cond::Time_t	firstTillTime,
		const std::string &	recordName,
		bool	withlogging = `false`
	)

Definition at line 217 of file PoolDBOutputService.cc.

References a, cond::persistency::Session::createIovForPayload(), idDealer::editor, cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), lookUpRecord(), lookUpUserLogInfo(), m_mutex, m_session, SiPixelClusterizer_cfi::payloadType, cond::persistency::IOVEditor::payloadType(), cond::persistency::IOVEditor::setDescription(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::throwException(), cond::persistency::Session::transaction(), and cond::UserLogInfo::usertext.

                                                                    {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   cond::persistency::TransactionScope scope( m_session.transaction() );
   Record& myrecord=this->lookUpRecord(recordName);
   if(!myrecord.m_isNewTag) {
     cond::throwException( myrecord.m_tag + " is not a new tag", "PoolDBOutputService::createNewIOV");
   }
   std::string iovToken;
   std::string payloadType("");
   try{
     // FIX ME: synchronization type and description have to be passed as the other parameters?
     cond::persistency::IOVEditor editor = m_session.createIovForPayload( firstPayloadId, myrecord.m_tag, myrecord.m_timetype, cond::SYNCH_ANY ); 
     editor.setDescription( "New Tag" );
     payloadType = editor.payloadType();
     editor.insert( firstSinceTime, firstPayloadId );
     cond::UserLogInfo a=this->lookUpUserLogInfo(recordName);
     editor.flush( a.usertext );
     myrecord.m_isNewTag=false;
   }catch(const std::exception& er){ 
     cond::throwException(std::string(er.what()) + " from PoolDBOutputService::createNewIOV ",
            "PoolDBOutputService::createNewIOV");
   }
   scope.close();
 }

cond::Time_t PoolDBOutputService::currentTime ( ) const

Definition at line 180 of file PoolDBOutputService.cc.

References m_currentTimes, and s_streamIndex.

Referenced by SiStripBadChannelBuilder::algoAnalyze(), DBWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstantsMC::analyze(), BufferedBoostIODBWriter::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), FFTJetCorrectorDBWriter::analyze(), BoostIODBWriter< DataType >::analyze(), SiStripApvGainRescaler::analyze(), AlignPCLThresholdsWriter::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), JetResolutionDBWriter::beginJob(), SiStripFedCablingBuilder::beginRun(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), SurveyDBUploader::endJob(), CentralityTableProducer::endJob(), Mixing2DB::endJob(), SiStripFedCablingManipulator::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), popcon::L1RPCHwConfigSourceHandler::getNewObjects(), popcon::RPCEMapSourceHandler::getNewObjects(), MisalignedTrackerESProducer::produce(), MuonAlignment::saveCSCSurveyToDB(), MuonAlignment::saveCSCtoDB(), MuonAlignment::saveDTSurveyToDB(), MuonAlignment::saveDTtoDB(), TrackerAlignment::saveToDB(), ConditionDBWriter< SiStripApvGain >::setTime(), CaloGeometryDBWriter::write(), WriteESAlignments::write(), BeamFitter::write2DB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

                                                  {
   assert(-1 != s_streamIndex);
   return m_currentTimes[s_streamIndex];
 }

void cond::service::PoolDBOutputService::disconnect ( )

private

Referenced by Vispa.Views.LineDecayView.LineDecayView::createLineDecayContainer(), Vispa.Views.PropertyView.BooleanProperty::setChecked(), Vispa.Views.PropertyView.BooleanProperty::setReadOnly(), Vispa.Views.PropertyView.DropDownProperty::setReadOnly(), Vispa.Views.PropertyView.TextEditWithButtonProperty::setReadOnly(), Vispa.Views.PropertyView.IntegerProperty::setValue(), Vispa.Plugins.EdmBrowser.EdmBrowserTabController.EdmBrowserTabController::updateViewMenu(), and Vispa.Plugins.ConfigEditor.ConfigEditorTabController.ConfigEditorTabController::updateViewMenu().

cond::Time_t PoolDBOutputService::endOfTime ( ) const

Definition at line 170 of file PoolDBOutputService.cc.

References cond::TimeTypeSpecs::endValue, m_timetype, and cond::timeTypeSpecs.

Referenced by SiStripBadChannelBuilder::algoAnalyze(), EcalDQMStatusWriter::analyze(), DBWriter::analyze(), EcalPFRecHitThresholdsMaker::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), BTagCalibrationDbCreator::beginJob(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), QGLikelihoodSystematicsDBWriter::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), JetCorrectorDBWriter::beginJob(), XMLGeometryBuilder::beginJob(), QGLikelihoodDBWriter::beginJob(), SiStripFedCablingBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), GEMRecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), GeometricDetLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), RPCRecoIdealDBLoader::beginRun(), PGeometricDetExtraBuilder::beginRun(), PGeometricDetBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), EcalTPGDBCopy::copyToDB(), ESDBCopy::copyToDB(), EcalDBCopy::copyToDB(), CocoaDBMgr::DumpCocoaResults(), PhysicsTools::MVATrainerSave::endJob(), PhysicsTools::MVATrainerContainerSave::endJob(), BeamSpotWrite2DB::endJob(), CentralityTableProducer::endJob(), StoreESCondition::endJob(), BeamProfile2DB::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), HLTPrescaleRecorder::endRun(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), and CaloGeometryDBWriter::writeIndexed().

                                                {
   return timeTypeSpecs[m_timetype].endValue;
 }

void PoolDBOutputService::fillRecord ( edm::ParameterSet & pset )

private

Definition at line 22 of file PoolDBOutputService.cc.

References edm::ParameterSet::getParameter(), edm::ParameterSet::getUntrackedParameter(), m_callbacks, cond::service::PoolDBOutputService::Record::m_closeIOV, m_closeIOV, cond::service::PoolDBOutputService::Record::m_idName, m_logheaders, cond::service::PoolDBOutputService::Record::m_tag, cond::service::PoolDBOutputService::Record::m_timetype, m_timetypestr, AlCaHLTBitMon_QueryRunRegistry::string, and cond::time::timeTypeFromName().

Referenced by PoolDBOutputService().

                                                                   {
   Record thisrecord;
 
   thisrecord.m_idName = pset.getParameter<std::string>("record");
   thisrecord.m_tag = pset.getParameter<std::string>("tag");
   
   thisrecord.m_closeIOV =
     pset.getUntrackedParameter<bool>("closeIOV", m_closeIOV);
  
   thisrecord.m_timetype = cond::time::timeTypeFromName( pset.getUntrackedParameter< std::string >("timetype",m_timetypestr) );
 
   m_callbacks.insert(std::make_pair(thisrecord.m_idName,thisrecord));
 
   cond::UserLogInfo userloginfo;
   m_logheaders.insert(std::make_pair(thisrecord.m_idName,userloginfo));
 }

void PoolDBOutputService::forceInit ( )

Definition at line 164 of file PoolDBOutputService.cc.

References initDB(), CommonMethods::lock(), m_dbstarted, and m_mutex.

Referenced by l1t::DataWriterExt::readObject(), l1t::WriterProxyT< Record, Type >::save(), and l1t::DataWriterExt::writeKeyList().

                                               {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
     if (!m_dbstarted) initDB();  
 }

void PoolDBOutputService::initDB ( bool dummy = false )

private

Definition at line 104 of file PoolDBOutputService.cc.

References cond::persistency::Session::createDatabase(), cppFunctionSkipper::exception, cond::persistency::Session::existsDatabase(), CommonMethods::lock(), m_dbstarted, m_mutex, m_session, cond::persistency::TransactionScope::start(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by forceInit(), and lookUpRecord().

 {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   cond::persistency::TransactionScope scope( m_session.transaction() );
   scope.start( false );
   try{ 
     if( !m_session.existsDatabase() ) m_session.createDatabase();
 
   } catch( const std::exception& er ){
     cond::throwException( std::string(er.what()),"PoolDBOutputService::initDB" );
   }
   scope.close();
   m_dbstarted=true;
 }

bool PoolDBOutputService::isNewTagRequest ( const std::string & recordName )

Definition at line 98 of file PoolDBOutputService.cc.

References lookUpRecord(), and cond::service::PoolDBOutputService::Record::m_isNewTag.

Referenced by SiStripBadChannelBuilder::algoAnalyze(), DBWriter::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), BTagCalibrationDbCreator::beginJob(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), JetResolutionDBWriter::beginJob(), QGLikelihoodSystematicsDBWriter::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload_IOV::beginJob(), JetCorrectorDBWriter::beginJob(), XMLGeometryBuilder::beginJob(), QGLikelihoodDBWriter::beginJob(), HcalParametersDBBuilder::beginRun(), SiStripFedCablingBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), GEMRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), GeometricDetLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), RPCRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), PGeometricDetExtraBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), CentralityTableProducer::endJob(), StoreESCondition::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), AlcaBeamSpotHarvester::endRun(), HLTPrescaleRecorder::endRun(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

                                                                             {
   Record& myrecord=this->lookUpRecord(recordName);
   return myrecord.m_isNewTag; 
 }

cond::service::PoolDBOutputService::Record & PoolDBOutputService::lookUpRecord ( const std::string & recordName )

private

Definition at line 274 of file PoolDBOutputService.cc.

References cond::persistency::Session::existsIov(), initDB(), CommonMethods::lock(), m_callbacks, m_dbstarted, m_mutex, m_session, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by appendSinceTime(), closeIOV(), createNewIOV(), isNewTagRequest(), tag(), and tagInfo().

                                                                        {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   if (!m_dbstarted) this->initDB();
   cond::persistency::TransactionScope scope( m_session.transaction() );
   std::map<std::string,Record>::iterator it=m_callbacks.find(recordName);
   if(it==m_callbacks.end()) {
     cond::throwException("The record \""+recordName +"\" has not been registered.","PoolDBOutputService::lookUpRecord");
   }
   if( !m_session.existsIov( it->second.m_tag) ){
     it->second.m_isNewTag=true;
   } else {
     it->second.m_isNewTag=false;
   }
   scope.close();
   return it->second;
 }

cond::UserLogInfo & PoolDBOutputService::lookUpUserLogInfo ( const std::string & recordName )

private

Definition at line 292 of file PoolDBOutputService.cc.

References m_logheaders.

Referenced by appendSinceTime(), createNewIOV(), and setLogHeaderForRecord().

                                                                             {
   std::map<std::string,cond::UserLogInfo>::iterator it=m_logheaders.find(recordName);
   if(it==m_logheaders.end()) throw cond::Exception("Log db was not set for record " + recordName + " from PoolDBOutputService::lookUpUserLogInfo");
   return it->second;
 }

void PoolDBOutputService::postEndJob ( )

Definition at line 120 of file PoolDBOutputService.cc.

References cond::persistency::Transaction::commit(), m_dbstarted, m_session, and cond::persistency::Session::transaction().

Referenced by PoolDBOutputService().

 {
   if( m_dbstarted) {
     m_session.transaction().commit();
     m_dbstarted = false;
   }
 }

void PoolDBOutputService::postModuleEvent	(	edm::StreamContext const &	iContext,
		edm::ModuleCallingContext const &
	)

private

Definition at line 140 of file PoolDBOutputService.cc.

References s_streamIndex.

Referenced by PoolDBOutputService().

                                                                                                                 {
   s_streamIndex = -1;
 }

void PoolDBOutputService::preEventProcessing ( edm::StreamContext const & iContext )

private

Definition at line 129 of file PoolDBOutputService.cc.

References m_currentTimes, edm::StreamContext::streamID(), edm::StreamContext::timestamp(), edm::StreamID::value(), and edm::Timestamp::value().

Referenced by PoolDBOutputService().

 {
   m_currentTimes[iContext.streamID().value()] = iContext.timestamp().value();
 }

void PoolDBOutputService::preGlobalBeginLumi ( edm::GlobalContext const & iContext )

private

Definition at line 152 of file PoolDBOutputService.cc.

References edm::GlobalContext::luminosityBlockID(), m_currentTimes, ntuplemaker::time, and edm::LuminosityBlockID::value().

Referenced by PoolDBOutputService().

                                                                                    {
   for( auto& time : m_currentTimes) {
     time = iContext.luminosityBlockID().value();
   }
 }

void PoolDBOutputService::preGlobalBeginRun ( edm::GlobalContext const & iContext )

private

Definition at line 145 of file PoolDBOutputService.cc.

References edm::GlobalContext::luminosityBlockID(), m_currentTimes, edm::LuminosityBlockID::run(), and ntuplemaker::time.

Referenced by PoolDBOutputService().

                                                                                   {
   for( auto& time : m_currentTimes) {
     time = iContext.luminosityBlockID().run();
   }
 }

void PoolDBOutputService::preModuleEvent	(	edm::StreamContext const &	iContext,
		edm::ModuleCallingContext const &
	)

private

Definition at line 135 of file PoolDBOutputService.cc.

References s_streamIndex, edm::StreamContext::streamID(), and edm::StreamID::value().

Referenced by PoolDBOutputService().

                                                                                                                {
   s_streamIndex = iContext.streamID().value();
 }

cond::persistency::Session PoolDBOutputService::session ( ) const

Definition at line 88 of file PoolDBOutputService.cc.

References m_session, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by PCLMetadataWriter::endRun(), popcon::PopCon::initialize(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::readObject(), l1t::DataWriter::readObject(), l1t::WriterProxyT< Record, Type >::save(), l1t::DataWriterExt::writeKeyList(), l1t::DataWriter::writeKeyList(), and l1t::DataWriter::writePayload().

                                              {
   return m_session;
 }

void PoolDBOutputService::setLogHeaderForRecord	(	const std::string &	recordName,
		const std::string &	provenance,
		const std::string &	usertext
	)

Definition at line 318 of file PoolDBOutputService.cc.

References lookUpUserLogInfo(), cond::UserLogInfo::provenance, and cond::UserLogInfo::usertext.

Referenced by popcon::PopCon::write().

 {
   cond::UserLogInfo& myloginfo=this->lookUpUserLogInfo(recordName);
   myloginfo.provenance=dataprovenance;
   myloginfo.usertext=usertext;
 }

std::string PoolDBOutputService::tag ( const std::string & recordName )

Definition at line 93 of file PoolDBOutputService.cc.

References lookUpRecord(), and cond::service::PoolDBOutputService::Record::m_tag.

Referenced by PCLMetadataWriter::endRun(), popcon::PopCon::initialize(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::updateIOV(), and l1t::DataWriterExt::updateIOV().

                                                                 {
   return this->lookUpRecord(recordName).m_tag;
 }

void PoolDBOutputService::tagInfo	(	const std::string &	recordName,
		cond::TagInfo_t &	result
	)

Definition at line 327 of file PoolDBOutputService.cc.

References cond::persistency::IOVProxy::getLast(), plotBeamSpotDB::last, cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, CommonMethods::lock(), lookUpRecord(), m_mutex, m_session, cond::service::PoolDBOutputService::Record::m_tag, cond::TagInfo_t::name, cond::Iov_t::payloadId, cond::persistency::Session::readIov(), record, cond::persistency::IOVProxy::sequenceSize(), cond::Iov_t::since, cond::TagInfo_t::size, and cond::Iov_t::till.

Referenced by l1t::DataWriter::lastPayloadToken(), l1t::DataWriterExt::lastPayloadToken(), l1t::DataWriterExt::updateIOV(), and l1t::DataWriter::updateIOV().

                                                                                          {
   //
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   Record& record = lookUpRecord(recordName);
   result.name=record.m_tag;
   //use iovproxy to find out.
   cond::persistency::IOVProxy iov = m_session.readIov( record.m_tag );
   result.size=iov.sequenceSize();
   if (result.size>0) {
     cond::Iov_t last = iov.getLast();
     result.lastInterval = cond::ValidityInterval( last.since, last.till );
     result.lastPayloadToken = last.payloadId;
   }
 }

template<typename T >

void cond::service::PoolDBOutputService::writeOne	(	T *	payload,
		Time_t	time,
		const std::string &	recordName,
		bool	withlogging = `false`
	)

inline

Definition at line 54 of file PoolDBOutputService.h.

References CommonMethods::lock(), SiPixelClusterizer_cfi::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

Referenced by EcalDQMStatusWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), GBRForestWriter::analyze(), SurveyInputTrackerFromDB::analyze(), BufferedBoostIODBWriter::analyze(), TrackerSystematicMisalignments::analyze(), WriteCTPPSPixelAnalysisMask::analyze(), WriteCTPPSPixelDAQMapping::analyze(), BoostIODBWriter< DataType >::analyze(), FFTJetCorrectorDBWriter::analyze(), SiStripApvGainRescaler::analyze(), AlignPCLThresholdsWriter::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), TrackerGeometryCompare::analyze(), MCMisalignmentScaler::analyze(), JetResolutionDBWriter::beginJob(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), SiPixelStatusHarvester::constructTag(), EcalDBCopy::copyToDB(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), SurveyDBUploader::endJob(), Mixing2DB::endJob(), DTKeyedConfigDBInit::endJob(), SiStripLorentzAngleCalibration::endOfJob(), SiPixelLorentzAngleCalibration::endOfJob(), SiStripBackplaneCalibration::endOfJob(), AlcaBeamSpotHarvester::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), cond::BTransitionAnalyzer< EcalADCToGeVConstant, EcalADCToGeVConstantRcd >::endRun(), SiPixelStatusHarvester::endRunProduce(), CorrPCCProducer::endRunProduce(), LaserAlignment::endRunProduce(), MisalignedTrackerESProducer::produce(), MuonAlignment::saveCSCSurveyToDB(), MuonAlignment::saveCSCtoDB(), MuonAlignment::saveDTSurveyToDB(), MuonAlignment::saveDTtoDB(), TrackerAlignment::saveToDB(), MisalignedMuonESProducer::saveToDB(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), WriteESAlignments::write(), AlignmentProducerBase::writeDB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), popcon::PopCon::writeOne(), DTCalibDBUtils::writeToDB(), and CreateIdealTkAlRecords::writeToDB().

                                                                                                      {
         if( !payload ) throwException( "Provided payload pointer is invalid.","PoolDBOutputService::writeOne");
     std::lock_guard<std::recursive_mutex> lock(m_mutex);
     if (!m_dbstarted) this->initDB();
     Hash payloadId = m_session.storePayload( *payload );
     std::string payloadType = cond::demangledName(typeid(T));
     if (isNewTagRequest(recordName) ){
       createNewIOV(payloadId, payloadType, time, endOfTime(), recordName, withlogging);
         } else {
       appendSinceTime(payloadId, time, recordName, withlogging);
         }   
       }