#include <PoolDBOutputService.h>
Classes | |
struct | Record |
Public Member Functions | |
template<typename T > | |
void | appendOneIOV (const T &payload, 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 () |
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 () |
const Record & | lookUpRecord (const std::string &recordName) |
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 | writeOneIOV (const T &payload, Time_t time, const std::string &recordName) |
virtual | ~PoolDBOutputService () |
Static Public Attributes | |
static const std::string | kSharedResource = "PoolDBOutputService" |
Private Member Functions | |
bool | appendSinceTime (const std::string &payloadId, cond::Time_t sinceTime, const 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) |
Record & | getRecord (const std::string &recordName) |
bool | getTagInfo (const std::string &recordName, cond::TagInfo_t &result) |
bool | initDB (bool readOnly=false) |
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 |
Definition at line 33 of file PoolDBOutputService.h.
PoolDBOutputService::PoolDBOutputService | ( | const edm::ParameterSet & | iConfig, |
edm::ActivityRegistry & | iAR | ||
) |
Definition at line 41 of file PoolDBOutputService.cc.
|
virtual |
Definition at line 241 of file PoolDBOutputService.cc.
|
inline |
Definition at line 185 of file PoolDBOutputService.h.
References appendSinceTime(), doCommitTransaction(), doStartTransaction(), cppFunctionSkipper::exception, initDB(), CommonMethods::lock(), lookUpRecord(), m_autoCommit, m_mutex, m_session, jetsAK4_Puppi_cff::payload, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().
Referenced by DBWriter::analyze(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiStripNoisesAndBadCompsChecker::analyze(), SiPixelLorentzAngleDBLoader::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), BeamSpotOnlineFromOfflineConverter::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripApvGainFromFileBuilder::analyze(), SiStripFedCablingBuilder::beginRun(), SiPixelGainCalibScaler::computeAndStorePalyoads(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), StoreESCondition::endJob(), BeamSpotOnlineRecordsWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), SiStripBadChannelBuilder::getNewObject(), SiPhase2BadStripChannelBuilder::getNewObject(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), and BeamSpotOnlineShifter::writeToDB().
bool PoolDBOutputService::appendSinceTime | ( | const std::string & | payloadId, |
cond::Time_t | sinceTime, | ||
const std::string & | recordName | ||
) |
Definition at line 314 of file PoolDBOutputService.cc.
References cppFunctionSkipper::exception, CommonMethods::lock(), align_cfg::recordName, runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and hcalRecHitTable_cff::time.
Referenced by appendOneIOV(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), and writeOneIOV().
|
private |
Definition at line 343 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 hcalRecHitTable_cff::time.
cond::Time_t PoolDBOutputService::beginOfTime | ( | ) | const |
Definition at line 260 of file PoolDBOutputService.cc.
References cond::TimeTypeSpecs::beginValue, and cond::timeTypeSpecs.
Referenced by L1KeyListWriter::analyze(), L1KeyWriter::analyze(), L1TMuonOverlapParamsWriter::analyze(), L1TCaloParamsUpdater::analyze(), L1MenuWriter::analyze(), DBWriter::analyze(), SiStripThresholdBuilder::analyze(), L1TCaloStage2ParamsWriter::analyze(), SurveyInputTrackerFromDB::analyze(), SiStripPedestalsBuilder::analyze(), L1TGlobalPrescalesVetosWriter::analyze(), L1TMuonEndCapForestWriter::analyze(), L1TMuonGlobalParamsWriter::analyze(), SiStripSummaryBuilder::analyze(), SiStripNoisesBuilder::analyze(), L1TMuonEndCapParamsWriter::analyze(), SiStripApvGainBuilder::analyze(), L1TMuonBarrelParamsWriter::analyze(), L1TMuonOverlapFwVersionTester::analyze(), EcalPFRecHitThresholdsMaker::analyze(), SiStripDetVOffFakeBuilder::analyze(), GBRForestWriter::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDBLoader::analyze(), SiStripNoisesAndBadCompsChecker::analyze(), PPSGeometryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), SiPixelTemplateDBObjectUploader::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), TrackerGeometryCompare::analyze(), TrackerSystematicMisalignments::analyze(), BeamSpotOnlineFromOfflineConverter::analyze(), SiStripApvGainFromFileBuilder::analyze(), XMLGeometryBuilder::beginJob(), PTrackerParametersDBBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), ME0RecoIdealDBLoader::beginRun(), RPCRecoIdealDBLoader::beginRun(), PHGCalParametersDBBuilder::beginRun(), CSCRecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), GEMRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), SiStripFedCablingBuilder::beginRun(), SiPixelGainCalibScaler::computeAndStorePalyoads(), ESDBCopy::copyToDB(), EcalTPGDBCopy::copyToDB(), EcalDBCopy::copyToDB(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), BeamProfile2DBWriter::endJob(), StoreESCondition::endJob(), BeamSpotOnlineRecordsWriter::endJob(), StoreEcalCondition::endJob(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), SiStripFedCablingManipulator::endRun(), LaserAlignment::endRunProduce(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), SiStripBadChannelBuilder::getNewObject(), SiPhase2BadStripChannelBuilder::getNewObject(), EcalLaserCondTools::processIov(), MuonMisalignedProducer::saveToDB(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), DTCalibDBUtils::writeToDB(), and BeamSpotOnlineShifter::writeToDB().
void PoolDBOutputService::closeIOV | ( | Time_t | lastTill, |
const std::string & | recordName | ||
) |
Definition at line 407 of file PoolDBOutputService.cc.
References cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), CommonMethods::lock(), align_cfg::recordName, cond::persistency::IOVEditor::setEndOfValidity(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().
Referenced by popcon::PopCon::finalize().
void PoolDBOutputService::commitTransaction | ( | ) |
Definition at line 180 of file PoolDBOutputService.cc.
References CommonMethods::lock().
Referenced by popcon::PopCon::finalize(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), and cond::service::OnlineDBOutputService::writeIOVForNextLumisection().
void PoolDBOutputService::createNewIOV | ( | const std::string & | firstPayloadId, |
cond::Time_t | firstSinceTime, | ||
const std::string & | recordName | ||
) |
Definition at line 267 of file PoolDBOutputService.cc.
References a, cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), align_cfg::recordName, cond::persistency::IOVEditor::setDescription(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, and cond::throwException().
Referenced by createOneIOV(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), and writeOneIOV().
|
private |
Definition at line 298 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, HLT_2024v10_cff::payloadType, cond::persistency::IOVEditor::setDescription(), and cond::SYNCH_ANY.
|
inline |
Definition at line 163 of file PoolDBOutputService.h.
References createNewIOV(), doCommitTransaction(), doStartTransaction(), cppFunctionSkipper::exception, getRecord(), initDB(), CommonMethods::lock(), m_autoCommit, m_mutex, m_session, jetsAK4_Puppi_cff::payload, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().
Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripThresholdBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), EcalPFRecHitThresholdsMaker::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDBLoader::analyze(), SiStripNoisesAndBadCompsChecker::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), BeamSpotOnlineFromOfflineConverter::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripApvGainFromFileBuilder::analyze(), XMLGeometryBuilder::beginJob(), PTrackerParametersDBBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), CSCRecoIdealDBLoader::beginRun(), PHGCalParametersDBBuilder::beginRun(), ME0RecoIdealDBLoader::beginRun(), RPCRecoIdealDBLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), GEMRecoIdealDBLoader::beginRun(), PGeometricDetBuilder::beginRun(), SiStripFedCablingBuilder::beginRun(), SiPixelGainCalibScaler::computeAndStorePalyoads(), ESDBCopy::copyToDB(), EcalTPGDBCopy::copyToDB(), EcalDBCopy::copyToDB(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), BeamProfile2DBWriter::endJob(), StoreESCondition::endJob(), BeamSpotOnlineRecordsWriter::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), SiStripBadChannelBuilder::getNewObject(), SiPhase2BadStripChannelBuilder::getNewObject(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), and BeamSpotOnlineShifter::writeToDB().
cond::Time_t PoolDBOutputService::currentTime | ( | ) | const |
Definition at line 262 of file PoolDBOutputService.cc.
References cms::cuda::assert(), and s_streamIndex.
Referenced by L1MuonOverlapParamsDBProducer::analyze(), L1MuonOverlapPhase1ParamsDBProducer::analyze(), LHCInfoPerFillWriter::analyze(), LHCInfoPerLSWriter::analyze(), DBWriter::analyze(), SiStripThresholdBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), WritePPSAlignmentConfiguration::analyze(), WritePPSAssociationCuts::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiStripNoisesAndBadCompsChecker::analyze(), SiPixelLorentzAngleDBLoader::analyze(), SiPixelVCalDB::analyze(), SiPixelLorentzAngleDB::analyze(), PPSTimingCalibrationLUTWriter::analyze(), PPSTimingCalibrationWriter::analyze(), BufferedBoostIODBWriter::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixelTemplateDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalSCDynamicDPhiParametersMaker::analyze(), EcalMustacheSCParametersMaker::analyze(), SiStripBadChannelPatcher::analyze(), BoostIODBWriter< DataType >::analyze(), FFTJetCorrectorDBWriter::analyze(), cms::SiPixelCondObjBuilder::analyze(), SiStripApvGainRescaler::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), SiPhase2OuterTrackerLorentzAngleWriter::analyze(), SiStripGainPayloadCopyAndExclude::analyze(), BeamSpotOnlineFromOfflineConverter::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripApvGainFromFileBuilder::analyze(), SiStripFedCablingBuilder::beginRun(), PPSDiamondSampicTimingCalibrationPCLHarvester::calibDb(), SiPixelGainCalibScaler::computeAndStorePalyoads(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), PPSTimingCalibrationPCLHarvester::dqmEndJob(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripLorentzAnglePCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), SiPixelLorentzAnglePCLHarvester::dqmEndJob(), SiPixelLorentzAnglePCLHarvesterMCS::dqmEndJob(), PPSAlignmentHarvester::dqmEndRun(), CocoaDBMgr::DumpCocoaResults(), SurveyDBUploader::endJob(), BeamSpotWrite2DB::endJob(), SiPixelQualityProbabilitiesTestWriter::endJob(), Mixing2DB::endJob(), SiPixelQualityProbabilitiesWriteFromASCII::endJob(), SiPixelFEDChannelContainerWriteFromASCII::endJob(), SiPixelFEDChannelContainerFromQualityConverter::endJob(), BeamSpotOnlineRecordsWriter::endJob(), FastSiPixelFEDChannelContainerFromQuality::endJob(), SiStripApvGainInspector::endJob(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), SiStripFedCablingManipulator::endRun(), SiPixelGainCalibrationReadDQMFile::fillDatabase(), SiPixelGainCalibrationRejectNoisyAndDead::fillDatabase(), WriteCTPPSPixGainCalibrations::fillDB(), SiStripBadChannelBuilder::getNewObject(), SiPhase2BadStripChannelBuilder::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(), SiStripHitEfficiencyHarvester::writeBadStripPayload(), GlobalTrackerMuonAlignment::writeGlPosRcd(), CaloGeometryDBWriter::writeIndexed(), AlignPCLThresholdsWriter< T >::writePayload(), DTCalibDBUtils::writeToDB(), and BeamSpotOnlineShifter::writeToDB().
|
private |
Definition at line 164 of file PoolDBOutputService.cc.
Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().
|
private |
Definition at line 157 of file PoolDBOutputService.cc.
Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().
cond::Time_t PoolDBOutputService::endOfTime | ( | ) | const |
Definition at line 258 of file PoolDBOutputService.cc.
References cond::TimeTypeSpecs::endValue, and cond::timeTypeSpecs.
Referenced by EcalDQMStatusWriter::analyze(), and CocoaDBMgr::DumpCocoaResults().
void PoolDBOutputService::eraseSinceTime | ( | const std::string & | payloadId, |
cond::Time_t | sinceTime, | ||
const std::string & | recordName | ||
) |
Definition at line 358 of file PoolDBOutputService.cc.
References a, cond::persistency::IOVEditor::erase(), cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), CommonMethods::lock(), align_cfg::recordName, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().
Referenced by cond::service::OnlineDBOutputService::writeIOVForNextLumisection().
|
private |
Definition at line 22 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_refreshTime, cond::service::PoolDBOutputService::Record::m_tag, cond::service::PoolDBOutputService::Record::m_timetype, AlCaHLTBitMon_QueryRunRegistry::string, and cond::time::timeTypeFromName().
void PoolDBOutputService::forceInit | ( | ) |
Definition at line 243 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(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), and l1t::DataWriterExt::writeKeyList().
|
private |
Definition at line 203 of file PoolDBOutputService.cc.
References ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, align_cfg::recordName, and cond::throwException().
Referenced by createOneIOV(), writeMany(), and writeOneIOV().
|
private |
Definition at line 443 of file PoolDBOutputService.cc.
References cond::persistency::IOVProxy::getLast(), AlCaHarvesting_cff::record, align_cfg::recordName, mps_fire::result, and runTheMatrix::ret.
Referenced by writeMany(), and writeOneIOV().
|
private |
Definition at line 185 of file PoolDBOutputService.cc.
Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().
bool PoolDBOutputService::isNewTagRequest | ( | const std::string & | recordName | ) |
Definition at line 136 of file PoolDBOutputService.cc.
References cppFunctionSkipper::exception, CommonMethods::lock(), align_cfg::recordName, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().
Referenced by DBWriter::analyze(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripApvGainBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDBLoader::analyze(), SiStripNoisesAndBadCompsChecker::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), SiPixelTemplateDBObjectUploader::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), BeamSpotOnlineFromOfflineConverter::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripApvGainFromFileBuilder::analyze(), XMLGeometryBuilder::beginJob(), PTrackerParametersDBBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), CSCRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), PHGCalParametersDBBuilder::beginRun(), RPCRecoIdealDBLoader::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(), SiPhase2BadStripChannelBuilder::getNewObject(), EcalLaserCondTools::processIov(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), writeMany(), writeOneIOV(), DTCalibDBUtils::writeToDB(), and BeamSpotOnlineShifter::writeToDB().
void PoolDBOutputService::lockRecords | ( | ) |
Definition at line 98 of file PoolDBOutputService.cc.
References CommonMethods::lock(), and cond::persistency::IOVEditor::lock().
Referenced by FakeBeamMonitor::dqmBeginRun(), and BeamMonitor::dqmBeginRun().
|
inline |
Definition at line 245 of file PoolDBOutputService.h.
References m_logger.
Referenced by FakeBeamMonitor::beginLuminosityBlock(), BeamMonitor::beginLuminosityBlock(), FakeBeamMonitor::endLuminosityBlock(), BeamMonitor::endLuminosityBlock(), FakeBeamMonitor::FitAndFill(), BeamMonitor::FitAndFill(), and cond::service::OnlineDBOutputService::writeIOVForNextLumisection().
const cond::service::PoolDBOutputService::Record & PoolDBOutputService::lookUpRecord | ( | const std::string & | recordName | ) |
Definition at line 389 of file PoolDBOutputService.cc.
References ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, align_cfg::recordName, and cond::throwException().
Referenced by appendOneIOV(), and cond::service::OnlineDBOutputService::writeIOVForNextLumisection().
|
private |
Definition at line 399 of file PoolDBOutputService.cc.
References ALPAKA_ACCELERATOR_NAMESPACE::vertexFinder::it, and align_cfg::recordName.
Referenced by writeMany().
cond::persistency::Session PoolDBOutputService::newReadOnlySession | ( | const std::string & | connectionString, |
const std::string & | transactionId | ||
) |
Definition at line 89 of file PoolDBOutputService.cc.
References l1RCTOmdsFedVectorProducer_cfi::connectionString, and runTheMatrix::ret.
Referenced by cond::service::OnlineDBOutputService::preLoadIov().
void PoolDBOutputService::postEndJob | ( | ) |
Definition at line 213 of file PoolDBOutputService.cc.
|
private |
|
private |
Definition at line 215 of file PoolDBOutputService.cc.
References edm::StreamContext::streamID(), edm::StreamContext::timestamp(), edm::Timestamp::value(), and edm::StreamID::value().
|
private |
Definition at line 235 of file PoolDBOutputService.cc.
References edm::GlobalContext::luminosityBlockID(), hcalRecHitTable_cff::time, and edm::LuminosityBlockID::value().
|
private |
Definition at line 229 of file PoolDBOutputService.cc.
References edm::GlobalContext::luminosityBlockID(), edm::LuminosityBlockID::run(), and hcalRecHitTable_cff::time.
|
private |
Definition at line 219 of file PoolDBOutputService.cc.
References s_streamIndex, edm::StreamContext::streamID(), and edm::StreamID::value().
void PoolDBOutputService::releaseLocks | ( | ) |
Definition at line 115 of file PoolDBOutputService.cc.
References CommonMethods::lock(), and cond::persistency::IOVEditor::unlock().
Referenced by FakeBeamMonitor::dqmEndRun(), and BeamMonitor::dqmEndRun().
cond::persistency::Session PoolDBOutputService::session | ( | ) | const |
Definition at line 96 of file PoolDBOutputService.cc.
Referenced by PCLMetadataWriter::endRun(), popcon::PopCon::initialize(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::readObject(), l1t::DataWriterExt::readObject(), l1t::WriterProxyT< Record, Type >::save(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), l1t::DataWriter::writeKeyList(), l1t::DataWriterExt::writeKeyList(), and l1t::DataWriter::writePayload().
void PoolDBOutputService::setLogHeaderForRecord | ( | const std::string & | recordName, |
const std::string & | provenance, | ||
const std::string & | usertext | ||
) |
Definition at line 434 of file PoolDBOutputService.cc.
References cond::UserLogInfo::provenance, align_cfg::recordName, and cond::UserLogInfo::usertext.
Referenced by popcon::PopCon::write().
void PoolDBOutputService::startTransaction | ( | ) |
Definition at line 175 of file PoolDBOutputService.cc.
References CommonMethods::lock().
Referenced by popcon::PopCon::initialize(), and AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB().
std::string PoolDBOutputService::tag | ( | const std::string & | recordName | ) |
Definition at line 132 of file PoolDBOutputService.cc.
References align_cfg::recordName.
Referenced by SiPhase2OuterTrackerLorentzAngleWriter::analyze(), PCLMetadataWriter::endRun(), popcon::PopCon::initialize(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::updateIOV(), and l1t::DataWriterExt::updateIOV().
bool PoolDBOutputService::tagInfo | ( | const std::string & | recordName, |
cond::TagInfo_t & | result | ||
) |
Definition at line 458 of file PoolDBOutputService.cc.
References cppFunctionSkipper::exception, CommonMethods::lock(), align_cfg::recordName, mps_fire::result, runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, and cond::throwException().
Referenced by l1t::DataWriter::lastPayloadToken(), l1t::DataWriterExt::lastPayloadToken(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), and AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB().
|
inline |
Definition at line 107 of file PoolDBOutputService.h.
References a, cond::persistency::Session::createIov(), doCommitTransaction(), doStartTransaction(), cond::persistency::Session::editIov(), cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), getRecord(), getTagInfo(), initDB(), cond::persistency::IOVEditor::insert(), isNewTagRequest(), cond::TagInfo_t::lastInterval, CommonMethods::lock(), cond::persistency::Logger::logInfo(), lookUpUserLogInfo(), m_autoCommit, m_logger, m_mutex, m_session, cond::time::MAX_VAL(), jetsAK4_Puppi_cff::payload, HLT_2024v10_cff::payloadType, align_cfg::recordName, cond::persistency::IOVEditor::setDescription(), cond::Iov_t::since, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::throwException(), hcalRecHitTable_cff::time, to_string(), and cond::persistency::Session::transaction().
Referenced by popcon::PopCon::write().
|
inline |
Definition at line 64 of file PoolDBOutputService.h.
References appendSinceTime(), createNewIOV(), doCommitTransaction(), doStartTransaction(), cppFunctionSkipper::exception, getRecord(), getTagInfo(), initDB(), isNewTagRequest(), cond::TagInfo_t::lastInterval, CommonMethods::lock(), cond::persistency::Logger::logInfo(), m_autoCommit, m_logger, m_mutex, m_session, cond::time::MAX_VAL(), jetsAK4_Puppi_cff::payload, HLT_2024v10_cff::payloadType, align_cfg::recordName, cond::Iov_t::since, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), hcalRecHitTable_cff::time, to_string(), and cond::persistency::Session::transaction().
Referenced by EcalDQMStatusWriter::analyze(), L1KeyListWriter::analyze(), L1KeyWriter::analyze(), L1TMuonOverlapParamsWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), L1MuonOverlapPhase1ParamsDBProducer::analyze(), LHCInfoPerFillWriter::analyze(), LHCInfoPerLSWriter::analyze(), L1TCaloStage2ParamsWriter::analyze(), L1TGlobalPrescalesVetosWriter::analyze(), L1TMuonEndCapForestWriter::analyze(), L1TMuonGlobalParamsWriter::analyze(), SurveyInputTrackerFromDB::analyze(), L1TMuonEndCapParamsWriter::analyze(), WritePPSAlignmentConfiguration::analyze(), L1TMuonBarrelParamsWriter::analyze(), L1TMuonOverlapFwVersionTester::analyze(), WritePPSAssociationCuts::analyze(), GBRForestWriter::analyze(), PPSGeometryBuilder::analyze(), PPSTimingCalibrationWriter::analyze(), PPSTimingCalibrationLUTWriter::analyze(), BufferedBoostIODBWriter::analyze(), WriteCTPPSPixelAnalysisMask::analyze(), ProduceDropBoxMetadata::analyze(), CTPPSRPAlignmentInfoAnalyzer::analyze(), WriteCTPPSPixelDAQMapping::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelTemplateDBObjectUploader::analyze(), WriteCTPPSTotemDAQMappingMask::analyze(), WriteCTPPSBeamParameters::analyze(), EcalMustacheSCParametersMaker::analyze(), EcalSCDynamicDPhiParametersMaker::analyze(), SiStripBadChannelPatcher::analyze(), BoostIODBWriter< DataType >::analyze(), FFTJetCorrectorDBWriter::analyze(), SiStripApvGainRescaler::analyze(), SiPhase2OuterTrackerLorentzAngleWriter::analyze(), TrackerSystematicMisalignments::analyze(), TrackerGeometryCompare::analyze(), SiStripGainPayloadCopyAndExclude::analyze(), MCMisalignmentScaler::analyze(), DTCCablingMapTestProducer::beginJob(), PPSDiamondSampicTimingCalibrationPCLHarvester::calibDb(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), SiPixelStatusHarvester::constructTag(), EcalDBCopy::copyToDB(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), PPSTimingCalibrationPCLHarvester::dqmEndJob(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripLorentzAnglePCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), SiPixelLorentzAnglePCLHarvester::dqmEndJob(), SiPixelLorentzAnglePCLHarvesterMCS::dqmEndJob(), SiPixelStatusHarvester::dqmEndRun(), PPSAlignmentHarvester::dqmEndRun(), CorrPCCProducer::dqmEndRunProduce(), SurveyDBUploader::endJob(), SiPixelQualityProbabilitiesTestWriter::endJob(), SiPixelQualityProbabilitiesWriteFromASCII::endJob(), Mixing2DB::endJob(), SiPixelFEDChannelContainerWriteFromASCII::endJob(), DTKeyedConfigDBInit::endJob(), SiPixelFEDChannelContainerFromQualityConverter::endJob(), FastSiPixelFEDChannelContainerFromQuality::endJob(), SiStripApvGainInspector::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(), WriteCTPPSPixGainCalibrations::fillDB(), 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(), SiStripHitEfficiencyHarvester::writeBadStripPayload(), AlignmentProducerBase::writeDB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), AlignPCLThresholdsWriter< T >::writePayload(), DTCalibDBUtils::writeToDB(), and CreateIdealTkAlRecords::writeToDB().
|
static |
Definition at line 37 of file PoolDBOutputService.h.
Referenced by BoostIODBWriter< DataType >::BoostIODBWriter(), ConditionDBWriter< SiStripApvGain >::ConditionDBWriter(), SiPixelLorentzAngleDBLoader::SiPixelLorentzAngleDBLoader(), SiStripApvGainInspector::SiStripApvGainInspector(), and SiStripNoisesAndBadCompsChecker::SiStripNoisesAndBadCompsChecker().
|
private |
Definition at line 306 of file PoolDBOutputService.h.
Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().
|
private |
Definition at line 303 of file PoolDBOutputService.h.
|
private |
Definition at line 301 of file PoolDBOutputService.h.
|
private |
Definition at line 308 of file PoolDBOutputService.h.
|
private |
Definition at line 298 of file PoolDBOutputService.h.
Referenced by logger(), writeMany(), and writeOneIOV().
|
private |
Definition at line 311 of file PoolDBOutputService.h.
Referenced by fillRecord().
|
private |
Definition at line 299 of file PoolDBOutputService.h.
Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().
|
private |
Definition at line 310 of file PoolDBOutputService.h.
Referenced by fillRecord().
|
private |
Definition at line 304 of file PoolDBOutputService.h.
Referenced by appendOneIOV(), createOneIOV(), writeMany(), and writeOneIOV().
|
private |
Definition at line 300 of file PoolDBOutputService.h.
|
private |
Definition at line 305 of file PoolDBOutputService.h.
|
private |
Definition at line 307 of file PoolDBOutputService.h.