#include <PoolDBOutputService.h>

Inheritance diagram for cond::service::PoolDBOutputService:

Classes
struct	Record

Public Member Functions
template<typename T >
void	appendOneIOV (const T &payload, cond::Time_t sinceTime, const std::string &recordName)

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

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

cond::Time_t	beginOfTime () const

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

void	commitTransaction ()

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

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

template<typename T >
void	createOneIOV (const T &payload, cond::Time_t firstSinceTime, 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)

void	lockRecords ()

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

void	releaseLocks ()

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 >
void	writeMany (const std::map< Time_t, std::shared_ptr< T > > &iovAndPayloads, const std::string &recordName)

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

template<typename T >
Hash	writeOneIOV (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	(	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);
   // 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 ( )

virtual

Definition at line 199 of file PoolDBOutputService.cc.

199 {}

Member Function Documentation

template<typename T >

void cond::service::PoolDBOutputService::appendOneIOV	(	const T &	payload,
		cond::Time_t	sinceTime,
		const std::string &	recordName
	)

inline

Definition at line 202 of file PoolDBOutputService.h.

References appendSinceTime(), 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 DBWriter::analyze(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelVCalDB::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalTestDevDB::analyze(), SiStripFedCablingBuilder::beginRun(), SiPixelGainCalibScaler::computeAndStorePalyoads(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamSpotOnlineRecordsWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), SiStripBadChannelBuilder::getNewObject(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), and CaloGeometryDBWriter::writeIndexed().

                                                                                              {
         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(payload), sinceTime, myrecord);
         } catch (const std::exception& er) {
           cond::throwException(std::string(er.what()), "PoolDBOutputService::appendSinceTime");
         }
         scope.close();
       }

template<typename T >

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

inline

Definition at line 221 of file PoolDBOutputService.h.

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

Referenced by appendOneIOV(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload_IOV::beginJob(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), and writeOneIOV().

                                                                                                    {
         if (!payloadPtr)
           throwException("Provided payload pointer is invalid.", "PoolDBOutputService::appendSinceTime");
         std::unique_ptr<const T> payload(payloadPtr);
         this->appendOneIOV<T>(*payload, sinceTime, recordName);
       }

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

Definition at line 265 of file PoolDBOutputService.cc.

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

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

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

private

Definition at line 286 of file PoolDBOutputService.cc.

References a, cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), cond::service::PoolDBOutputService::Record::m_idName, cond::service::PoolDBOutputService::Record::m_tag, AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::UserLogInfo::usertext.

                                                                            {
   m_logger.logInfo() << "Updating existing tag " << myrecord.m_tag << ", adding iov with since " << time;
   try {
     cond::persistency::IOVEditor editor = m_session.editIov(myrecord.m_tag);
     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;
 }

cond::Time_t PoolDBOutputService::beginOfTime ( ) const

Definition at line 215 of file PoolDBOutputService.cc.

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

Referenced by DBWriter::analyze(), L1KeyListWriter::analyze(), L1KeyWriter::analyze(), L1TMuonOverlapParamsWriter::analyze(), L1TCaloParamsUpdater::analyze(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), L1TCaloStage2ParamsWriter::analyze(), L1TGlobalPrescalesVetosWriter::analyze(), L1TMuonGlobalParamsWriter::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), L1MenuWriter::analyze(), L1TMuonEndCapForestWriter::analyze(), L1TMuonEndCapParamsWriter::analyze(), SiStripApvGainBuilder::analyze(), L1TMuonBarrelParamsWriter::analyze(), SurveyInputTrackerFromDB::analyze(), L1TMuonOverlapFwVersionTester::analyze(), EcalPFRecHitThresholdsMaker::analyze(), SiStripDetVOffFakeBuilder::analyze(), GBRForestWriter::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), PPSGeometryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), SiPixelTemplateDBObjectUploader::analyze(), EcalTestDevDB::analyze(), TrackerGeometryCompare::analyze(), TrackerSystematicMisalignments::analyze(), BTagCalibrationDbCreator::beginJob(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), JetResolutionDBWriter::beginJob(), JetCorrectorDBWriter::beginJob(), XMLGeometryBuilder::beginJob(), QGLikelihoodSystematicsDBWriter::beginJob(), QGLikelihoodDBWriter::beginJob(), PTrackerAdditionalParametersPerDetDBBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), RPCRecoIdealDBLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), PHGCalParametersDBBuilder::beginRun(), DTRecoIdealDBLoader::beginRun(), GEMRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), SiStripFedCablingBuilder::beginRun(), SiPixelGainCalibScaler::computeAndStorePalyoads(), ESDBCopy::copyToDB(), EcalTPGDBCopy::copyToDB(), EcalDBCopy::copyToDB(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamProfile2DB::endJob(), BeamSpotOnlineRecordsWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), LaserAlignment::endRunProduce(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), SiStripBadChannelBuilder::getNewObject(), EcalLaserCondTools::processIov(), MuonMisalignedProducer::saveToDB(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

215 { return timeTypeSpecs[m_timetype].beginValue; }

cond::timeTypeSpecs

const TimeTypeSpecs timeTypeSpecs[]

Definition: Time.cc:16

cond::TimeTypeSpecs::beginValue

Time_t beginValue

Definition: Time.h:41

cond::service::PoolDBOutputService::m_timetype

cond::TimeType m_timetype

Definition: PoolDBOutputService.h:314

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

Definition at line 344 of file PoolDBOutputService.cc.

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

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

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

void PoolDBOutputService::commitTransaction ( )

Definition at line 152 of file PoolDBOutputService.cc.

References CommonMethods::lock().

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

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

template<typename T >

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

inline

Definition at line 194 of file PoolDBOutputService.h.

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

Referenced by PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload_IOV::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), createOneIOV(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), and writeOneIOV().

                                                                                                                  {
         if (!payloadPtr)
           throwException("Provided payload pointer is invalid.", "PoolDBOutputService::createNewIOV");
         std::unique_ptr<const T> payload(payloadPtr);
         this->createOneIOV<T>(*payload, firstSinceTime, recordName);
       }

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

Definition at line 222 of file PoolDBOutputService.cc.

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, cond::persistency::IOVEditor::setDescription(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::throwException(), and cond::UserLogInfo::usertext.

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

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

private

Definition at line 249 of file PoolDBOutputService.cc.

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, cond::persistency::IOVEditor::setDescription(), cond::SYNCH_ANY, and cond::UserLogInfo::usertext.

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

template<typename T >

void cond::service::PoolDBOutputService::createOneIOV	(	const T &	payload,
		cond::Time_t	firstSinceTime,
		const std::string &	recordName
	)

inline

Definition at line 174 of file PoolDBOutputService.h.

References createNewIOV(), 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(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripApvGainBuilder::analyze(), EcalPFRecHitThresholdsMaker::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalTestDevDB::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), XMLGeometryBuilder::beginJob(), PTrackerAdditionalParametersPerDetDBBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), ME0RecoIdealDBLoader::beginRun(), PHGCalParametersDBBuilder::beginRun(), RPCRecoIdealDBLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), GEMRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), SiStripFedCablingBuilder::beginRun(), SiPixelGainCalibScaler::computeAndStorePalyoads(), ESDBCopy::copyToDB(), EcalTPGDBCopy::copyToDB(), EcalDBCopy::copyToDB(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamProfile2DB::endJob(), BeamSpotOnlineRecordsWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), SiStripBadChannelBuilder::getNewObject(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), and CaloGeometryDBWriter::writeIndexed().

                                                                                                   {
         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(payload);
           createNewIOV(payloadId, cond::demangledName(typeid(payload)), firstSinceTime, myrecord);
         } catch (const std::exception& er) {
           cond::throwException(std::string(er.what()), "PoolDBOutputService::createNewIov");
         }
         scope.close();
       }

cond::Time_t PoolDBOutputService::currentTime ( ) const

Definition at line 217 of file PoolDBOutputService.cc.

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

Referenced by DBWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripNoisesBuilder::analyze(), L1MuonOverlapPhase1ParamsDBProducer::analyze(), SiStripApvGainBuilder::analyze(), WritePPSAlignmentConfig::analyze(), WritePPSAlignmentConfiguration::analyze(), WritePPSAssociationCuts::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), BufferedBoostIODBWriter::analyze(), SiPixelDynamicInefficiencyDB::analyze(), PPSTimingCalibrationWriter::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), SiPixelTemplateDBObjectUploader::analyze(), EcalSCDynamicDPhiParametersMaker::analyze(), EcalMustacheSCParametersMaker::analyze(), AlignPCLThresholdsWriter::analyze(), FFTJetCorrectorDBWriter::analyze(), BoostIODBWriter< DataType >::analyze(), JetResolutionDBWriter::beginJob(), SiStripFedCablingBuilder::beginRun(), PPSDiamondSampicTimingCalibrationPCLHarvester::calibDb(), SiPixelGainCalibScaler::computeAndStorePalyoads(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), PPSTimingCalibrationPCLHarvester::dqmEndJob(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), SiPixelLorentzAnglePCLHarvester::dqmEndJob(), PPSAlignmentHarvester::dqmEndRun(), CocoaDBMgr::DumpCocoaResults(), SurveyDBUploader::endJob(), BeamSpotWrite2DB::endJob(), CentralityTableProducer::endJob(), Mixing2DB::endJob(), BeamSpotOnlineRecordsWriter::endJob(), SiStripFedCablingManipulator::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), WriteCTPPSPixGainCalibrations::fillDB(), SiStripBadChannelBuilder::getNewObject(), popcon::L1RPCHwConfigSourceHandler::getNewObjects(), popcon::RPCEMapSourceHandler::getNewObjects(), MisalignedTrackerESProducer::produce(), MuonAlignment::saveCSCSurveyToDB(), MuonAlignment::saveCSCtoDB(), MuonAlignment::saveDTSurveyToDB(), MuonAlignment::saveDTtoDB(), MuonAlignment::saveGEMtoDB(), 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 PoolDBOutputService::doCommitTransaction ( )

private

Definition at line 140 of file PoolDBOutputService.cc.

Referenced by writeMany(), and writeOneIOV().

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

void PoolDBOutputService::doStartTransaction ( )

private

Definition at line 133 of file PoolDBOutputService.cc.

Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().

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

cond::Time_t PoolDBOutputService::endOfTime ( ) const

Definition at line 213 of file PoolDBOutputService.cc.

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

Referenced by EcalDQMStatusWriter::analyze(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), and CocoaDBMgr::DumpCocoaResults().

213 { return timeTypeSpecs[m_timetype].endValue; }

cond::timeTypeSpecs

const TimeTypeSpecs timeTypeSpecs[]

Definition: Time.cc:16

cond::service::PoolDBOutputService::m_timetype

cond::TimeType m_timetype

Definition: PoolDBOutputService.h:314

cond::TimeTypeSpecs::endValue

Time_t endValue

Definition: Time.h:42

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

Definition at line 301 of file PoolDBOutputService.cc.

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, AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::UserLogInfo::usertext.

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

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

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

private

Definition at line 20 of file PoolDBOutputService.cc.

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().

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

void PoolDBOutputService::forceInit ( )

Definition at line 201 of file PoolDBOutputService.cc.

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().

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

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

private

Definition at line 373 of file PoolDBOutputService.cc.

References cppFunctionSkipper::exception, cond::persistency::IOVProxy::getLast(), cond::TagInfo_t::lastInterval, cond::service::PoolDBOutputService::Record::m_tag, cond::TagInfo_t::name, GlobalPosition_Frontier_DevDB_cff::record, runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().

Referenced by writeMany(), and writeOneIOV().

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

void PoolDBOutputService::initDB ( )

private

Definition at line 157 of file PoolDBOutputService.cc.

Referenced by createOneIOV(), writeMany(), and writeOneIOV().

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

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

Definition at line 128 of file PoolDBOutputService.cc.

References cond::service::PoolDBOutputService::Record::m_isNewTag.

Referenced by DBWriter::analyze(), SiStripThresholdBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelVCalDB::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixelTemplateDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalTestDevDB::analyze(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload_IOV::beginJob(), JetResolutionDBWriter::beginJob(), XMLGeometryBuilder::beginJob(), PTrackerAdditionalParametersPerDetDBBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), ME0RecoIdealDBLoader::beginRun(), RPCRecoIdealDBLoader::beginRun(), PHGCalParametersDBBuilder::beginRun(), CSCRecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), GEMRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), SiStripFedCablingBuilder::beginRun(), SiPixelGainCalibScaler::computeAndStorePalyoads(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamSpotOnlineRecordsWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), AlcaBeamSpotHarvester::endRun(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), SiStripBadChannelBuilder::getNewObject(), EcalLaserCondTools::processIov(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), writeMany(), writeOneIOV(), and DTCalibDBUtils::writeToDB().

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

void PoolDBOutputService::lockRecords ( )

Definition at line 94 of file PoolDBOutputService.cc.

References CommonMethods::lock(), and cond::persistency::IOVEditor::lock().

Referenced by BeamMonitor::dqmBeginRun(), and FakeBeamMonitor::dqmBeginRun().

                                                  {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   doStartTransaction();
   cond::persistency::TransactionScope scope(m_session.transaction());
   this->initDB();
   for (auto& iR : m_records) {
     if (iR.second.m_isNewTag == false) {
       cond::persistency::IOVEditor editor = m_session.editIov(iR.second.m_tag);
       editor.lock();
     }
   }
   doCommitTransaction();
   scope.close();
 }

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

inline

Definition at line 263 of file PoolDBOutputService.h.

References m_logger.

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

263 { return m_logger; }

cond::service::PoolDBOutputService::m_logger

cond::persistency::Logger m_logger

Definition: PoolDBOutputService.h:312

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

private

Definition at line 326 of file PoolDBOutputService.cc.

References cond::throwException().

Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().

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

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

private

Definition at line 336 of file PoolDBOutputService.cc.

Referenced by writeMany().

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

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

Definition at line 85 of file PoolDBOutputService.cc.

References runTheMatrix::ret.

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

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

void PoolDBOutputService::postEndJob ( )

Definition at line 171 of file PoolDBOutputService.cc.

171 { commitTransaction(); }

cond::service::PoolDBOutputService::commitTransaction

void commitTransaction()

Definition: PoolDBOutputService.cc:152

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

private

Definition at line 182 of file PoolDBOutputService.cc.

References s_streamIndex.

                                                                                          {
   s_streamIndex = -1;
 }

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

private

Definition at line 173 of file PoolDBOutputService.cc.

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

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

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

private

Definition at line 193 of file PoolDBOutputService.cc.

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

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

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

private

Definition at line 187 of file PoolDBOutputService.cc.

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

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

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

private

Definition at line 177 of file PoolDBOutputService.cc.

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

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

void PoolDBOutputService::releaseLocks ( )

Definition at line 109 of file PoolDBOutputService.cc.

References CommonMethods::lock(), and cond::persistency::IOVEditor::unlock().

Referenced by BeamMonitor::dqmEndRun(), and FakeBeamMonitor::dqmEndRun().

                                                   {
   std::lock_guard<std::recursive_mutex> lock(m_mutex);
   doStartTransaction();
   cond::persistency::TransactionScope scope(m_session.transaction());
   this->initDB();
   for (auto& iR : m_records) {
     if (iR.second.m_isNewTag == false) {
       cond::persistency::IOVEditor editor = m_session.editIov(iR.second.m_tag);
       editor.unlock();
     }
   }
   doCommitTransaction();
   scope.close();
 }

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

Definition at line 92 of file PoolDBOutputService.cc.

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().

92 { return m_session; }

cond::service::PoolDBOutputService::m_session

cond::persistency::Session m_session

Definition: PoolDBOutputService.h:318

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

Definition at line 364 of file PoolDBOutputService.cc.

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

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

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

void PoolDBOutputService::startTransaction ( )

Definition at line 147 of file PoolDBOutputService.cc.

References CommonMethods::lock().

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

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

Definition at line 124 of file PoolDBOutputService.cc.

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

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

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

Definition at line 395 of file PoolDBOutputService.cc.

References CommonMethods::lock().

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

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

template<typename T >

void cond::service::PoolDBOutputService::writeMany	(	const std::map< Time_t, std::shared_ptr< T > > &	iovAndPayloads,
		const std::string &	recordName
	)

inline

Definition at line 118 of file PoolDBOutputService.h.

References a, cond::persistency::Session::createIov(), doCommitTransaction(), doStartTransaction(), cond::persistency::Session::editIov(), cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), getTagInfo(), initDB(), cond::persistency::IOVEditor::insert(), isNewTagRequest(), cond::TagInfo_t::lastInterval, CommonMethods::lock(), cond::persistency::Logger::logInfo(), lookUpRecord(), lookUpUserLogInfo(), 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, cond::service::PoolDBOutputService::Record::m_timetype, cond::time::MAX_VAL(), jetCorrFactors_cfi::payload, HLT_FULL_cff::payloadType, cond::persistency::IOVEditor::setDescription(), cond::Iov_t::since, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::throwException(), cond::persistency::Session::transaction(), and cond::UserLogInfo::usertext.

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

                                                                                                            {
         if (iovAndPayloads.empty())
           return;
         std::lock_guard<std::recursive_mutex> lock(m_mutex);
         doStartTransaction();
         cond::persistency::TransactionScope scope(m_session.transaction());
         try {
           this->initDB();
           Record& myrecord = this->lookUpRecord(recordName);
           m_logger.logInfo() << "Tag mapped to record " << recordName << ": " << myrecord.m_tag;
           bool newTag = isNewTagRequest(recordName);
           cond::Time_t lastSince;
           cond::persistency::IOVEditor editor;
           if (newTag) {
             std::string payloadType = cond::demangledName(typeid(T));
             editor = m_session.createIov(payloadType, myrecord.m_tag, myrecord.m_timetype, cond::SYNCH_ANY);
             editor.setDescription("New Tag");
           } else {
             editor = m_session.editIov(myrecord.m_tag);
             if (myrecord.m_onlyAppendUpdatePolicy) {
               cond::TagInfo_t tInfo;
               this->getTagInfo(myrecord.m_idName, tInfo);
               lastSince = tInfo.lastInterval.since;
               if (lastSince == cond::time::MAX_VAL)
                 lastSince = 0;
             }
           }
           for (auto& iovEntry : iovAndPayloads) {
             Time_t time = iovEntry.first;
             auto payload = iovEntry.second;
             if (myrecord.m_onlyAppendUpdatePolicy && !newTag) {
               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;
                 continue;
               }
             }
             auto payloadHash = m_session.storePayload(*payload);
             editor.insert(time, payloadHash);
           }
           cond::UserLogInfo a = this->lookUpUserLogInfo(myrecord.m_idName);
           editor.flush(a.usertext);
           if (m_autoCommit) {
             doCommitTransaction();
           }
         } catch (const std::exception& er) {
           cond::throwException(std::string(er.what()), "PoolDBOutputService::writeMany");
         }
         scope.close();
         return;
       }

template<typename T >

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

inline

Definition at line 110 of file PoolDBOutputService.h.

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

Referenced by PPSGeometryBuilder::analyze(), WriteCTPPSPixGainCalibrations::fillDB(), and DTCalibDBUtils::writeToDB().

                                                                                    {
         if (!payloadPtr)
           throwException("Provided payload pointer is invalid.", "PoolDBOutputService::writeOne");
         std::unique_ptr<const T> payload(payloadPtr);
         return writeOneIOV<T>(*payload, time, recordName);
       }

template<typename T >

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

inline

Definition at line 62 of file PoolDBOutputService.h.

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(), HLT_FULL_cff::payloadType, cond::Iov_t::since, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by EcalDQMStatusWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), L1MuonOverlapPhase1ParamsDBProducer::analyze(), SurveyInputTrackerFromDB::analyze(), WritePPSAlignmentConfig::analyze(), L1TMuonOverlapFwVersionTester::analyze(), WritePPSAlignmentConfiguration::analyze(), WritePPSAssociationCuts::analyze(), GBRForestWriter::analyze(), PPSTimingCalibrationWriter::analyze(), BufferedBoostIODBWriter::analyze(), ProduceDropBoxMetadata::analyze(), CTPPSRPAlignmentInfoAnalyzer::analyze(), WriteCTPPSPixelAnalysisMask::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), WriteCTPPSPixelDAQMapping::analyze(), SiPixelTemplateDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), WriteCTPPSBeamParameters::analyze(), EcalMustacheSCParametersMaker::analyze(), EcalSCDynamicDPhiParametersMaker::analyze(), FFTJetCorrectorDBWriter::analyze(), BoostIODBWriter< DataType >::analyze(), SiStripApvGainRescaler::analyze(), TrackerSystematicMisalignments::analyze(), TrackerGeometryCompare::analyze(), MCMisalignmentScaler::analyze(), BTagCalibrationDbCreator::beginJob(), JetResolutionDBWriter::beginJob(), JetCorrectorDBWriter::beginJob(), QGLikelihoodSystematicsDBWriter::beginJob(), QGLikelihoodDBWriter::beginJob(), DTCCablingMapTestProducer::beginJob(), PPSDiamondSampicTimingCalibrationPCLHarvester::calibDb(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), SiPixelStatusHarvester::constructTag(), EcalDBCopy::copyToDB(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), PPSTimingCalibrationPCLHarvester::dqmEndJob(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), SiPixelLorentzAnglePCLHarvester::dqmEndJob(), SiPixelStatusHarvester::dqmEndRun(), PPSAlignmentHarvester::dqmEndRun(), CorrPCCProducer::dqmEndRunProduce(), SurveyDBUploader::endJob(), CentralityTableProducer::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(), HLTPrescaleRecorder::endRun(), LaserAlignment::endRunProduce(), EcalLaserCondTools::from_hdf_to_db(), EcalLaserCondTools::processIov(), MisalignedTrackerESProducer::produce(), MuonAlignment::saveCSCSurveyToDB(), MuonAlignment::saveCSCtoDB(), MuonAlignment::saveDTSurveyToDB(), MuonAlignment::saveDTtoDB(), MuonAlignment::saveGEMtoDB(), TrackerAlignment::saveToDB(), MuonMisalignedProducer::saveToDB(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), WriteESAlignments::write(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), AlignmentProducerBase::writeDB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), and CreateIdealTkAlRecords::writeToDB().

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

Member Data Documentation

bool cond::service::PoolDBOutputService::m_autoCommit

private

Definition at line 320 of file PoolDBOutputService.h.

Referenced by writeMany(), and writeOneIOV().

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

private

Definition at line 317 of file PoolDBOutputService.h.

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

private

Definition at line 315 of file PoolDBOutputService.h.

bool cond::service::PoolDBOutputService::m_dbInitialised

private

Definition at line 322 of file PoolDBOutputService.h.

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

private

Definition at line 312 of file PoolDBOutputService.h.

Referenced by logger(), writeMany(), and writeOneIOV().

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

private

Definition at line 325 of file PoolDBOutputService.h.

Referenced by fillRecord().

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

private

Definition at line 313 of file PoolDBOutputService.h.

Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().

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

private

Definition at line 324 of file PoolDBOutputService.h.

Referenced by fillRecord().

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

private

Definition at line 318 of file PoolDBOutputService.h.

Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().

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

private

Definition at line 314 of file PoolDBOutputService.h.

bool cond::service::PoolDBOutputService::m_transactionActive

private

Definition at line 319 of file PoolDBOutputService.h.

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

private

Definition at line 321 of file PoolDBOutputService.h.

Referenced by writeOneIOV().

Classes

Public Member Functions

Private Member Functions

Private Attributes

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation