#include <PoolDBOutputService.h>

Inheritance diagram for cond::service::PoolDBOutputService:

Classes
struct	Record

Public Member Functions
bool	appendSinceTime (const std::string &payloadId, cond::Time_t sinceTime, const std::string &recordName)

template<typename T >
void	appendSinceTime (const T *payloadObj, cond::Time_t sinceTime, const std::string &recordName)

cond::Time_t	beginOfTime () const

void	closeIOV (Time_t lastTill, const std::string &recordName)

void	commitTransaction ()

void	createNewIOV (const std::string &firstPayloadId, cond::Time_t firstSinceTime, const std::string &recordName)

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

cond::Time_t	currentTime () const

cond::Time_t	endOfTime () const

void	eraseSinceTime (const std::string &payloadId, cond::Time_t sinceTime, const std::string &recordName)

void	forceInit ()

bool	isNewTagRequest (const std::string &recordName)

cond::persistency::Logger &	logger ()

cond::persistency::Session	newReadOnlySession (const std::string &connectionString, const std::string &transactionId)

	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)

void	startTransaction ()

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

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

template<typename T >
Hash	writeOne (const T *payload, Time_t time, const std::string &recordName)

virtual	~PoolDBOutputService ()

Private Member Functions
bool	appendSinceTime (const std::string &payloadId, cond::Time_t sinceTime, Record &record)

void	createNewIOV (const std::string &firstPayloadId, const std::string payloadType, cond::Time_t firstSinceTime, Record &record)

void	doCommitTransaction ()

void	doStartTransaction ()

void	fillRecord (edm::ParameterSet &pset, const std::string &gTimeTypeStr)

bool	getTagInfo (const std::string &recordName, cond::TagInfo_t &result)

void	initDB ()

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
bool	m_autoCommit

cond::persistency::ConnectionPool	m_connection

std::vector< cond::Time_t >	m_currentTimes

bool	m_dbInitialised

cond::persistency::Logger	m_logger

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

std::recursive_mutex	m_mutex

std::map< std::string, Record >	m_records

cond::persistency::Session	m_session

cond::TimeType	m_timetype

bool	m_transactionActive

unsigned int	m_writeTransactionDelay = 0

Detailed Description

Definition at line 33 of file PoolDBOutputService.h.

Constructor & Destructor Documentation

◆ PoolDBOutputService()

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

Definition at line 37 of file PoolDBOutputService.cc.

     : m_logger(iConfig.getUntrackedParameter<std::string>("jobName", "DBOutputService")),
       m_currentTimes{},
       m_session(),
       m_transactionActive(false),
       m_dbInitialised(false),
       m_records(),
       m_logheaders() {
   std::string timetypestr = iConfig.getUntrackedParameter<std::string>("timetype", "runnumber");
   m_timetype = cond::time::timeTypeFromName(timetypestr);
   m_autoCommit = iConfig.getUntrackedParameter<bool>("autoCommit", false);
   m_writeTransactionDelay = iConfig.getUntrackedParameter<unsigned int>("writeTransactionDelay", 0);
  
   edm::ParameterSet connectionPset = iConfig.getParameter<edm::ParameterSet>("DBParameters");
   m_connection.setParameters(connectionPset);
   m_connection.setLogDestination(m_logger);
   m_connection.configure();
   std::string connectionString = iConfig.getParameter<std::string>("connect");
   m_session = m_connection.createSession(connectionString, true);
   bool saveLogsOnDb = iConfig.getUntrackedParameter<bool>("saveLogsOnDB", false);
   if (saveLogsOnDb)
     m_logger.setDbDestination(connectionString, m_connection);
   // implicit start
   doStartTransaction();
  
   typedef std::vector<edm::ParameterSet> Parameters;
   Parameters toPut = iConfig.getParameter<Parameters>("toPut");
   for (Parameters::iterator itToPut = toPut.begin(); itToPut != toPut.end(); ++itToPut)
     fillRecord(*itToPut, timetypestr);
  
   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::~PoolDBOutputService ( )

virtual

Definition at line 171 of file PoolDBOutputService.cc.

171 {}

Member Function Documentation

◆ appendSinceTime() [1/3]

bool PoolDBOutputService::appendSinceTime	(	const std::string &	payloadId,
		cond::Time_t	sinceTime,
		const std::string &	recordName
	)

Definition at line 237 of file PoolDBOutputService.cc.

                                                                                       {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   Record& myrecord = this->lookUpRecord(recordName);
   if (myrecord.m_isNewTag) {
     cond::throwException(std::string("Cannot append to non-existing tag ") + myrecord.m_tag,
                          "PoolDBOutputService::appendSinceTime");
   }
   bool ret = false;
   doStartTransaction();
   cond::persistency::TransactionScope scope(m_session.transaction());
   try {
     ret = appendSinceTime(payloadId, time, myrecord);
   } catch (const std::exception& er) {
     cond::throwException(std::string(er.what()), "PoolDBOutputService::appendSinceTime");
   }
   scope.close();
   return ret;
 }

References cppFunctionSkipper::exception, CommonMethods::lock(), cond::service::PoolDBOutputService::Record::m_isNewTag, cond::service::PoolDBOutputService::Record::m_tag, align_cfg::recordName, runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and ntuplemaker::time.

◆ appendSinceTime() [2/3]

bool PoolDBOutputService::appendSinceTime	(	const std::string &	payloadId,
		cond::Time_t	sinceTime,
		Record &	record
	)

private

Definition at line 258 of file PoolDBOutputService.cc.

                                                                            {
   m_logger.logInfo() << "Updating existing tag " << myrecord.m_tag << ", adding iov with since " << time;
   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(myrecord.m_idName);
     editor.flush(a.usertext);
   } catch (const std::exception& er) {
     cond::throwException(std::string(er.what()), "PoolDBOutputService::appendSinceTime");
   }
   return true;
 }

References a, cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), cond::service::PoolDBOutputService::Record::m_idName, cond::service::PoolDBOutputService::Record::m_tag, cond::persistency::IOVEditor::payloadType(), HLT_2018_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and ntuplemaker::time.

◆ appendSinceTime() [3/3]

template<typename T >

void cond::service::PoolDBOutputService::appendSinceTime	(	const T *	payloadObj,
		cond::Time_t	sinceTime,
		const std::string &	recordName
	)

inline

Definition at line 135 of file PoolDBOutputService.h.

                                                                                                    {
         if (!payloadObj)
           throwException("Provided payload pointer is invalid.", "PoolDBOutputService::appendSinceTime");
         std::lock_guard<std::recursive_mutex> lock(m_mutex);
         Record& myrecord = this->lookUpRecord(recordName);
         if (myrecord.m_isNewTag) {
           cond::throwException(std::string("Cannot append to non-existing tag ") + myrecord.m_tag,
                                "PoolDBOutputService::appendSinceTime");
         }
         doStartTransaction();
         cond::persistency::TransactionScope scope(m_session.transaction());
         try {
           appendSinceTime(m_session.storePayload(*payloadObj), sinceTime, myrecord);
         } catch (const std::exception& er) {
           cond::throwException(std::string(er.what()), "PoolDBOutputService::appendSinceTime");
         }
         scope.close();
       }

References doStartTransaction(), cppFunctionSkipper::exception, CommonMethods::lock(), lookUpRecord(), cond::service::PoolDBOutputService::Record::m_isNewTag, m_mutex, m_session, cond::service::PoolDBOutputService::Record::m_tag, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), SiStripFedCablingBuilder::beginRun(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamSpotOnlineHLTRcdWriter::endJob(), BeamSpotOnlineLegacyRcdWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), HLTPrescaleRecorder::endRun(), SiStripBadChannelBuilder::getNewObject(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), CaloGeometryDBWriter::writeIndexed(), and writeOne().

◆ beginOfTime()

cond::Time_t PoolDBOutputService::beginOfTime ( ) const

Definition at line 187 of file PoolDBOutputService.cc.

187 { return timeTypeSpecs[m_timetype].beginValue; }

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

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), L1TMuonOverlapParamsWriter::analyze(), L1KeyListWriter::analyze(), L1KeyWriter::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripNoisesBuilder::analyze(), L1TCaloParamsUpdater::analyze(), SiStripApvGainBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), L1TMuonGlobalParamsWriter::analyze(), EcalPFRecHitThresholdsMaker::analyze(), L1TCaloStage2ParamsWriter::analyze(), L1TGlobalPrescalesVetosWriter::analyze(), L1TMuonBarrelParamsWriter::analyze(), L1TMuonEndCapParamsWriter::analyze(), L1MenuWriter::analyze(), L1TMuonEndCapForestWriter::analyze(), SurveyInputTrackerFromDB::analyze(), GBRForestWriter::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), TrackerSystematicMisalignments::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), PPSGeometryBuilder::analyze(), TrackerGeometryCompare::analyze(), XMLGeometryBuilder::beginJob(), SiStripFedCablingBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), GEMRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), GeometricTimingDetLoader::beginRun(), GeometricDetLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), PGeometricDetExtraBuilder::beginRun(), RPCRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), EcalTPGDBCopy::copyToDB(), EcalDBCopy::copyToDB(), ESDBCopy::copyToDB(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamProfile2DB::endJob(), BeamSpotOnlineLegacyRcdWriter::endJob(), BeamSpotOnlineHLTRcdWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), HLTPrescaleRecorder::endRun(), LaserAlignment::endRunProduce(), SiStripBadChannelBuilder::getNewObject(), EcalLaserCondTools::processIov(), MisalignedMuonESProducer::saveToDB(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

◆ closeIOV()

void PoolDBOutputService::closeIOV	(	Time_t	lastTill,
		const std::string &	recordName
	)

Definition at line 318 of file PoolDBOutputService.cc.

                                                                                           {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   Record& myrecord = lookUpRecord(recordName);
   if (myrecord.m_isNewTag) {
     cond::throwException(std::string("Cannot close non-existing tag ") + myrecord.m_tag,
                          "PoolDBOutputService::closeIOV");
   }
   m_logger.logInfo() << "Updating existing tag " << myrecord.m_tag << ", closing with end of validity " << lastTill;
   doStartTransaction();
   cond::persistency::TransactionScope scope(m_session.transaction());
   try {
     cond::persistency::IOVEditor editor = m_session.editIov(myrecord.m_tag);
     editor.setEndOfValidity(lastTill);
     editor.flush("Tag closed.");
   } catch (const std::exception& er) {
     cond::throwException(std::string(er.what()), "PoolDBOutputService::closeIOV");
   }
   scope.close();
 }

References cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), CommonMethods::lock(), cond::service::PoolDBOutputService::Record::m_isNewTag, cond::service::PoolDBOutputService::Record::m_tag, align_cfg::recordName, cond::persistency::IOVEditor::setEndOfValidity(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

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

◆ commitTransaction()

void PoolDBOutputService::commitTransaction ( )

Definition at line 124 of file PoolDBOutputService.cc.

                                                        {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   doCommitTransaction();
 }

References CommonMethods::lock().

Referenced by cond::service::OnlineDBOutputService::writeForNextLumisection().

◆ createNewIOV() [1/3]

void PoolDBOutputService::createNewIOV	(	const std::string &	firstPayloadId,
		cond::Time_t	firstSinceTime,
		const std::string &	recordName
	)

Definition at line 194 of file PoolDBOutputService.cc.

                                                                                    {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   Record& myrecord = this->lookUpRecord(recordName);
   if (!myrecord.m_isNewTag) {
     cond::throwException(myrecord.m_tag + " is not a new tag", "PoolDBOutputService::createNewIOV");
   }
   m_logger.logInfo() << "Creating new tag " << myrecord.m_tag << ", adding iov with since " << firstSinceTime
                      << " pointing to payload id " << firstPayloadId;
   doStartTransaction();
   cond::persistency::TransactionScope scope(m_session.transaction());
   try {
     this->initDB();
     cond::persistency::IOVEditor editor =
         m_session.createIovForPayload(firstPayloadId, myrecord.m_tag, myrecord.m_timetype, cond::SYNCH_ANY);
     editor.setDescription("New Tag");
     editor.insert(firstSinceTime, firstPayloadId);
     cond::UserLogInfo a = this->lookUpUserLogInfo(myrecord.m_idName);
     editor.flush(a.usertext);
     myrecord.m_isNewTag = false;
   } catch (const std::exception& er) {
     cond::throwException(std::string(er.what()), "PoolDBOutputService::createNewIov");
   }
   scope.close();
 }

References a, cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), cond::service::PoolDBOutputService::Record::m_idName, cond::service::PoolDBOutputService::Record::m_isNewTag, cond::service::PoolDBOutputService::Record::m_tag, cond::service::PoolDBOutputService::Record::m_timetype, align_cfg::recordName, cond::persistency::IOVEditor::setDescription(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, and cond::throwException().

◆ createNewIOV() [2/3]

void PoolDBOutputService::createNewIOV	(	const std::string &	firstPayloadId,
		const std::string	payloadType,
		cond::Time_t	firstSinceTime,
		Record &	record
	)

private

Definition at line 221 of file PoolDBOutputService.cc.

                                                                         {
   m_logger.logInfo() << "Creating new tag " << myrecord.m_tag << " for payload type " << payloadType
                      << ", adding iov with since " << firstSinceTime;
   // 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(myrecord.m_idName);
   editor.flush(a.usertext);
   myrecord.m_isNewTag = false;
 }

References a, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), cond::service::PoolDBOutputService::Record::m_idName, cond::service::PoolDBOutputService::Record::m_isNewTag, cond::service::PoolDBOutputService::Record::m_tag, cond::service::PoolDBOutputService::Record::m_timetype, HLT_2018_cff::payloadType, cond::persistency::IOVEditor::setDescription(), and cond::SYNCH_ANY.

◆ createNewIOV() [3/3]

template<typename T >

void cond::service::PoolDBOutputService::createNewIOV	(	const T *	firstPayloadObj,
		cond::Time_t	firstSinceTime,
		cond::Time_t	,
		const std::string &	recordName
	)

inline

Definition at line 110 of file PoolDBOutputService.h.

                                                      {
         if (!firstPayloadObj)
           throwException("Provided payload pointer is invalid.", "PoolDBOutputService::createNewIOV");
         std::lock_guard<std::recursive_mutex> lock(m_mutex);
         Record& myrecord = this->lookUpRecord(recordName);
         if (!myrecord.m_isNewTag) {
           cond::throwException(myrecord.m_tag + " is not a new tag", "PoolDBOutputService::createNewIOV");
         }
         doStartTransaction();
         cond::persistency::TransactionScope scope(m_session.transaction());
         try {
           this->initDB();
           Hash payloadId = m_session.storePayload(*firstPayloadObj);
           createNewIOV(payloadId, cond::demangledName(typeid(T)), firstSinceTime, myrecord);
         } catch (const std::exception& er) {
           cond::throwException(std::string(er.what()), "PoolDBOutputService::createNewIov");
         }
         scope.close();
       }

References doStartTransaction(), cppFunctionSkipper::exception, initDB(), CommonMethods::lock(), lookUpRecord(), cond::service::PoolDBOutputService::Record::m_isNewTag, m_mutex, m_session, cond::service::PoolDBOutputService::Record::m_tag, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripNoisesBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), EcalPFRecHitThresholdsMaker::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), XMLGeometryBuilder::beginJob(), SiStripFedCablingBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), GEMRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), GeometricTimingDetLoader::beginRun(), GeometricDetLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), PGeometricDetExtraBuilder::beginRun(), RPCRecoIdealDBLoader::beginRun(), HcalParametersDBBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), ESDBCopy::copyToDB(), EcalTPGDBCopy::copyToDB(), EcalDBCopy::copyToDB(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), BeamProfile2DB::endJob(), StoreESCondition::endJob(), BeamSpotOnlineHLTRcdWriter::endJob(), BeamSpotOnlineLegacyRcdWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), HLTPrescaleRecorder::endRun(), SiStripBadChannelBuilder::getNewObject(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), CaloGeometryDBWriter::writeIndexed(), and writeOne().

◆ currentTime()

cond::Time_t PoolDBOutputService::currentTime ( ) const

Definition at line 189 of file PoolDBOutputService.cc.

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

References cms::cuda::assert(), and s_streamIndex.

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripNoisesBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), L1MuonOverlapParamsDBProducer::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), BufferedBoostIODBWriter::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), AlignPCLThresholdsWriter::analyze(), FFTJetCorrectorDBWriter::analyze(), BoostIODBWriter< DataType >::analyze(), SiStripApvGainRescaler::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripFedCablingBuilder::beginRun(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), SurveyDBUploader::endJob(), Mixing2DB::endJob(), BeamSpotOnlineHLTRcdWriter::endJob(), BeamSpotOnlineLegacyRcdWriter::endJob(), SiStripFedCablingManipulator::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), WriteCTPPSPixGainCalibrations::fillDB(), SiStripBadChannelBuilder::getNewObject(), 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().

◆ doCommitTransaction()

void PoolDBOutputService::doCommitTransaction ( )

private

Definition at line 112 of file PoolDBOutputService.cc.

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

Referenced by writeOne().

◆ doStartTransaction()

void PoolDBOutputService::doStartTransaction ( )

private

Definition at line 105 of file PoolDBOutputService.cc.

                                                         {
   if (!m_transactionActive) {
     m_session.transaction().start(false);
     m_transactionActive = true;
   }
 }

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

◆ endOfTime()

cond::Time_t PoolDBOutputService::endOfTime ( ) const

Definition at line 185 of file PoolDBOutputService.cc.

185 { return timeTypeSpecs[m_timetype].endValue; }

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

◆ eraseSinceTime()

void PoolDBOutputService::eraseSinceTime	(	const std::string &	payloadId,
		cond::Time_t	sinceTime,
		const std::string &	recordName
	)

Definition at line 275 of file PoolDBOutputService.cc.

                                                                                      {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   Record& myrecord = this->lookUpRecord(recordName);
   if (myrecord.m_isNewTag) {
     cond::throwException(std::string("Cannot delete from non-existing tag ") + myrecord.m_tag,
                          "PoolDBOutputService::appendSinceTime");
   }
   m_logger.logInfo() << "Updating existing tag " << myrecord.m_tag << ", removing iov with since " << sinceTime
                      << " pointing to payload id " << payloadId;
   doStartTransaction();
   cond::persistency::TransactionScope scope(m_session.transaction());
   try {
     cond::persistency::IOVEditor editor = m_session.editIov(myrecord.m_tag);
     editor.erase(sinceTime, payloadId);
     cond::UserLogInfo a = this->lookUpUserLogInfo(recordName);
     editor.flush(a.usertext);
  
   } catch (const std::exception& er) {
     cond::throwException(std::string(er.what()), "PoolDBOutputService::eraseSinceTime");
   }
   scope.close();
 }

References a, cond::persistency::IOVEditor::erase(), cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), CommonMethods::lock(), cond::service::PoolDBOutputService::Record::m_isNewTag, cond::service::PoolDBOutputService::Record::m_tag, align_cfg::recordName, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

Referenced by cond::service::OnlineDBOutputService::writeForNextLumisection().

◆ fillRecord()

void PoolDBOutputService::fillRecord	(	edm::ParameterSet &	pset,
		const std::string &	gTimeTypeStr
	)

private

Definition at line 20 of file PoolDBOutputService.cc.

                                                                                                           {
   Record thisrecord;
  
   thisrecord.m_idName = recordPset.getParameter<std::string>("record");
   thisrecord.m_tag = recordPset.getParameter<std::string>("tag");
  
   thisrecord.m_timetype =
       cond::time::timeTypeFromName(recordPset.getUntrackedParameter<std::string>("timetype", gTimeTypeStr));
  
   thisrecord.m_onlyAppendUpdatePolicy = recordPset.getUntrackedParameter<bool>("onlyAppendUpdatePolicy", false);
  
   m_records.insert(std::make_pair(thisrecord.m_idName, thisrecord));
  
   cond::UserLogInfo userloginfo;
   m_logheaders.insert(std::make_pair(thisrecord.m_idName, userloginfo));
 }

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

◆ forceInit()

void PoolDBOutputService::forceInit ( )

Definition at line 173 of file PoolDBOutputService.cc.

                                                {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   doStartTransaction();
   cond::persistency::TransactionScope scope(m_session.transaction());
   try {
     initDB();
   } catch (const std::exception& er) {
     cond::throwException(std::string(er.what()), "PoolDBOutputService::forceInit");
   }
   scope.close();
 }

References cppFunctionSkipper::exception, CommonMethods::lock(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

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

◆ getTagInfo()

bool PoolDBOutputService::getTagInfo	(	const std::string &	recordName,
		cond::TagInfo_t &	result
	)

private

Definition at line 347 of file PoolDBOutputService.cc.

                                                                                                   {
   Record& record = lookUpRecord(recordName);
   result.name = record.m_tag;
   m_logger.logDebug() << "Fetching tag info for " << record.m_tag;
   doStartTransaction();
   bool ret = false;
   cond::persistency::TransactionScope scope(m_session.transaction());
   try {
     //use iovproxy to find out.
     if (m_session.existsIov(record.m_tag)) {
       cond::persistency::IOVProxy iov = m_session.readIov(record.m_tag);
       result.lastInterval = iov.getLast();
       ret = true;
     }
   } catch (const std::exception& er) {
     cond::throwException(std::string(er.what()), "PoolDBOutputService::tagInfo");
   }
   scope.close();
   return ret;
 }

References cppFunctionSkipper::exception, cond::persistency::IOVProxy::getLast(), GlobalPosition_Frontier_DevDB_cff::record, align_cfg::recordName, mps_fire::result, runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

Referenced by writeOne().

◆ initDB()

void PoolDBOutputService::initDB ( )

private

Definition at line 129 of file PoolDBOutputService.cc.

                                             {
   if (!m_dbInitialised) {
     if (!m_session.existsDatabase())
       m_session.createDatabase();
     else {
       for (auto& iR : m_records) {
         if (m_session.existsIov(iR.second.m_tag))
           iR.second.m_isNewTag = false;
       }
     }
     m_dbInitialised = true;
   }
 }

Referenced by createNewIOV(), and writeOne().

◆ isNewTagRequest()

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

Definition at line 100 of file PoolDBOutputService.cc.

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

References cond::service::PoolDBOutputService::Record::m_isNewTag, and align_cfg::recordName.

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripNoisesBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), XMLGeometryBuilder::beginJob(), SiStripFedCablingBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), GEMRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), GeometricTimingDetLoader::beginRun(), GeometricDetLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), PGeometricDetExtraBuilder::beginRun(), RPCRecoIdealDBLoader::beginRun(), HcalParametersDBBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamSpotOnlineHLTRcdWriter::endJob(), BeamSpotOnlineLegacyRcdWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), AlcaBeamSpotHarvester::endRun(), HLTPrescaleRecorder::endRun(), SiStripBadChannelBuilder::getNewObject(), EcalLaserCondTools::processIov(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), CaloGeometryDBWriter::writeIndexed(), writeOne(), and DTCalibDBUtils::writeToDB().

◆ logger()

cond::persistency::Logger& cond::service::PoolDBOutputService::logger ( )

inline

Definition at line 189 of file PoolDBOutputService.h.

189 { return m_logger; }

References m_logger.

Referenced by BeamMonitor::beginLuminosityBlock(), FakeBeamMonitor::beginLuminosityBlock(), BeamMonitor::endLuminosityBlock(), FakeBeamMonitor::endLuminosityBlock(), BeamMonitor::FitAndFill(), FakeBeamMonitor::FitAndFill(), and cond::service::OnlineDBOutputService::writeForNextLumisection().

◆ lookUpRecord()

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

private

Definition at line 300 of file PoolDBOutputService.cc.

                                  {
   std::map<std::string, Record>::iterator it = m_records.find(recordName);
   if (it == m_records.end()) {
     cond::throwException("The record \"" + recordName + "\" has not been registered.",
                          "PoolDBOutputService::lookUpRecord");
   }
   return it->second;
 }

References align_cfg::recordName, and cond::throwException().

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

◆ lookUpUserLogInfo()

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

private

Definition at line 310 of file PoolDBOutputService.cc.

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

References align_cfg::recordName.

◆ newReadOnlySession()

cond::persistency::Session PoolDBOutputService::newReadOnlySession	(	const std::string &	connectionString,
		const std::string &	transactionId
	)

Definition at line 87 of file PoolDBOutputService.cc.

                                                                                                                   {
   cond::persistency::Session ret;
   ret = m_connection.createReadOnlySession(connectionString, transactionId);
   return ret;
 }

References l1RCTOmdsFedVectorProducer_cfi::connectionString, and runTheMatrix::ret.

Referenced by cond::service::OnlineDBOutputService::getReadOnlyCache().

◆ postEndJob()

void PoolDBOutputService::postEndJob ( )

Definition at line 143 of file PoolDBOutputService.cc.

143 { commitTransaction(); }

◆ postModuleEvent()

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

private

Definition at line 154 of file PoolDBOutputService.cc.

                                                                                          {
   s_streamIndex = -1;
 }

References s_streamIndex.

◆ preEventProcessing()

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

private

Definition at line 145 of file PoolDBOutputService.cc.

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

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

◆ preGlobalBeginLumi()

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

private

Definition at line 165 of file PoolDBOutputService.cc.

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

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

◆ preGlobalBeginRun()

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

private

Definition at line 159 of file PoolDBOutputService.cc.

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

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

◆ preModuleEvent()

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

private

Definition at line 149 of file PoolDBOutputService.cc.

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

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

◆ session()

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

Definition at line 94 of file PoolDBOutputService.cc.

94 { return m_session; }

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

◆ setLogHeaderForRecord()

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

Definition at line 338 of file PoolDBOutputService.cc.

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

References cond::UserLogInfo::provenance, align_cfg::recordName, and cond::UserLogInfo::usertext.

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

◆ startTransaction()

void PoolDBOutputService::startTransaction ( )

Definition at line 119 of file PoolDBOutputService.cc.

                                                       {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   doStartTransaction();
 }

References CommonMethods::lock().

Referenced by cond::service::OnlineDBOutputService::OnlineDBOutputService().

◆ tag()

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

Definition at line 96 of file PoolDBOutputService.cc.

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

References align_cfg::recordName.

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

◆ tagInfo()

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

Definition at line 369 of file PoolDBOutputService.cc.

                                                                                                {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   return getTagInfo(recordName, result);
 }

References CommonMethods::lock(), align_cfg::recordName, and mps_fire::result.

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

◆ writeOne()

template<typename T >

Hash cond::service::PoolDBOutputService::writeOne	(	const T *	payload,
		Time_t	time,
		const std::string &	recordName
	)

inline

Definition at line 57 of file PoolDBOutputService.h.

                                                                                 {
         if (!payload)
           throwException("Provided payload pointer is invalid.", "PoolDBOutputService::writeOne");
         std::lock_guard<std::recursive_mutex> lock(m_mutex);
         doStartTransaction();
         cond::persistency::TransactionScope scope(m_session.transaction());
         Hash thePayloadHash("");
         try {
           this->initDB();
           Record& myrecord = this->lookUpRecord(recordName);
           m_logger.logInfo() << "Tag mapped to record " << recordName << ": " << myrecord.m_tag;
           bool newTag = isNewTagRequest(recordName);
           if (myrecord.m_onlyAppendUpdatePolicy && !newTag) {
             cond::TagInfo_t tInfo;
             this->getTagInfo(myrecord.m_idName, tInfo);
             cond::Time_t lastSince = tInfo.lastInterval.since;
             if (lastSince == cond::time::MAX_VAL)
               lastSince = 0;
             if (time <= lastSince) {
               m_logger.logInfo() << "Won't append iov with since " << std::to_string(time)
                                  << ", because is less or equal to last available since = " << lastSince;
               if (m_autoCommit)
                 doCommitTransaction();
               scope.close();
               return thePayloadHash;
             }
           }
           thePayloadHash = m_session.storePayload(*payload);
           std::string payloadType = cond::demangledName(typeid(T));
           if (newTag) {
             createNewIOV(thePayloadHash, payloadType, time, myrecord);
           } else {
             appendSinceTime(thePayloadHash, time, myrecord);
           }
           if (m_autoCommit) {
             if (m_writeTransactionDelay) {
               m_logger.logWarning() << "Waiting " << m_writeTransactionDelay << "s before commit the changes...";
               ::sleep(m_writeTransactionDelay);
             }
             doCommitTransaction();
           }
         } catch (const std::exception& er) {
           cond::throwException(std::string(er.what()), "PoolDBOutputService::writeOne");
         }
         scope.close();
         return thePayloadHash;
       }

References appendSinceTime(), createNewIOV(), doCommitTransaction(), doStartTransaction(), cppFunctionSkipper::exception, getTagInfo(), initDB(), isNewTagRequest(), cond::TagInfo_t::lastInterval, CommonMethods::lock(), cond::persistency::Logger::logInfo(), cond::persistency::Logger::logWarning(), lookUpRecord(), m_autoCommit, cond::service::PoolDBOutputService::Record::m_idName, m_logger, m_mutex, cond::service::PoolDBOutputService::Record::m_onlyAppendUpdatePolicy, m_session, cond::service::PoolDBOutputService::Record::m_tag, m_writeTransactionDelay, cond::time::MAX_VAL(), jets_cff::payload, HLT_2018_cff::payloadType, align_cfg::recordName, cond::Iov_t::since, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), ntuplemaker::time, and cond::persistency::Session::transaction().

Referenced by EcalDQMStatusWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), L1TCaloParamsUpdater::analyze(), SurveyInputTrackerFromDB::analyze(), GBRForestWriter::analyze(), BufferedBoostIODBWriter::analyze(), TrackerSystematicMisalignments::analyze(), WriteCTPPSBeamParameters::analyze(), CTPPSRPAlignmentInfoAnalyzer::analyze(), WriteCTPPSPixelAnalysisMask::analyze(), WriteCTPPSPixelDAQMapping::analyze(), AlignPCLThresholdsWriter::analyze(), BoostIODBWriter< DataType >::analyze(), PPSGeometryBuilder::analyze(), FFTJetCorrectorDBWriter::analyze(), SiStripApvGainRescaler::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), TrackerGeometryCompare::analyze(), MCMisalignmentScaler::analyze(), DTCCablingMapTestProducer::beginJob(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), SiPixelStatusHarvester::constructTag(), EcalDBCopy::copyToDB(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), SiPixelStatusHarvester::dqmEndRun(), CorrPCCProducer::dqmEndRunProduce(), SurveyDBUploader::endJob(), Mixing2DB::endJob(), DTKeyedConfigDBInit::endJob(), DTCCablingMapProducer::endJob(), SiStripLorentzAngleCalibration::endOfJob(), SiPixelLorentzAngleCalibration::endOfJob(), SiStripBackplaneCalibration::endOfJob(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), AlcaBeamSpotHarvester::endRun(), cond::BTransitionAnalyzer< EcalADCToGeVConstant, EcalADCToGeVConstantRcd >::endRun(), LaserAlignment::endRunProduce(), WriteCTPPSPixGainCalibrations::fillDB(), EcalLaserCondTools::processIov(), 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().

Member Data Documentation

◆ m_autoCommit

bool cond::service::PoolDBOutputService::m_autoCommit

private

Definition at line 246 of file PoolDBOutputService.h.

Referenced by writeOne().

◆ m_connection

cond::persistency::ConnectionPool cond::service::PoolDBOutputService::m_connection

private

Definition at line 243 of file PoolDBOutputService.h.

◆ m_currentTimes

std::vector<cond::Time_t> cond::service::PoolDBOutputService::m_currentTimes

private

Definition at line 241 of file PoolDBOutputService.h.

◆ m_dbInitialised

bool cond::service::PoolDBOutputService::m_dbInitialised

private

Definition at line 248 of file PoolDBOutputService.h.

◆ m_logger

cond::persistency::Logger cond::service::PoolDBOutputService::m_logger

private

Definition at line 238 of file PoolDBOutputService.h.

Referenced by logger(), and writeOne().

◆ m_logheaders

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

private

Definition at line 251 of file PoolDBOutputService.h.

Referenced by fillRecord().

◆ m_mutex

std::recursive_mutex cond::service::PoolDBOutputService::m_mutex

private

Definition at line 239 of file PoolDBOutputService.h.

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

◆ m_records

std::map<std::string, Record> cond::service::PoolDBOutputService::m_records

private

Definition at line 250 of file PoolDBOutputService.h.

Referenced by fillRecord().

◆ m_session

cond::persistency::Session cond::service::PoolDBOutputService::m_session

private

Definition at line 244 of file PoolDBOutputService.h.

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

◆ m_timetype

cond::TimeType cond::service::PoolDBOutputService::m_timetype

private

Definition at line 240 of file PoolDBOutputService.h.

◆ m_transactionActive

bool cond::service::PoolDBOutputService::m_transactionActive

private

Definition at line 245 of file PoolDBOutputService.h.

◆ m_writeTransactionDelay

unsigned int cond::service::PoolDBOutputService::m_writeTransactionDelay = 0

private

Definition at line 247 of file PoolDBOutputService.h.

Referenced by writeOne().

Classes

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

◆ PoolDBOutputService()

◆ ~PoolDBOutputService()

Member Function Documentation

◆ appendSinceTime() [1/3]

◆ appendSinceTime() [2/3]

◆ appendSinceTime() [3/3]

◆ beginOfTime()

◆ closeIOV()

◆ commitTransaction()

◆ createNewIOV() [1/3]

◆ createNewIOV() [2/3]

◆ createNewIOV() [3/3]

◆ currentTime()

◆ doCommitTransaction()

◆ doStartTransaction()

◆ endOfTime()

◆ eraseSinceTime()

◆ fillRecord()

◆ forceInit()

◆ getTagInfo()

◆ initDB()

◆ isNewTagRequest()

◆ logger()

◆ lookUpRecord()

◆ lookUpUserLogInfo()

◆ newReadOnlySession()

◆ postEndJob()

◆ postModuleEvent()

◆ preEventProcessing()

◆ preGlobalBeginLumi()

◆ preGlobalBeginRun()

◆ preModuleEvent()

◆ session()

◆ setLogHeaderForRecord()

◆ startTransaction()

◆ tag()

◆ tagInfo()

◆ writeOne()

Member Data Documentation

◆ m_autoCommit

◆ m_connection

◆ m_currentTimes

◆ m_dbInitialised

◆ m_logger

◆ m_logheaders

◆ m_mutex

◆ m_records

◆ m_session

◆ m_timetype

◆ m_transactionActive

◆ m_writeTransactionDelay