cond::service::PoolDBOutputService Class Reference

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

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

Detailed Description

Definition at line 33 of file PoolDBOutputService.h.

Constructor & Destructor Documentation

PoolDBOutputService()

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

Definition at line 39 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", true);
  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::~PoolDBOutputService ( )

virtual

Definition at line 239 of file PoolDBOutputService.cc.

{}

Member Function Documentation

appendOneIOV()

template<typename T >

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

inline

Definition at line 183 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 SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripNoisesBuilder::analyze(), DBWriter::analyze(), SiStripApvGainBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::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(), and CaloGeometryDBWriter::writeIndexed().

                                                                                             {
        std::lock_guard<std::recursive_mutex> lock(m_mutex);
        doStartTransaction();
        cond::persistency::TransactionScope scope(m_session.transaction());
        try {
          bool dbexists = this->initDB(true);
          if (!dbexists) {
            cond::throwException(std::string("Target database does not exist."),
                                 "PoolDBOutputService::appendSinceTime");
          }
          auto& myrecord = this->lookUpRecord(recordName);
          if (myrecord.m_isNewTag) {
            cond::throwException(std::string("Cannot append to non-existing tag ") + myrecord.m_tag,
                                 "PoolDBOutputService::appendSinceTime");
          }
          appendSinceTime(m_session.storePayload(payload), sinceTime, myrecord);
          if (m_autoCommit) {
            doCommitTransaction();
          }
        } catch (const std::exception& er) {
          cond::throwException(std::string(er.what()), "PoolDBOutputService::appendSinceTime");
        }
        scope.close();
      }

appendSinceTime() [1/2]

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

Definition at line 312 of file PoolDBOutputService.cc.

References cppFunctionSkipper::exception, CommonMethods::lock(), align_cfg::recordName, runTheMatrix::ret, AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and protons_cff::time.

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

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

appendSinceTime() [2/2]

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

private

Definition at line 341 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 protons_cff::time.

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

beginOfTime()

cond::Time_t PoolDBOutputService::beginOfTime

(

)

const

Definition at line 258 of file PoolDBOutputService.cc.

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

Referenced by 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(), DBWriter::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(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), SiPixelTemplateDBObjectUploader::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), TrackerGeometryCompare::analyze(), TrackerSystematicMisalignments::analyze(), SiStripApvGainFromFileBuilder::analyze(), XMLGeometryBuilder::beginJob(), PTrackerAdditionalParametersPerDetDBBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), RPCRecoIdealDBLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::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(), SiPhase2BadStripChannelBuilder::getNewObject(), EcalLaserCondTools::processIov(), MuonMisalignedProducer::saveToDB(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

{ return timeTypeSpecs[m_timetype].beginValue; }

closeIOV()

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

Definition at line 405 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().

                                                                                          {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  doStartTransaction();
  cond::persistency::TransactionScope scope(m_session.transaction());
  try {
    bool dbexists = this->initDB();
    if (!dbexists) {
      cond::throwException(std::string("Target database does not exist."), "PoolDBOutputService::closeIOV");
    }
    auto& 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;
    cond::persistency::IOVEditor editor = m_session.editIov(myrecord.m_tag);
    editor.setEndOfValidity(lastTill);
    editor.flush("Tag closed.");
    if (m_autoCommit) {
      doCommitTransaction();
    }
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::closeIOV");
  }
  scope.close();
}

commitTransaction()

void PoolDBOutputService::commitTransaction

(

)

Definition at line 178 of file PoolDBOutputService.cc.

References CommonMethods::lock().

Referenced by popcon::PopCon::finalize(), and cond::service::OnlineDBOutputService::writeIOVForNextLumisection().

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

createNewIOV() [1/2]

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

Definition at line 265 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(), and writeOneIOV().

                                                                                   {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  doStartTransaction();
  cond::persistency::TransactionScope scope(m_session.transaction());
  try {
    this->initDB();
    auto& myrecord = this->getRecord(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;
    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;
    if (m_autoCommit) {
      doCommitTransaction();
    }
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::createNewIov");
  }
  scope.close();
}

createNewIOV() [2/2]

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

private

Definition at line 296 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_2022v12_cff::payloadType, cond::persistency::IOVEditor::setDescription(), and cond::SYNCH_ANY.

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

createOneIOV()

template<typename T >

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

inline

Definition at line 161 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(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripApvGainBuilder::analyze(), DBWriter::analyze(), SiStripDetVOffFakeBuilder::analyze(), EcalPFRecHitThresholdsMaker::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripApvGainFromFileBuilder::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(), SiPhase2BadStripChannelBuilder::getNewObject(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), and CaloGeometryDBWriter::writeIndexed().

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

currentTime()

cond::Time_t PoolDBOutputService::currentTime

(

)

const

Definition at line 260 of file PoolDBOutputService.cc.

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

Referenced by L1MuonOverlapParamsDBProducer::analyze(), SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), L1MuonOverlapPhase1ParamsDBProducer::analyze(), SiStripApvGainBuilder::analyze(), DBWriter::analyze(), WritePPSAssociationCuts::analyze(), WritePPSAlignmentConfiguration::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), BufferedBoostIODBWriter::analyze(), PPSTimingCalibrationLUTWriter::analyze(), SiPixelDynamicInefficiencyDB::analyze(), PPSTimingCalibrationWriter::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), SiPixelTemplateDBObjectUploader::analyze(), EcalMustacheSCParametersMaker::analyze(), EcalSCDynamicDPhiParametersMaker::analyze(), FFTJetCorrectorDBWriter::analyze(), cms::SiPixelCondObjBuilder::analyze(), BoostIODBWriter< DataType >::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), SiStripApvGainRescaler::analyze(), SiPhase2OuterTrackerLorentzAngleWriter::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripApvGainFromFileBuilder::analyze(), SiStripFedCablingBuilder::beginRun(), PPSDiamondSampicTimingCalibrationPCLHarvester::calibDb(), SiPixelGainCalibScaler::computeAndStorePalyoads(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), PPSTimingCalibrationPCLHarvester::dqmEndJob(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), SiPixelLorentzAnglePCLHarvester::dqmEndJob(), PPSAlignmentHarvester::dqmEndRun(), CocoaDBMgr::DumpCocoaResults(), SurveyDBUploader::endJob(), BeamSpotWrite2DB::endJob(), Mixing2DB::endJob(), SiPixelQualityProbabilitiesTestWriter::endJob(), SiPixelQualityProbabilitiesWriteFromASCII::endJob(), SiPixelFEDChannelContainerWriteFromASCII::endJob(), SiPixelFEDChannelContainerFromQualityConverter::endJob(), BeamSpotOnlineRecordsWriter::endJob(), FastSiPixelFEDChannelContainerFromQuality::endJob(), SiStripFedCablingManipulator::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::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(), and DTCalibDBUtils::writeToDB().

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

doCommitTransaction()

void PoolDBOutputService::doCommitTransaction ( )

private

Definition at line 162 of file PoolDBOutputService.cc.

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

                                                         {
  if (m_transactionActive) {
    if (m_writeTransactionDelay) {
      m_logger.logWarning() << "Waiting " << m_writeTransactionDelay << "s before commit the changes...";
      ::sleep(m_writeTransactionDelay);
    }
    m_session.transaction().commit();
    m_transactionActive = false;
  }
}

doStartTransaction()

void PoolDBOutputService::doStartTransaction ( )

private

Definition at line 155 of file PoolDBOutputService.cc.

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

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

endOfTime()

cond::Time_t PoolDBOutputService::endOfTime

(

)

const

Definition at line 256 of file PoolDBOutputService.cc.

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

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

{ return timeTypeSpecs[m_timetype].endValue; }

eraseSinceTime()

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

Definition at line 356 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().

                                                                                     {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  doStartTransaction();
  cond::persistency::TransactionScope scope(m_session.transaction());
  try {
    bool dbexists = this->initDB();
    if (!dbexists) {
      cond::throwException(std::string("Target database does not exist."), "PoolDBOutputService::eraseSinceTime");
    }
    auto& 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;
    cond::persistency::IOVEditor editor = m_session.editIov(myrecord.m_tag);
    editor.erase(sinceTime, payloadId);
    cond::UserLogInfo a = this->lookUpUserLogInfo(recordName);
    editor.flush(a.usertext);
    if (m_autoCommit) {
      doCommitTransaction();
    }
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::eraseSinceTime");
  }
  scope.close();
}

fillRecord()

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_refreshTime, 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);

  thisrecord.m_refreshTime = recordPset.getUntrackedParameter<unsigned int>("refreshTime", 1);

  m_records.insert(std::make_pair(thisrecord.m_idName, thisrecord));

  cond::UserLogInfo userloginfo;
  m_logheaders.insert(std::make_pair(thisrecord.m_idName, userloginfo));
}

forceInit()

void PoolDBOutputService::forceInit

(

)

Definition at line 241 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();
    if (m_autoCommit) {
      doCommitTransaction();
    }
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::forceInit");
  }
  scope.close();
}

getRecord()

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

private

Definition at line 201 of file PoolDBOutputService.cc.

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

Referenced by 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::getRecord");
  }
  return it->second;
}

getTagInfo()

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

private

Definition at line 441 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().

                                                                                                  {
  auto& record = lookUpRecord(recordName);
  result.name = record.m_tag;
  m_logger.logDebug() << "Fetching tag info for " << record.m_tag;
  bool ret = false;
  //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;
  }
  return ret;
}

initDB()

bool PoolDBOutputService::initDB ( bool  readOnly = false )

private

Definition at line 183 of file PoolDBOutputService.cc.

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

                                                         {
  if (!m_dbInitialised) {
    if (!m_session.existsDatabase()) {
      if (readOnly)
        return false;
      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;
  }
  return m_dbInitialised;
}

isNewTagRequest()

bool PoolDBOutputService::isNewTagRequest

(

const std::string &

recordName

)

Definition at line 134 of file PoolDBOutputService.cc.

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

Referenced by SiStripPedestalsBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripApvGainBuilder::analyze(), DBWriter::analyze(), SiStripDetVOffFakeBuilder::analyze(), cms::SiPixelPerformanceSummaryBuilder::analyze(), SiPixelLorentzAngleDB::analyze(), SiPixelVCalDB::analyze(), SiPixelDynamicInefficiencyDB::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), SiPixelGenErrorDBObjectUploader::analyze(), SiPixelCalibConfigurationObjectMaker::analyze(), SiPixelTemplateDBObjectUploader::analyze(), SiPixel2DTemplateDBObjectUploader::analyze(), EcalTestDevDB::analyze(), cms::SiPixelCondObjBuilder::analyze(), cms::SiPixelCondObjForHLTBuilder::analyze(), cms::SiPixelCondObjOfflineBuilder::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripApvGainFromFileBuilder::analyze(), XMLGeometryBuilder::beginJob(), PTrackerAdditionalParametersPerDetDBBuilder::beginRun(), 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(), and DTCalibDBUtils::writeToDB().

                                                                                {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  bool doCommit = false;
  if (!m_transactionActive) {
    m_session.transaction().start(true);
    doCommit = true;
  }
  bool dbexists = false;
  try {
    dbexists = initDB(true);
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::isNewTagRequest");
  }
  if (doCommit)
    m_session.transaction().commit();
  if (!dbexists)
    return true;
  auto& myrecord = this->lookUpRecord(recordName);
  return myrecord.m_isNewTag;
}

lockRecords()

void PoolDBOutputService::lockRecords

(

)

Definition at line 96 of file PoolDBOutputService.cc.

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

Referenced by FakeBeamMonitor::dqmBeginRun(), and BeamMonitor::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();
    }
  }
  if (m_autoCommit) {
    doCommitTransaction();
  }
  scope.close();
}

logger()

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

inline

Definition at line 243 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().

{ return m_logger; }

lookUpRecord()

const cond::service::PoolDBOutputService::Record & PoolDBOutputService::lookUpRecord

(

const std::string &

recordName

)

Definition at line 387 of file PoolDBOutputService.cc.

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

Referenced by appendOneIOV(), and cond::service::OnlineDBOutputService::writeIOVForNextLumisection().

                                 {
  std::map<std::string, Record>::const_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;
}

lookUpUserLogInfo()

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

private

Definition at line 397 of file PoolDBOutputService.cc.

References align_cfg::recordName.

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

newReadOnlySession()

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

Definition at line 87 of file PoolDBOutputService.cc.

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

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

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

postEndJob()

void PoolDBOutputService::postEndJob

(

)

Definition at line 211 of file PoolDBOutputService.cc.

{ commitTransaction(); }

postModuleEvent()

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

private

Definition at line 222 of file PoolDBOutputService.cc.

References s_streamIndex.

                                                                                         {
  s_streamIndex = -1;
}

preEventProcessing()

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

private

Definition at line 213 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();
}

preGlobalBeginLumi()

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

private

Definition at line 233 of file PoolDBOutputService.cc.

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

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

preGlobalBeginRun()

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

private

Definition at line 227 of file PoolDBOutputService.cc.

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

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

preModuleEvent()

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

private

Definition at line 217 of file PoolDBOutputService.cc.

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

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

releaseLocks()

void PoolDBOutputService::releaseLocks

(

)

Definition at line 113 of file PoolDBOutputService.cc.

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

Referenced by FakeBeamMonitor::dqmEndRun(), and BeamMonitor::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();
    }
  }
  if (m_autoCommit) {
    doCommitTransaction();
  }
  scope.close();
}

session()

cond::persistency::Session PoolDBOutputService::session

(

)

const

Definition at line 94 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(), l1t::DataWriter::writeKeyList(), l1t::DataWriterExt::writeKeyList(), and l1t::DataWriter::writePayload().

{ return m_session; }

setLogHeaderForRecord()

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

Definition at line 432 of file PoolDBOutputService.cc.

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

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

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

startTransaction()

void PoolDBOutputService::startTransaction

(

)

Definition at line 173 of file PoolDBOutputService.cc.

References CommonMethods::lock().

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

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

tag()

std::string PoolDBOutputService::tag

(

const std::string &

recordName

)

Definition at line 130 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().

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

tagInfo()

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

Definition at line 456 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(), and l1t::DataWriterExt::updateIOV().

                                                                                               {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  bool ret = false;
  bool doCommit = false;
  if (!m_transactionActive) {
    m_session.transaction().start(true);
    doCommit = true;
  }
  bool dbexists = false;
  cond::persistency::TransactionScope scope(m_session.transaction());
  try {
    dbexists = initDB(true);
    if (dbexists) {
      ret = getTagInfo(recordName, result);
    }
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::tagInfo");
  }
  if (doCommit)
    m_session.transaction().commit();
  scope.close();
  return ret;
}

writeMany()

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 105 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_2022v12_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(), protons_cff::time, cond::impl::to_string(), and cond::persistency::Session::transaction().

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();
          auto& myrecord = this->getRecord(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;
      }

writeOneIOV()

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, 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_2022v12_cff::payloadType, align_cfg::recordName, cond::Iov_t::since, cond::persistency::Session::storePayload(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), protons_cff::time, cond::impl::to_string(), and cond::persistency::Session::transaction().

Referenced by EcalDQMStatusWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), L1MuonOverlapPhase1ParamsDBProducer::analyze(), SurveyInputTrackerFromDB::analyze(), WritePPSAlignmentConfiguration::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(), WriteCTPPSBeamParameters::analyze(), EcalMustacheSCParametersMaker::analyze(), EcalSCDynamicDPhiParametersMaker::analyze(), FFTJetCorrectorDBWriter::analyze(), BoostIODBWriter< DataType >::analyze(), SiStripApvGainRescaler::analyze(), TrackerSystematicMisalignments::analyze(), TrackerGeometryCompare::analyze(), SiPhase2OuterTrackerLorentzAngleWriter::analyze(), MCMisalignmentScaler::analyze(), 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(), SiPixelQualityProbabilitiesTestWriter::endJob(), Mixing2DB::endJob(), SiPixelQualityProbabilitiesWriteFromASCII::endJob(), SiPixelFEDChannelContainerWriteFromASCII::endJob(), DTKeyedConfigDBInit::endJob(), SiPixelFEDChannelContainerFromQualityConverter::endJob(), FastSiPixelFEDChannelContainerFromQuality::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(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), AlignmentProducerBase::writeDB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), AlignPCLThresholdsWriter< T >::writePayload(), DTCalibDBUtils::writeToDB(), 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();
          auto& myrecord = this->getRecord(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) {
            doCommitTransaction();
          }
        } catch (const std::exception& er) {
          cond::throwException(std::string(er.what()), "PoolDBOutputService::writeOne");
        }
        scope.close();
        return thePayloadHash;
      }

Member Data Documentation

m_autoCommit

bool cond::service::PoolDBOutputService::m_autoCommit

private

Definition at line 304 of file PoolDBOutputService.h.

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

m_connection

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

private

Definition at line 301 of file PoolDBOutputService.h.

m_currentTimes

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

private

Definition at line 299 of file PoolDBOutputService.h.

m_dbInitialised

bool cond::service::PoolDBOutputService::m_dbInitialised

private

Definition at line 306 of file PoolDBOutputService.h.

m_logger

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

private

Definition at line 296 of file PoolDBOutputService.h.

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

m_logheaders

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

private

Definition at line 309 of file PoolDBOutputService.h.

Referenced by fillRecord().

m_mutex

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

private

Definition at line 297 of file PoolDBOutputService.h.

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

m_records

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

private

Definition at line 308 of file PoolDBOutputService.h.

Referenced by fillRecord().

m_session

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

private

Definition at line 302 of file PoolDBOutputService.h.

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

m_timetype

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

private

Definition at line 298 of file PoolDBOutputService.h.

m_transactionActive

bool cond::service::PoolDBOutputService::m_transactionActive

private

Definition at line 303 of file PoolDBOutputService.h.

m_writeTransactionDelay

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

private

Definition at line 305 of file PoolDBOutputService.h.