Skip to content
New issue

Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.

Sign up for GitHub

By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.

Already on GitHub? Sign in to your account

Jump to bottom

Renamed new methods in PoolDBOutputService #35556

Merged
merged 3 commits into from Oct 9, 2021
Merged

Renamed new methods in PoolDBOutputService #35556

Show file tree
Hide file tree
Changes from all commits
Commits
Show all changes
3 commits
Select commit Hold shift + click to select a range
b2f7c08
Modified new method names to avoid template instantiation ambiguities
ggovi Oct 6, 2021
c11e910
Code-checks/format
ggovi Oct 6, 2021
9446aac
One more fix + one client migrated
ggovi Oct 7, 2021
File filter

Filter by extension

Filter by extension
Conversations
Failed to load comments.
Jump to
Jump to file
Failed to load files.
Diff view
Diff view
5 changes: 2 additions & 3 deletions CalibCalorimetry/CaloMiscalibTools/plugins/WriteEcalMiscalibConstants.cc
View file
Open in desktop
Expand Up @@ -54,12 +54,11 @@ void WriteEcalMiscalibConstants::analyze(const edm::Event& iEvent, const edm::Ev
if (poolDbService.isAvailable()) {
if (poolDbService->isNewTagRequest(newTagRequest_)) {
edm::LogVerbatim("WriteEcalMiscalibConstants") << "Creating a new IOV";
poolDbService->createNewIOV<const EcalIntercalibConstants>(*Mcal, poolDbService->beginOfTime(), newTagRequest_);
poolDbService->createOneIOV<const EcalIntercalibConstants>(*Mcal, poolDbService->beginOfTime(), newTagRequest_);
edm::LogVerbatim("WriteEcalMiscalibConstants") << "Done";
} else {
edm::LogVerbatim("WriteEcalMiscalibConstants") << "Old IOV";
poolDbService->appendSinceTime<const EcalIntercalibConstants>(
*Mcal, poolDbService->currentTime(), newTagRequest_);
poolDbService->appendOneIOV<const EcalIntercalibConstants>(*Mcal, poolDbService->currentTime(), newTagRequest_);
}
}
}
Expand Down
5 changes: 2 additions & 3 deletions CalibCalorimetry/CaloMiscalibTools/plugins/WriteEcalMiscalibConstantsMC.cc
View file
Open in desktop
Expand Up @@ -54,12 +54,11 @@ void WriteEcalMiscalibConstantsMC::analyze(const edm::Event& iEvent, const edm::
if (poolDbService.isAvailable()) {
if (poolDbService->isNewTagRequest(newTagRequest_)) {
edm::LogVerbatim("WriteEcalMiscalibConstantsMC") << "Creating a new IOV";
poolDbService->createNewIOV<const EcalIntercalibConstantsMC>(*Mcal, poolDbService->beginOfTime(), newTagRequest_);
poolDbService->createOneIOV<const EcalIntercalibConstantsMC>(*Mcal, poolDbService->beginOfTime(), newTagRequest_);
edm::LogVerbatim("WriteEcalMiscalibConstantsMC") << "Done";
} else {
edm::LogVerbatim("WriteEcalMiscalibConstantsMC") << "Old IOV";
poolDbService->appendSinceTime<const EcalIntercalibConstantsMC>(
*Mcal, poolDbService->currentTime(), newTagRequest_);
poolDbService->appendOneIOV<const EcalIntercalibConstantsMC>(*Mcal, poolDbService->currentTime(), newTagRequest_);
}
}
}
Expand Down
12 changes: 6 additions & 6 deletions CalibTracker/SiPixelQuality/plugins/SiPixelStatusHarvester.cc
View file
Open in desktop
Expand Up @@ -194,7 +194,7 @@ void SiPixelStatusHarvester::dqmEndRun(const edm::Run& iRun, const edm::EventSet
}
if (debug_ == true) { // only produced for debugging reason
cond::Time_t thisIOV = (cond::Time_t)iRun.id().run();
poolDbService->writeOne<SiPixelQuality>(*siPixelQualityPermBad, thisIOV, recordName_ + "_permanentBad");
poolDbService->writeOneIOV<SiPixelQuality>(*siPixelQualityPermBad, thisIOV, recordName_ + "_permanentBad");
}

// IOV for final payloads. FEDerror25 and pcl
Expand Down Expand Up @@ -298,7 +298,7 @@ void SiPixelStatusHarvester::dqmEndRun(const edm::Run& iRun, const edm::EventSet
fedError25IOV[it->first] = it->first;

if (debug_ == true) // only produced for debugging reason
poolDbService->writeOne<SiPixelQuality>(*siPixelQuality_FEDerror25, thisIOV, recordName_ + "_FEDerror25");
poolDbService->writeOneIOV<SiPixelQuality>(*siPixelQuality_FEDerror25, thisIOV, recordName_ + "_FEDerror25");

delete siPixelQuality_FEDerror25;
}
Expand Down Expand Up @@ -556,12 +556,12 @@ void SiPixelStatusHarvester::dqmEndRun(const edm::Run& iRun, const edm::EventSet
edm::LuminosityBlockID lu(iRun.id().run(), endLumiBlock_ + 1);
cond::Time_t thisIOV = (cond::Time_t)(lu.value());
if (!SiPixelStatusHarvester::equal(lastPrompt, siPixelQualityPermBad))
poolDbService->writeOne<SiPixelQuality>(*siPixelQualityPermBad, thisIOV, recordName_ + "_prompt");
poolDbService->writeOneIOV<SiPixelQuality>(*siPixelQualityPermBad, thisIOV, recordName_ + "_prompt");

// add empty bad components to last lumi+1 IF AND ONLY IF the last payload of other is not equal to empty
SiPixelQuality* siPixelQualityDummy = new SiPixelQuality();
if (!SiPixelStatusHarvester::equal(lastOther, siPixelQualityDummy))
poolDbService->writeOne<SiPixelQuality>(*siPixelQualityDummy, thisIOV, recordName_ + "_other");
poolDbService->writeOneIOV<SiPixelQuality>(*siPixelQualityDummy, thisIOV, recordName_ + "_other");

delete siPixelQualityDummy;
}
Expand Down Expand Up @@ -657,12 +657,12 @@ void SiPixelStatusHarvester::constructTag(std::map<int, SiPixelQuality*> siPixel

SiPixelQuality* thisPayload = qIt->second;
if (qIt == siPixelQualityTag.begin())
poolDbService->writeOne<SiPixelQuality>(*thisPayload, thisIOV, recordName_ + "_" + tagName);
poolDbService->writeOneIOV<SiPixelQuality>(*thisPayload, thisIOV, recordName_ + "_" + tagName);
else {
SiPixelQuality* prevPayload = (std::prev(qIt))->second;
if (!SiPixelStatusHarvester::equal(thisPayload,
prevPayload)) // only append newIOV if this payload differs wrt last
poolDbService->writeOne<SiPixelQuality>(*thisPayload, thisIOV, recordName_ + "_" + tagName);
poolDbService->writeOneIOV<SiPixelQuality>(*thisPayload, thisIOV, recordName_ + "_" + tagName);
}
}
}
Expand Down
2 changes: 1 addition & 1 deletion CalibTracker/SiStripESProducers/plugins/DBWriter/DummyCondDBWriter.h
View file
Open in desktop
Expand Up @@ -68,7 +68,7 @@ void DummyCondDBWriter<TObject, TObjectO, TRecord>::endRun(const edm::Run& run,
else
Time_ = iConfig_.getUntrackedParameter<uint32_t>("OpenIovAtTime", 1);

dbservice->writeOne(*obj, Time_, rcdName);
dbservice->writeOneIOV(*obj, Time_, rcdName);
} else {
edm::LogError("SiStripFedCablingBuilder") << "Service is unavailable" << std::endl;
}
Expand Down
4 changes: 2 additions & 2 deletions CalibTracker/SiStripESProducers/plugins/DBWriter/SiStripFedCablingManipulator.cc
View file
Open in desktop
Expand Up @@ -41,12 +41,12 @@ void SiStripFedCablingManipulator::endRun(const edm::Run& run, const edm::EventS
edm::LogInfo("SiStripFedCablingManipulator") << "first request for storing objects with Record "
<< "SiStripFedCablingRcd"
<< " at time " << Time_ << std::endl;
dbservice->createNewIOV<SiStripFedCabling>(*obj, Time_, "SiStripFedCablingRcd");
dbservice->createOneIOV<SiStripFedCabling>(*obj, Time_, "SiStripFedCablingRcd");
} else {
edm::LogInfo("SiStripFedCablingManipulator") << "appending a new object to existing tag "
<< "SiStripFedCablingRcd"
<< " in since mode " << std::endl;
dbservice->appendSinceTime<SiStripFedCabling>(*obj, Time_, "SiStripFedCablingRcd");
dbservice->appendOneIOV<SiStripFedCabling>(*obj, Time_, "SiStripFedCablingRcd");
}
} else {
edm::LogError("SiStripFedCablingManipulator") << "Service is unavailable" << std::endl;
Expand Down
2 changes: 1 addition & 1 deletion CommonTools/ConditionDBWriter/interface/ConditionDBWriter.h
View file
Open in desktop
Expand Up @@ -332,7 +332,7 @@ class ConditionDBWriter : public edm::one::EDAnalyzer<edm::one::WatchRuns, edm::

edm::LogInfo("ConditionDBWriter") << "appending a new object to tag " << Record_ << " in since mode " << std::endl;

mydbservice->writeOne<T>(*objPointer, since, Record_);
mydbservice->writeOneIOV<T>(*objPointer, since, Record_);
}

void setTime() {
Expand Down
4 changes: 2 additions & 2 deletions CondCore/DBOutputService/interface/OnlineDBOutputService.h
View file
Open in desktop
Expand Up @@ -37,11 +37,11 @@ namespace cond {

//
template <typename PayloadType>
bool writeForNextLumisection(const PayloadType& payload, const std::string& recordName) {
bool writeIOVForNextLumisection(const PayloadType& payload, const std::string& recordName) {
cond::Time_t targetTime = getLastLumiProcessed() + m_latencyInLumisections;
auto t0 = std::chrono::high_resolution_clock::now();
logger().logInfo() << "Updating lumisection " << targetTime;
cond::Hash payloadId = PoolDBOutputService::writeOne<PayloadType>(payload, targetTime, recordName);
cond::Hash payloadId = PoolDBOutputService::writeOneIOV<PayloadType>(payload, targetTime, recordName);
bool ret = true;
if (payloadId.empty()) {
return false;
Expand Down
18 changes: 8 additions & 10 deletions CondCore/DBOutputService/interface/PoolDBOutputService.h
View file
Open in desktop
Expand Up @@ -59,7 +59,7 @@ namespace cond {
bool isNewTagRequest(const std::string& recordName);

template <typename T>
Hash writeOne(const T& payload, Time_t time, const std::string& recordName) {
Hash writeOneIOV(const T& payload, Time_t time, const std::string& recordName) {
std::lock_guard<std::recursive_mutex> lock(m_mutex);
doStartTransaction();
cond::persistency::TransactionScope scope(m_session.transaction());
Expand All @@ -85,7 +85,7 @@ namespace cond {
}
}
thePayloadHash = m_session.storePayload(payload);
std::string payloadType = cond::demangledName(typeid(T));
std::string payloadType = cond::demangledName(typeid(payload));
if (newTag) {
createNewIOV(thePayloadHash, payloadType, time, myrecord);
} else {
Expand All @@ -111,8 +111,7 @@ namespace cond {
if (!payloadPtr)
throwException("Provided payload pointer is invalid.", "PoolDBOutputService::writeOne");
std::unique_ptr<const T> payload(payloadPtr);
std::lock_guard<std::recursive_mutex> lock(m_mutex);
return writeOne<T>(*payload, time, recordName);
return writeOneIOV<T>(*payload, time, recordName);
}

template <typename T>
Expand Down Expand Up @@ -172,9 +171,8 @@ namespace cond {
void closeIOV(Time_t lastTill, const std::string& recordName);

template <typename T>
void createNewIOV(const T& payload, cond::Time_t firstSinceTime, const std::string& recordName) {
void createOneIOV(const T& payload, cond::Time_t firstSinceTime, const std::string& recordName) {
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");
Expand All @@ -184,7 +182,7 @@ namespace cond {
try {
this->initDB();
Hash payloadId = m_session.storePayload(payload);
createNewIOV(payloadId, cond::demangledName(typeid(T)), firstSinceTime, myrecord);
createNewIOV(payloadId, cond::demangledName(typeid(payload)), firstSinceTime, myrecord);
} catch (const std::exception& er) {
cond::throwException(std::string(er.what()), "PoolDBOutputService::createNewIov");
}
Expand All @@ -197,11 +195,11 @@ namespace cond {
if (!payloadPtr)
throwException("Provided payload pointer is invalid.", "PoolDBOutputService::createNewIOV");
std::unique_ptr<const T> payload(payloadPtr);
this->createNewIOV<T>(*payload, firstSinceTime, recordName);
this->createOneIOV<T>(*payload, firstSinceTime, recordName);
}

template <typename T>
void appendSinceTime(const T& payload, cond::Time_t sinceTime, const std::string& recordName) {
void appendOneIOV(const T& payload, cond::Time_t sinceTime, const std::string& recordName) {
std::lock_guard<std::recursive_mutex> lock(m_mutex);
Record& myrecord = this->lookUpRecord(recordName);
if (myrecord.m_isNewTag) {
Expand All @@ -224,7 +222,7 @@ namespace cond {
if (!payloadPtr)
throwException("Provided payload pointer is invalid.", "PoolDBOutputService::appendSinceTime");
std::unique_ptr<const T> payload(payloadPtr);
this->appendSinceTime<T>(*payload, sinceTime, recordName);
this->appendOneIOV<T>(*payload, sinceTime, recordName);
}

void createNewIOV(const std::string& firstPayloadId, cond::Time_t firstSinceTime, const std::string& recordName);
Expand Down
2 changes: 1 addition & 1 deletion CondCore/DBOutputService/test/stubs/LumiBasedUpdateAnalyzer.cc
View file
Open in desktop
Expand Up @@ -50,7 +50,7 @@ void LumiBasedUpdateAnalyzer::beginLuminosityBlock(const edm::LuminosityBlock& l
mydbservice->logger().logDebug() << "BeamType: " << mybeamspot.GetBeamType();
m_ret = 0;
try {
mydbservice->writeForNextLumisection(&mybeamspot, m_record);
mydbservice->writeIOVForNextLumisection(mybeamspot, m_record);
} catch (const std::exception& e) {
std::cout << "Error:" << e.what() << std::endl;
mydbservice->logger().logError() << e.what();
Expand Down
4 changes: 2 additions & 2 deletions CondFormats/MFObjects/test/MagFieldConfigDBWriter.cc
View file
Open in desktop
Expand Up @@ -45,10 +45,10 @@ void MagFieldConfigDBWriter::endJob() {
try {
if (dbOutputSvc->isNewTagRequest(record)) {
//create mode
dbOutputSvc->writeOne<MagFieldConfig>(*conf, dbOutputSvc->beginOfTime(), record);
dbOutputSvc->writeOneIOV<MagFieldConfig>(*conf, dbOutputSvc->beginOfTime(), record);
} else {
//append mode. Note: correct PoolDBESSource must be loaded
dbOutputSvc->writeOne<MagFieldConfig>(*conf, dbOutputSvc->currentTime(), record);
dbOutputSvc->writeOneIOV<MagFieldConfig>(*conf, dbOutputSvc->currentTime(), record);
}
} catch (const cond::Exception& er) {
std::cout << er.what() << std::endl;
Expand Down
8 changes: 4 additions & 4 deletions CondTools/SiPixel/plugins/SiPixelGainCalibrationReadDQMFile.cc
View file
Open in desktop
Expand Up @@ -450,20 +450,20 @@ void SiPixelGainCalibrationReadDQMFile::fillDatabase(const edm::EventSetup &iSet
edm::LogPrint("SiPixelGainCalibrationReadDQMFile")
<< "now doing SiPixelGainCalibrationForHLTRcd payload..." << std::endl;
if (mydbservice->isNewTagRequest(record_)) {
mydbservice->createNewIOV<SiPixelGainCalibrationForHLT>(
mydbservice->createOneIOV<SiPixelGainCalibrationForHLT>(
*theGainCalibrationDbInputHLT, mydbservice->beginOfTime(), "SiPixelGainCalibrationForHLTRcd");
} else {
mydbservice->appendSinceTime<SiPixelGainCalibrationForHLT>(
mydbservice->appendOneIOV<SiPixelGainCalibrationForHLT>(
*theGainCalibrationDbInputHLT, mydbservice->currentTime(), "SiPixelGainCalibrationForHLTRcd");
}
} else if (record_ == "SiPixelGainCalibrationOfflineRcd") {
edm::LogPrint("SiPixelGainCalibrationReadDQMFile")
<< "now doing SiPixelGainCalibrationOfflineRcd payload..." << std::endl;
if (mydbservice->isNewTagRequest(record_)) {
mydbservice->createNewIOV<SiPixelGainCalibrationOffline>(
mydbservice->createOneIOV<SiPixelGainCalibrationOffline>(
*theGainCalibrationDbInputOffline, mydbservice->beginOfTime(), "SiPixelGainCalibrationOfflineRcd");
} else {
mydbservice->appendSinceTime<SiPixelGainCalibrationOffline>(
mydbservice->appendOneIOV<SiPixelGainCalibrationOffline>(
*theGainCalibrationDbInputOffline, mydbservice->currentTime(), "SiPixelGainCalibrationOfflineRcd");
}
}
Expand Down
4 changes: 2 additions & 2 deletions CondTools/SiPixel/plugins/SiPixelTemplateDBObjectUploader.cc
View file
Open in desktop
Expand Up @@ -281,9 +281,9 @@ void SiPixelTemplateDBObjectUploader::analyze(const edm::Event& iEvent, const ed
if (!poolDbService.isAvailable()) // Die if not available
throw cms::Exception("NotAvailable") << "PoolDBOutputService not available";
if (poolDbService->isNewTagRequest("SiPixelTemplateDBObjectRcd"))
poolDbService->writeOne(&obj, poolDbService->beginOfTime(), "SiPixelTemplateDBObjectRcd");
poolDbService->writeOneIOV(obj, poolDbService->beginOfTime(), "SiPixelTemplateDBObjectRcd");
else
poolDbService->writeOne(&obj, poolDbService->currentTime(), "SiPixelTemplateDBObjectRcd");
poolDbService->writeOneIOV(obj, poolDbService->currentTime(), "SiPixelTemplateDBObjectRcd");
}

void SiPixelTemplateDBObjectUploader::endJob() {}
Expand Down
4 changes: 2 additions & 2 deletions CondTools/SiStrip/plugins/SiStripApvSimulationParametersBuilder.cc
View file
Open in desktop
Expand Up @@ -22,10 +22,10 @@ void SiStripApvSimulationParametersBuilder::analyze(const edm::Event&, const edm
edm::Service<cond::service::PoolDBOutputService> mydbservice;
if (mydbservice.isAvailable()) {
if (mydbservice->isNewTagRequest("SiStripApvSimulationParametersRcd")) {
mydbservice->createNewIOV<SiStripApvSimulationParameters>(
mydbservice->createOneIOV<SiStripApvSimulationParameters>(
*obj, mydbservice->beginOfTime(), "SiStripApvSimulationParametersRcd");
} else {
mydbservice->appendSinceTime<SiStripApvSimulationParameters>(
mydbservice->appendOneIOV<SiStripApvSimulationParameters>(
*obj, mydbservice->currentTime(), "SiStripApvSimulationParametersRcd");
}
} else {
Expand Down
5 changes: 2 additions & 3 deletions CondTools/SiStrip/plugins/SiStripBadChannelBuilder.cc
View file
Open in desktop
Expand Up @@ -79,10 +79,9 @@ std::unique_ptr<SiStripBadStrip> SiStripBadChannelBuilder::getNewObject() {

if (mydbservice.isAvailable()) {
if (mydbservice->isNewTagRequest("SiStripBadStripRcd")) {
mydbservice->createNewIOV<SiStripBadStrip>(*obj, mydbservice->beginOfTime(), "SiStripBadStripRcd");
mydbservice->createOneIOV<SiStripBadStrip>(*obj, mydbservice->beginOfTime(), "SiStripBadStripRcd");
} else {
//mydbservice->createNewIOV<SiStripBadStrip>(*obj, mydbservice->currentTime(),"SiStripBadStripRcd");
mydbservice->appendSinceTime<SiStripBadStrip>(*obj, mydbservice->currentTime(), "SiStripBadStripRcd");
mydbservice->appendOneIOV<SiStripBadStrip>(*obj, mydbservice->currentTime(), "SiStripBadStripRcd");
}
} else {
edm::LogError("SiStripBadStripBuilder") << "Service is unavailable" << std::endl;
Expand Down
2 changes: 1 addition & 1 deletion DQM/BeamMonitor/plugins/BeamMonitor.cc
View file
Open in desktop
Expand Up @@ -1430,7 +1430,7 @@ void BeamMonitor::FitAndFill(const LuminosityBlock& lumiSeg, int& lastlumi, int&
<< "BeamMonitor::FitAndFill - [PayloadCreation] SetCreationTime: " << creationTime
<< " [epoch in microseconds]";
try {
onlineDbService_->writeForNextLumisection(BSOnline, recordName_);
onlineDbService_->writeIOVForNextLumisection(BSOnline, recordName_);
onlineDbService_->logger().logInfo()
<< "BeamMonitor::FitAndFill - [PayloadCreation] writeForNextLumisection executed correctly";
} catch (const std::exception& e) {
Expand Down
2 changes: 1 addition & 1 deletion DQM/BeamMonitor/plugins/FakeBeamMonitor.cc
View file
Open in desktop
Expand Up @@ -1459,7 +1459,7 @@ void FakeBeamMonitor::FitAndFill(const LuminosityBlock& lumiSeg, int& lastlumi,
onlineDbService_->logger().logInfo() << "FakeBeamMonitor::FitAndFill - [PayloadCreation] SetCreationTime: "
<< creationTime << " [epoch in microseconds]";
try {
onlineDbService_->writeForNextLumisection(BSOnline, recordName_);
onlineDbService_->writeIOVForNextLumisection(BSOnline, recordName_);
onlineDbService_->logger().logInfo()
<< "FakeBeamMonitor::FitAndFill - [PayloadCreation] writeForNextLumisection executed correctly";
} catch (const std::exception& e) {
Expand Down
4 changes: 2 additions & 2 deletions DQM/EcalMonitorDbModule/plugins/EcalDQMStatusWriter.cc
View file
Open in desktop
Expand Up @@ -36,8 +36,8 @@ void EcalDQMStatusWriter::analyze(edm::Event const &, edm::EventSetup const &_es
if (firstRun_ == dbOutput.endOfTime())
return;

dbOutput.writeOne(channelStatus_, firstRun_, "EcalDQMChannelStatusRcd");
dbOutput.writeOne(towerStatus_, firstRun_, "EcalDQMTowerStatusRcd");
dbOutput.writeOneIOV(channelStatus_, firstRun_, "EcalDQMChannelStatusRcd");
dbOutput.writeOneIOV(towerStatus_, firstRun_, "EcalDQMTowerStatusRcd");

firstRun_ = dbOutput.endOfTime(); // avoid accidentally re-writing the conditions
}
Expand Down
2 changes: 1 addition & 1 deletion IOMC/EventVertexGenerators/src/BeamProfile2DB.cc
View file
Open in desktop
Expand Up @@ -103,7 +103,7 @@ void BeamProfile2DB::beginJob() {}
// ------------ method called once each job just after ending the event loop ------------
void BeamProfile2DB::endJob() {
edm::Service<cond::service::PoolDBOutputService> poolDbService;
poolDbService->createNewIOV<SimBeamSpotObjects>(beamSpot_, poolDbService->beginOfTime(), "SimBeamSpotObjectsRcd");
poolDbService->createOneIOV<SimBeamSpotObjects>(beamSpot_, poolDbService->beginOfTime(), "SimBeamSpotObjectsRcd");
}

// ------------ method fills 'descriptions' with the allowed parameters for the module ------------
Expand Down
9 changes: 4 additions & 5 deletions RecoHI/HiJetAlgos/plugins/UETableProducer.cc
View file
Open in desktop
Expand Up @@ -202,18 +202,17 @@ void UETableProducer::endJob() {
jme_payload->push_back(JetCorrectorParametersCollection::L1Offset, parameter);

if (pool->isNewTagRequest("JetCorrectionsRecord")) {
pool->createNewIOV<JetCorrectorParametersCollection>(*jme_payload, pool->beginOfTime(), "JetCorrectionsRecord");
pool->createOneIOV<JetCorrectorParametersCollection>(*jme_payload, pool->beginOfTime(), "JetCorrectionsRecord");
} else {
pool->appendSinceTime<JetCorrectorParametersCollection>(
*jme_payload, pool->currentTime(), "JetCorrectionsRecord");
pool->appendOneIOV<JetCorrectorParametersCollection>(*jme_payload, pool->currentTime(), "JetCorrectionsRecord");
}
} else {
ue_predictor_pf->values = ue_vec;

if (pool->isNewTagRequest("HeavyIonUERcd")) {
pool->createNewIOV<UETable>(*ue_predictor_pf, pool->beginOfTime(), "HeavyIonUERcd");
pool->createOneIOV<UETable>(*ue_predictor_pf, pool->beginOfTime(), "HeavyIonUERcd");
} else {
pool->appendSinceTime<UETable>(*ue_predictor_pf, pool->currentTime(), "HeavyIonUERcd");
pool->appendOneIOV<UETable>(*ue_predictor_pf, pool->currentTime(), "HeavyIonUERcd");
}
}
}
Expand Down