cond::service::PoolDBOutputService Class Reference

#include <PoolDBOutputService.h>

Inheritance diagram for cond::service::PoolDBOutputService:

Classes
struct	Record

Public Member Functions
bool	appendSinceTime (const std::string &payloadId, cond::Time_t sinceTime, const std::string &recordName)
template<typename T >
void	appendSinceTime (const T *payloadObj, cond::Time_t sinceTime, const std::string &recordName)
cond::Time_t	beginOfTime () const
void	closeIOV (Time_t lastTill, const std::string &recordName)
void	commitTransaction ()
void	createNewIOV (const std::string &firstPayloadId, cond::Time_t firstSinceTime, const std::string &recordName)
template<typename T >
void	createNewIOV (const T *firstPayloadObj, cond::Time_t firstSinceTime, cond::Time_t, const std::string &recordName)
cond::Time_t	currentTime () const
cond::Time_t	endOfTime () const
void	eraseSinceTime (const std::string &payloadId, cond::Time_t sinceTime, const std::string &recordName)
void	forceInit ()
bool	isNewTagRequest (const std::string &recordName)
void	lockRecords ()
cond::persistency::Logger &	logger ()
cond::persistency::Session	newReadOnlySession (const std::string &connectionString, const std::string &transactionId)
	PoolDBOutputService (const edm::ParameterSet &iConfig, edm::ActivityRegistry &iAR)
void	postEndJob ()
void	releaseLocks ()
cond::persistency::Session	session () const
void	setLogHeaderForRecord (const std::string &recordName, const std::string &provenance, const std::string &usertext)
void	startTransaction ()
std::string	tag (const std::string &recordName)
bool	tagInfo (const std::string &recordName, cond::TagInfo_t &result)
template<typename T >
Hash	writeOne (const T *payload, Time_t time, const std::string &recordName)
virtual	~PoolDBOutputService ()

Private Member Functions
bool	appendSinceTime (const std::string &payloadId, cond::Time_t sinceTime, Record &record)
void	createNewIOV (const std::string &firstPayloadId, const std::string payloadType, cond::Time_t firstSinceTime, Record &record)
void	doCommitTransaction ()
void	doStartTransaction ()
void	fillRecord (edm::ParameterSet &pset, const std::string &gTimeTypeStr)
bool	getTagInfo (const std::string &recordName, cond::TagInfo_t &result)
void	initDB ()
Record &	lookUpRecord (const std::string &recordName)
cond::UserLogInfo &	lookUpUserLogInfo (const std::string &recordName)
void	postModuleEvent (edm::StreamContext const &, edm::ModuleCallingContext const &)
void	preEventProcessing (edm::StreamContext const &)
void	preGlobalBeginLumi (edm::GlobalContext const &)
void	preGlobalBeginRun (edm::GlobalContext const &)
void	preModuleEvent (edm::StreamContext const &, edm::ModuleCallingContext const &)

Private Attributes
bool	m_autoCommit
cond::persistency::ConnectionPool	m_connection
std::vector< cond::Time_t >	m_currentTimes
bool	m_dbInitialised
cond::persistency::Logger	m_logger
std::map< std::string, cond::UserLogInfo >	m_logheaders
std::recursive_mutex	m_mutex
std::map< std::string, Record >	m_records
cond::persistency::Session	m_session
cond::TimeType	m_timetype
bool	m_transactionActive
unsigned int	m_writeTransactionDelay = 0

Detailed Description

Definition at line 33 of file PoolDBOutputService.h.

Constructor & Destructor Documentation

PoolDBOutputService()

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

Definition at line 37 of file PoolDBOutputService.cc.

    : m_logger(iConfig.getUntrackedParameter<std::string>("jobName", "DBOutputService")),
      m_currentTimes{},
      m_session(),
      m_transactionActive(false),
      m_dbInitialised(false),
      m_records(),
      m_logheaders() {
  std::string timetypestr = iConfig.getUntrackedParameter<std::string>("timetype", "runnumber");
  m_timetype = cond::time::timeTypeFromName(timetypestr);
  m_autoCommit = iConfig.getUntrackedParameter<bool>("autoCommit", false);
  m_writeTransactionDelay = iConfig.getUntrackedParameter<unsigned int>("writeTransactionDelay", 0);
  edm::ParameterSet connectionPset = iConfig.getParameter<edm::ParameterSet>("DBParameters");
  m_connection.setParameters(connectionPset);
  m_connection.setLogDestination(m_logger);
  m_connection.configure();
  std::string connectionString = iConfig.getParameter<std::string>("connect");
  m_session = m_connection.createSession(connectionString, true);
  bool saveLogsOnDb = iConfig.getUntrackedParameter<bool>("saveLogsOnDB", false);
  if (saveLogsOnDb)
    m_logger.setDbDestination(connectionString);
  // 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 199 of file PoolDBOutputService.cc.

{}

Member Function Documentation

appendSinceTime() [1/3]

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

Definition at line 265 of file PoolDBOutputService.cc.

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

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

appendSinceTime() [2/3]

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

private

Definition at line 286 of file PoolDBOutputService.cc.

                                                                           {
  m_logger.logInfo() << "Updating existing tag " << myrecord.m_tag << ", adding iov with since " << time;
  std::string payloadType("");
  try {
    cond::persistency::IOVEditor editor = m_session.editIov(myrecord.m_tag);
    payloadType = editor.payloadType();
    editor.insert(time, payloadId);
    cond::UserLogInfo a = this->lookUpUserLogInfo(myrecord.m_idName);
    editor.flush(a.usertext);
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::appendSinceTime");
  }
  return true;
}

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

appendSinceTime() [3/3]

template<typename T >

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

inline

Definition at line 141 of file PoolDBOutputService.h.

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

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

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

beginOfTime()

cond::Time_t PoolDBOutputService::beginOfTime

(

)

const

Definition at line 215 of file PoolDBOutputService.cc.

{ return timeTypeSpecs[m_timetype].beginValue; }

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

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

closeIOV()

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

Definition at line 346 of file PoolDBOutputService.cc.

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

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

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

commitTransaction()

void PoolDBOutputService::commitTransaction

(

)

Definition at line 152 of file PoolDBOutputService.cc.

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

References CommonMethods::lock().

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

createNewIOV() [1/3]

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

Definition at line 222 of file PoolDBOutputService.cc.

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

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

createNewIOV() [2/3]

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

private

Definition at line 249 of file PoolDBOutputService.cc.

                                                                        {
  m_logger.logInfo() << "Creating new tag " << myrecord.m_tag << " for payload type " << payloadType
                     << ", adding iov with since " << firstSinceTime;
  // FIX ME: synchronization type and description have to be passed as the other parameters?
  cond::persistency::IOVEditor editor =
      m_session.createIov(payloadType, myrecord.m_tag, myrecord.m_timetype, cond::SYNCH_ANY);
  editor.setDescription("New Tag");
  editor.insert(firstSinceTime, firstPayloadId);
  cond::UserLogInfo a = this->lookUpUserLogInfo(myrecord.m_idName);
  editor.flush(a.usertext);
  myrecord.m_isNewTag = false;
}

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

createNewIOV() [3/3]

template<typename T >

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

inline

Definition at line 116 of file PoolDBOutputService.h.

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

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

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

currentTime()

cond::Time_t PoolDBOutputService::currentTime

(

)

const

Definition at line 217 of file PoolDBOutputService.cc.

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

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

Referenced by DBWriter::analyze(), SiStripNoisesBuilder::analyze(), L1MuonOverlapParamsDBProducer::analyze(), SiStripApvGainBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), WritePPSAlignmentConfig::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), BufferedBoostIODBWriter::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalSCDynamicDPhiParametersMaker::analyze(), EcalMustacheSCParametersMaker::analyze(), AlignPCLThresholdsWriter::analyze(), FFTJetCorrectorDBWriter::analyze(), BoostIODBWriter< DataType >::analyze(), SiStripApvGainRescaler::analyze(), SiPhase2OuterTrackerLorentzAngleWriter::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), SiStripFedCablingBuilder::beginRun(), SiStripBadStripFromQualityDBWriter::dqmEndJob(), ECALpedestalPCLHarvester::dqmEndJob(), PPSTimingCalibrationPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), CocoaDBMgr::DumpCocoaResults(), SurveyDBUploader::endJob(), BeamSpotWrite2DB::endJob(), Mixing2DB::endJob(), BeamSpotOnlineLegacyRcdWriter::endJob(), BeamSpotOnlineHLTRcdWriter::endJob(), SiStripFedCablingManipulator::endRun(), DummyCondDBWriter< TObject, TObjectO, TRecord >::endRun(), WriteCTPPSPixGainCalibrations::fillDB(), SiStripBadChannelBuilder::getNewObject(), popcon::L1RPCHwConfigSourceHandler::getNewObjects(), popcon::RPCEMapSourceHandler::getNewObjects(), MisalignedTrackerESProducer::produce(), MuonAlignment::saveCSCSurveyToDB(), MuonAlignment::saveCSCtoDB(), MuonAlignment::saveDTSurveyToDB(), MuonAlignment::saveDTtoDB(), MuonAlignment::saveGEMtoDB(), TrackerAlignment::saveToDB(), ConditionDBWriter< SiStripApvGain >::setTime(), CaloGeometryDBWriter::write(), WriteESAlignments::write(), BeamFitter::write2DB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

doCommitTransaction()

void PoolDBOutputService::doCommitTransaction ( )

private

Definition at line 140 of file PoolDBOutputService.cc.

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

Referenced by writeOne().

doStartTransaction()

void PoolDBOutputService::doStartTransaction ( )

private

Definition at line 133 of file PoolDBOutputService.cc.

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

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

endOfTime()

cond::Time_t PoolDBOutputService::endOfTime

(

)

const

Definition at line 213 of file PoolDBOutputService.cc.

{ return timeTypeSpecs[m_timetype].endValue; }

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

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

eraseSinceTime()

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

Definition at line 303 of file PoolDBOutputService.cc.

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

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

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

fillRecord()

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

private

Definition at line 20 of file PoolDBOutputService.cc.

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

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

forceInit()

void PoolDBOutputService::forceInit

(

)

Definition at line 201 of file PoolDBOutputService.cc.

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

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

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

getTagInfo()

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

private

Definition at line 375 of file PoolDBOutputService.cc.

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

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

Referenced by writeOne().

initDB()

void PoolDBOutputService::initDB ( )

private

Definition at line 157 of file PoolDBOutputService.cc.

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

Referenced by createNewIOV(), and writeOne().

isNewTagRequest()

bool PoolDBOutputService::isNewTagRequest

(

const std::string &

recordName

)

Definition at line 128 of file PoolDBOutputService.cc.

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

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

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

lockRecords()

void PoolDBOutputService::lockRecords

(

)

Definition at line 94 of file PoolDBOutputService.cc.

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

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

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

logger()

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

inline

Definition at line 195 of file PoolDBOutputService.h.

{ return m_logger; }

References m_logger.

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

lookUpRecord()

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

private

Definition at line 328 of file PoolDBOutputService.cc.

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

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

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

lookUpUserLogInfo()

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

private

Definition at line 338 of file PoolDBOutputService.cc.

                                                                                              {
  std::map<std::string, cond::UserLogInfo>::iterator it = m_logheaders.find(recordName);
  if (it == m_logheaders.end())
    throw cond::Exception("Log db was not set for record " + recordName +
                          " from PoolDBOutputService::lookUpUserLogInfo");
  return it->second;
}

References align_cfg::recordName.

newReadOnlySession()

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

Definition at line 85 of file PoolDBOutputService.cc.

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

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

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

postEndJob()

void PoolDBOutputService::postEndJob

(

)

Definition at line 171 of file PoolDBOutputService.cc.

{ commitTransaction(); }

postModuleEvent()

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

private

Definition at line 182 of file PoolDBOutputService.cc.

                                                                                         {
  s_streamIndex = -1;
}

References s_streamIndex.

preEventProcessing()

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

private

Definition at line 173 of file PoolDBOutputService.cc.

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

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

preGlobalBeginLumi()

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

private

Definition at line 193 of file PoolDBOutputService.cc.

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

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

preGlobalBeginRun()

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

private

Definition at line 187 of file PoolDBOutputService.cc.

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

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

preModuleEvent()

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

private

Definition at line 177 of file PoolDBOutputService.cc.

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

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

releaseLocks()

void PoolDBOutputService::releaseLocks

(

)

Definition at line 109 of file PoolDBOutputService.cc.

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

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

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

session()

cond::persistency::Session PoolDBOutputService::session

(

)

const

Definition at line 92 of file PoolDBOutputService.cc.

{ return m_session; }

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

setLogHeaderForRecord()

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

Definition at line 366 of file PoolDBOutputService.cc.

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

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

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

startTransaction()

void PoolDBOutputService::startTransaction

(

)

Definition at line 147 of file PoolDBOutputService.cc.

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

References CommonMethods::lock().

tag()

std::string PoolDBOutputService::tag

(

const std::string &

recordName

)

Definition at line 124 of file PoolDBOutputService.cc.

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

References align_cfg::recordName.

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

tagInfo()

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

Definition at line 397 of file PoolDBOutputService.cc.

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

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

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

writeOne()

template<typename T >

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

inline

Definition at line 63 of file PoolDBOutputService.h.

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

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

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

Member Data Documentation

m_autoCommit

bool cond::service::PoolDBOutputService::m_autoCommit

private

Definition at line 252 of file PoolDBOutputService.h.

Referenced by writeOne().

m_connection

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

private

Definition at line 249 of file PoolDBOutputService.h.

m_currentTimes

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

private

Definition at line 247 of file PoolDBOutputService.h.

m_dbInitialised

bool cond::service::PoolDBOutputService::m_dbInitialised

private

Definition at line 254 of file PoolDBOutputService.h.

m_logger

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

private

Definition at line 244 of file PoolDBOutputService.h.

Referenced by logger(), and writeOne().

m_logheaders

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

private

Definition at line 257 of file PoolDBOutputService.h.

Referenced by fillRecord().

m_mutex

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

private

Definition at line 245 of file PoolDBOutputService.h.

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

m_records

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

private

Definition at line 256 of file PoolDBOutputService.h.

Referenced by fillRecord().

m_session

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

private

Definition at line 250 of file PoolDBOutputService.h.

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

m_timetype

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

private

Definition at line 246 of file PoolDBOutputService.h.

m_transactionActive

bool cond::service::PoolDBOutputService::m_transactionActive

private

Definition at line 251 of file PoolDBOutputService.h.

m_writeTransactionDelay

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

private

Definition at line 253 of file PoolDBOutputService.h.

Referenced by writeOne().