cond::service::PoolDBOutputService Class Reference

#include <PoolDBOutputService.h>

Classes
struct	Record

Public Member Functions
template<typename T >
void	appendSinceTime (T *payloadObj, cond::Time_t sinceTime, const std::string &recordName, bool withlogging=false)
void	appendSinceTime (const std::string &payloadId, cond::Time_t sinceTime, const std::string &recordName, bool withlogging=false)
cond::Time_t	beginOfTime () const
void	closeIOV (Time_t lastTill, const std::string &recordName, bool withlogging=false)
template<typename T >
void	createNewIOV (T *firstPayloadObj, cond::Time_t firstSinceTime, cond::Time_t firstTillTime, const std::string &recordName, bool withlogging=false)
void	createNewIOV (const std::string &firstPayloadId, const std::string payloadType, cond::Time_t firstSinceTime, cond::Time_t firstTillTime, const std::string &recordName, bool withlogging=false)
void	createNewIOV (const std::string &firstPayloadId, cond::Time_t firstSinceTime, cond::Time_t firstTillTime, const std::string &recordName, bool withlogging=false)
cond::Time_t	currentTime () const
cond::Time_t	endOfTime () const
void	forceInit ()
bool	isNewTagRequest (const std::string &recordName)
	PoolDBOutputService (const edm::ParameterSet &iConfig, edm::ActivityRegistry &iAR)
void	postEndJob ()
cond::persistency::Session	session () const
void	setLogHeaderForRecord (const std::string &recordName, const std::string &provenance, const std::string &usertext)
std::string	tag (const std::string &recordName)
void	tagInfo (const std::string &recordName, cond::TagInfo_t &result)
template<typename T >
void	writeOne (T *payload, Time_t time, const std::string &recordName, bool withlogging=false)
virtual	~PoolDBOutputService ()

Private Member Functions
void	connect ()
void	disconnect ()
void	fillRecord (edm::ParameterSet &pset)
void	initDB (bool dummy=false)
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
std::map< std::string, Record >	m_callbacks
bool	m_closeIOV
std::vector< cond::Time_t >	m_currentTimes
bool	m_dbstarted
std::map< std::string, cond::UserLogInfo >	m_logheaders
std::recursive_mutex	m_mutex
std::vector< std::pair< std::string, std::string > >	m_newtags
cond::persistency::Session	m_session
cond::TimeType	m_timetype
std::string	m_timetypestr

Detailed Description

Definition at line 36 of file PoolDBOutputService.h.

Constructor & Destructor Documentation

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

Definition at line 38 of file PoolDBOutputService.cc.

References l1RCTOmdsFedVectorProducer_cfi::connectionString, fillRecord(), edm::ParameterSet::getParameter(), cond::lumiid, m_callbacks, m_closeIOV, m_currentTimes, m_dbstarted, m_logheaders, m_session, m_timetype, m_timetypestr, edm::service::SystemBounds::maxNumberOfStreams(), postEndJob(), postModuleEvent(), preEventProcessing(), preGlobalBeginLumi(), preGlobalBeginRun(), preModuleEvent(), cond::runnumber, s_streamIndex, cond::persistency::ConnectionPool::setParameters(), AlCaHLTBitMon_QueryRunRegistry::string, cond::timestamp, cond::time::timeTypeFromName(), and DBConfiguration_cff::toPut.

    : m_timetypestr(""),
      m_currentTimes{},
      m_session(),
      m_dbstarted(false),
      m_callbacks(),
      m_closeIOV(false),
      m_logheaders() {
  m_closeIOV = iConfig.getUntrackedParameter<bool>("closeIOV", m_closeIOV);

  m_timetypestr = iConfig.getUntrackedParameter<std::string>("timetype", "runnumber");
  m_timetype = cond::time::timeTypeFromName(m_timetypestr);

  edm::ParameterSet connectionPset = iConfig.getParameter<edm::ParameterSet>("DBParameters");
  cond::persistency::ConnectionPool connection;
  connection.setParameters(connectionPset);
  connection.configure();
  std::string connectionString = iConfig.getParameter<std::string>("connect");
  m_session = connection.createSession(connectionString, true);

  typedef std::vector<edm::ParameterSet> Parameters;
  Parameters toPut = iConfig.getParameter<Parameters>("toPut");
  for (Parameters::iterator itToPut = toPut.begin(); itToPut != toPut.end(); ++itToPut)
    fillRecord(*itToPut);

  iAR.watchPostEndJob(this, &cond::service::PoolDBOutputService::postEndJob);
  iAR.watchPreallocate(
      [this](edm::service::SystemBounds const& iBounds) { m_currentTimes.resize(iBounds.maxNumberOfStreams()); });
  if (m_timetype == cond::timestamp) {  //timestamp
    iAR.watchPreEvent(this, &cond::service::PoolDBOutputService::preEventProcessing);
    iAR.watchPreModuleEvent(this, &cond::service::PoolDBOutputService::preModuleEvent);
    iAR.watchPostModuleEvent(this, &cond::service::PoolDBOutputService::postModuleEvent);
  } else if (m_timetype == cond::runnumber) {  //runnumber
    //NOTE: this assumes only one run is being processed at a time.
    // This is true for 7_1_X but plan are to allow multiple in flight at a time
    s_streamIndex = 0;
    iAR.watchPreGlobalBeginRun(this, &cond::service::PoolDBOutputService::preGlobalBeginRun);
  } else if (m_timetype == cond::lumiid) {
    //NOTE: this assumes only one lumi is being processed at a time.
    // This is true for 7_1_X but plan are to allow multiple in flight at a time
    s_streamIndex = 0;
    iAR.watchPreGlobalBeginLumi(this, &cond::service::PoolDBOutputService::preGlobalBeginLumi);
  }
}

PoolDBOutputService::~PoolDBOutputService ( )

virtual

Definition at line 142 of file PoolDBOutputService.cc.

References m_dbstarted, m_session, cond::persistency::Transaction::rollback(), and cond::persistency::Session::transaction().

                                                     {
  if (m_dbstarted) {
    m_session.transaction().rollback();
  }
}

Member Function Documentation

template<typename T >

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

inline

Definition at line 107 of file PoolDBOutputService.h.

References align_cfg::recordName, mps_fire::result, AlCaHLTBitMon_QueryRunRegistry::string, dumpRecoGeometry_cfg::tagInfo, and cond::persistency::throwException().

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripNoisesBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstants::analyze(), WriteEcalMiscalibConstantsMC::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), BTagCalibrationDbCreator::beginJob(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload_IOV::beginJob(), JetCorrectorDBWriter::beginJob(), QGLikelihoodSystematicsDBWriter::beginJob(), QGLikelihoodDBWriter::beginJob(), SiStripFedCablingBuilder::beginRun(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), CentralityTableProducer::endJob(), StoreESCondition::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), HLTPrescaleRecorder::endRun(), SiStripBadChannelBuilder::getNewObject(), l1t::DataWriter::updateIOV(), l1t::DataWriterExt::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), and CaloGeometryDBWriter::writeIndexed().

                                                     {
        if (!payloadObj)
          throwException("Provided payload pointer is invalid.", "PoolDBOutputService::appendSinceTime");
        appendSinceTime(m_session.storePayload(*payloadObj), sinceTime, recordName, withlogging);
      }

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

Definition at line 224 of file PoolDBOutputService.cc.

References a, cond::persistency::Session::editIov(), cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), lookUpRecord(), lookUpUserLogInfo(), m_mutex, m_session, cond::persistency::IOVEditor::payloadType(), HLT_2018_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), cond::persistency::Session::transaction(), and cond::UserLogInfo::usertext.

                                                                           {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  cond::persistency::TransactionScope scope(m_session.transaction());
  Record& myrecord = this->lookUpRecord(recordName);
  if (myrecord.m_isNewTag) {
    cond::throwException(std::string("Cannot append to non-existing tag ") + myrecord.m_tag,
                         "PoolDBOutputService::appendSinceTime");
  }
  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(recordName);
    editor.flush(a.usertext);

  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::appendSinceTime");
  }
  scope.close();
}

cond::Time_t PoolDBOutputService::beginOfTime

(

)

const

Definition at line 156 of file PoolDBOutputService.cc.

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

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

{ return timeTypeSpecs[m_timetype].beginValue; }

void PoolDBOutputService::closeIOV	(	Time_t	lastTill,
		const std::string &	recordName,
		bool	withlogging = false
	)

Definition at line 277 of file PoolDBOutputService.cc.

References cond::persistency::Session::editIov(), cond::persistency::IOVEditor::flush(), CommonMethods::lock(), lookUpRecord(), cond::service::PoolDBOutputService::Record::m_isNewTag, m_mutex, m_session, cond::service::PoolDBOutputService::Record::m_tag, cond::persistency::IOVEditor::setEndOfValidity(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().

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

                                                                                                            {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  // not fully working.. not be used for now...
  Record& myrecord = lookUpRecord(recordName);
  cond::persistency::TransactionScope scope(m_session.transaction());

  if (myrecord.m_isNewTag) {
    cond::throwException(std::string("Cannot close non-existing tag ") + myrecord.m_tag,
                         "PoolDBOutputService::closeIOV");
  }
  cond::persistency::IOVEditor editor = m_session.editIov(myrecord.m_tag);
  editor.setEndOfValidity(lastTill);
  editor.flush("Tag closed.");
  scope.close();
}

void cond::service::PoolDBOutputService::connect ( )

private

Referenced by Vispa.Gui.ZoomableScrollArea.ZoomableScrollArea::__init__(), Vispa.Views.PropertyView.BooleanProperty::__init__(), Vispa.Gui.FindDialog.FindDialog::_addScript(), Vispa.Gui.FindDialog.FindDialog::_addStringProperty(), Vispa.Main.Application.Application::_connectSignals(), Vispa.Plugins.ConfigEditor.CodeTableView.CodeTableView::_createItem(), Vispa.Gui.BoxContentDialog.BoxContentDialog::addButton(), Vispa.Gui.ToolBoxContainer.ToolBoxContainer::addWidget(), Vispa.Views.PropertyView.PropertyView::append(), Vispa.Views.PropertyView.PropertyView::appendAddRow(), Vispa.Main.Application.Application::createAction(), Vispa.Views.PropertyView.TextEditWithButtonProperty::createButton(), Vispa.Views.LineDecayView.LineDecayView::createLineDecayContainer(), Vispa.Views.PropertyView.TextEditWithButtonProperty::createLineEdit(), Vispa.Views.LineDecayView.LineDecayContainer::createObject(), Vispa.Views.PropertyView.TextEditWithButtonProperty::createTextEdit(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController::filterDialog(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController::find(), Vispa.Gui.PortWidget.PortWidget::mouseMoveEvent(), Vispa.Views.PropertyView.BooleanProperty::setChecked(), Vispa.Main.SplitterTab.SplitterTab::setController(), Vispa.Plugins.Browser.BrowserTab.BrowserTab::setController(), Vispa.Views.PropertyView.BooleanProperty::setReadOnly(), Vispa.Views.PropertyView.DropDownProperty::setReadOnly(), Vispa.Views.PropertyView.TextEditWithButtonProperty::setReadOnly(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController::setTab(), Vispa.Views.PropertyView.IntegerProperty::setValue(), Vispa.Plugins.Browser.BrowserTabController.BrowserTabController::switchCenterView(), o2o_db_cfgmap.DbManagerDAQ::update_hashmap(), Vispa.Plugins.EdmBrowser.EdmBrowserTabController.EdmBrowserTabController::updateViewMenu(), and Vispa.Plugins.ConfigEditor.ConfigEditorTabController.ConfigEditorTabController::updateViewMenu().

template<typename T >

void cond::service::PoolDBOutputService::createNewIOV ( T *  firstPayloadObj, cond::Time_t  firstSinceTime, cond::Time_t  firstTillTime, const std::string &  recordName, bool  withlogging = false  )

inline

Definition at line 73 of file PoolDBOutputService.h.

References CommonMethods::lock(), HLT_2018_cff::payloadType, align_cfg::recordName, AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

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

                                                  {
        if (!firstPayloadObj)
          throwException("Provided payload pointer is invalid.", "PoolDBOutputService::createNewIOV");
        std::lock_guard<std::recursive_mutex> lock(m_mutex);
        if (!m_dbstarted)
          this->initDB();
        createNewIOV(m_session.storePayload(*firstPayloadObj),
                     cond::demangledName(typeid(T)),
                     firstSinceTime,
                     firstTillTime,
                     recordName,
                     withlogging);
      }

void PoolDBOutputService::createNewIOV	(	const std::string &	firstPayloadId,
		const std::string	payloadType,
		cond::Time_t	firstSinceTime,
		cond::Time_t	firstTillTime,
		const std::string &	recordName,
		bool	withlogging = false
	)

Definition at line 163 of file PoolDBOutputService.cc.

References a, cond::persistency::Session::createIov(), cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), lookUpRecord(), lookUpUserLogInfo(), m_mutex, m_session, cond::persistency::IOVEditor::setDescription(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::throwException(), cond::persistency::Session::transaction(), and cond::UserLogInfo::usertext.

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

  cond::persistency::TransactionScope scope(m_session.transaction());
  Record& myrecord = this->lookUpRecord(recordName);
  if (!myrecord.m_isNewTag) {
    cond::throwException(myrecord.m_tag + " is not a new tag", "PoolDBOutputService::createNewIOV");
  }
  std::string iovToken;

  try {
    // 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(recordName);
    editor.flush(a.usertext);
    myrecord.m_isNewTag = false;
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()) + " from PoolDBOutputService::createNewIOV ",
                         "PoolDBOutputService::createNewIOV");
  }
  scope.close();
}

void PoolDBOutputService::createNewIOV	(	const std::string &	firstPayloadId,
		cond::Time_t	firstSinceTime,
		cond::Time_t	firstTillTime,
		const std::string &	recordName,
		bool	withlogging = false
	)

Definition at line 194 of file PoolDBOutputService.cc.

References a, cond::persistency::Session::createIovForPayload(), cppFunctionSkipper::exception, cond::persistency::IOVEditor::flush(), cond::persistency::IOVEditor::insert(), CommonMethods::lock(), lookUpRecord(), lookUpUserLogInfo(), m_mutex, m_session, cond::persistency::IOVEditor::payloadType(), HLT_2018_cff::payloadType, cond::persistency::IOVEditor::setDescription(), AlCaHLTBitMon_QueryRunRegistry::string, cond::SYNCH_ANY, cond::throwException(), cond::persistency::Session::transaction(), and cond::UserLogInfo::usertext.

                                                                        {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  cond::persistency::TransactionScope scope(m_session.transaction());
  Record& myrecord = this->lookUpRecord(recordName);
  if (!myrecord.m_isNewTag) {
    cond::throwException(myrecord.m_tag + " is not a new tag", "PoolDBOutputService::createNewIOV");
  }
  std::string iovToken;
  std::string payloadType("");
  try {
    // FIX ME: synchronization type and description have to be passed as the other parameters?
    cond::persistency::IOVEditor editor =
        m_session.createIovForPayload(firstPayloadId, myrecord.m_tag, myrecord.m_timetype, cond::SYNCH_ANY);
    editor.setDescription("New Tag");
    payloadType = editor.payloadType();
    editor.insert(firstSinceTime, firstPayloadId);
    cond::UserLogInfo a = this->lookUpUserLogInfo(recordName);
    editor.flush(a.usertext);
    myrecord.m_isNewTag = false;
  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()) + " from PoolDBOutputService::createNewIOV ",
                         "PoolDBOutputService::createNewIOV");
  }
  scope.close();
}

cond::Time_t PoolDBOutputService::currentTime

(

)

const

Definition at line 158 of file PoolDBOutputService.cc.

References m_currentTimes, and s_streamIndex.

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripNoisesBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), L1MuonOverlapParamsDBProducer::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), PPSTimingCalibrationWriter::analyze(), BufferedBoostIODBWriter::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), AlignPCLThresholdsWriter::analyze(), FFTJetCorrectorDBWriter::analyze(), BoostIODBWriter< DataType >::analyze(), SiStripApvGainRescaler::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), JetResolutionDBWriter::beginJob(), SiStripFedCablingBuilder::beginRun(), ECALpedestalPCLHarvester::dqmEndJob(), SiStripGainsPCLHarvester::dqmEndJob(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), SurveyDBUploader::endJob(), Mixing2DB::endJob(), CentralityTableProducer::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(), TrackerAlignment::saveToDB(), ConditionDBWriter< SiStripApvGain >::setTime(), CaloGeometryDBWriter::write(), WriteESAlignments::write(), BeamFitter::write2DB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

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

void cond::service::PoolDBOutputService::disconnect ( )

private

Referenced by Vispa.Views.LineDecayView.LineDecayView::createLineDecayContainer(), Vispa.Views.PropertyView.BooleanProperty::setChecked(), Vispa.Views.PropertyView.BooleanProperty::setReadOnly(), Vispa.Views.PropertyView.DropDownProperty::setReadOnly(), Vispa.Views.PropertyView.TextEditWithButtonProperty::setReadOnly(), Vispa.Views.PropertyView.IntegerProperty::setValue(), Vispa.Plugins.EdmBrowser.EdmBrowserTabController.EdmBrowserTabController::updateViewMenu(), and Vispa.Plugins.ConfigEditor.ConfigEditorTabController.ConfigEditorTabController::updateViewMenu().

cond::Time_t PoolDBOutputService::endOfTime

(

)

const

Definition at line 154 of file PoolDBOutputService.cc.

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

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

{ return timeTypeSpecs[m_timetype].endValue; }

void PoolDBOutputService::fillRecord ( edm::ParameterSet &  pset )

private

Definition at line 21 of file PoolDBOutputService.cc.

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

Referenced by PoolDBOutputService().

                                                                     {
  Record thisrecord;

  thisrecord.m_idName = pset.getParameter<std::string>("record");
  thisrecord.m_tag = pset.getParameter<std::string>("tag");

  thisrecord.m_closeIOV = pset.getUntrackedParameter<bool>("closeIOV", m_closeIOV);

  thisrecord.m_timetype =
      cond::time::timeTypeFromName(pset.getUntrackedParameter<std::string>("timetype", m_timetypestr));

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

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

void PoolDBOutputService::forceInit

(

)

Definition at line 148 of file PoolDBOutputService.cc.

References initDB(), CommonMethods::lock(), m_dbstarted, and m_mutex.

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

                                               {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  if (!m_dbstarted)
    initDB();
}

void PoolDBOutputService::initDB ( bool  dummy = false )

private

Definition at line 94 of file PoolDBOutputService.cc.

References cond::persistency::Session::createDatabase(), cppFunctionSkipper::exception, cond::persistency::Session::existsDatabase(), CommonMethods::lock(), m_dbstarted, m_mutex, m_session, cond::persistency::TransactionScope::start(), AlCaHLTBitMon_QueryRunRegistry::string, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by forceInit(), and lookUpRecord().

                                                {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  cond::persistency::TransactionScope scope(m_session.transaction());
  scope.start(false);
  try {
    if (!m_session.existsDatabase())
      m_session.createDatabase();

  } catch (const std::exception& er) {
    cond::throwException(std::string(er.what()), "PoolDBOutputService::initDB");
  }
  scope.close();
  m_dbstarted = true;
}

bool PoolDBOutputService::isNewTagRequest

(

const std::string &

recordName

)

Definition at line 89 of file PoolDBOutputService.cc.

References lookUpRecord(), and cond::service::PoolDBOutputService::Record::m_isNewTag.

Referenced by SiStripApvSimulationParametersBuilder::analyze(), DBWriter::analyze(), SiStripNoisesBuilder::analyze(), SiStripDetVOffFakeBuilder::analyze(), SiStripPedestalsBuilder::analyze(), SiStripSummaryBuilder::analyze(), SiStripThresholdBuilder::analyze(), SiStripApvGainBuilder::analyze(), WriteEcalMiscalibConstantsMC::analyze(), WriteEcalMiscalibConstants::analyze(), SiStripNoiseNormalizedWithApvGainBuilder::analyze(), SiStripApvGainBuilderFromTag::analyze(), EcalTestDevDB::analyze(), BTagCalibrationDbCreator::beginJob(), PhysicsPerformanceDBWriterTFormula_fromfile_WPandPL::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload::beginJob(), PhysicsPerformanceDBWriterFromFile_WPandPayload_IOV::beginJob(), JetResolutionDBWriter::beginJob(), XMLGeometryBuilder::beginJob(), JetCorrectorDBWriter::beginJob(), QGLikelihoodSystematicsDBWriter::beginJob(), QGLikelihoodDBWriter::beginJob(), SiStripFedCablingBuilder::beginRun(), HcalParametersDBBuilder::beginRun(), PTrackerParametersDBBuilder::beginRun(), GEMRecoIdealDBLoader::beginRun(), ME0RecoIdealDBLoader::beginRun(), GeometricTimingDetLoader::beginRun(), GeometricDetLoader::beginRun(), DTRecoIdealDBLoader::beginRun(), CSCRecoIdealDBLoader::beginRun(), PGeometricDetExtraBuilder::beginRun(), PGeometricDetBuilder::beginRun(), PHGCalParametersDBBuilder::beginRun(), RPCRecoIdealDBLoader::beginRun(), CocoaDBMgr::DumpCocoaResults(), BeamSpotWrite2DB::endJob(), CentralityTableProducer::endJob(), StoreESCondition::endJob(), StoreEcalCondition::endJob(), SiStripFedCablingManipulator::endRun(), AlcaBeamSpotHarvester::endRun(), HLTPrescaleRecorder::endRun(), SiStripBadChannelBuilder::getNewObject(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), l1t::DataWriterExt::updateIOV(), l1t::DataWriter::updateIOV(), CaloGeometryDBWriter::write(), BeamFitter::write2DB(), AlCaRecoTriggerBitsRcdUpdate::writeBitsToDB(), CaloGeometryDBWriter::writeIndexed(), and DTCalibDBUtils::writeToDB().

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

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

private

Definition at line 249 of file PoolDBOutputService.cc.

References cond::persistency::Session::existsIov(), initDB(), CommonMethods::lock(), m_callbacks, m_dbstarted, m_mutex, m_session, cond::throwException(), and cond::persistency::Session::transaction().

Referenced by appendSinceTime(), closeIOV(), createNewIOV(), isNewTagRequest(), tag(), and tagInfo().

                                 {
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  if (!m_dbstarted)
    this->initDB();
  cond::persistency::TransactionScope scope(m_session.transaction());
  std::map<std::string, Record>::iterator it = m_callbacks.find(recordName);
  if (it == m_callbacks.end()) {
    cond::throwException("The record \"" + recordName + "\" has not been registered.",
                         "PoolDBOutputService::lookUpRecord");
  }
  if (!m_session.existsIov(it->second.m_tag)) {
    it->second.m_isNewTag = true;
  } else {
    it->second.m_isNewTag = false;
  }
  scope.close();
  return it->second;
}

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

private

Definition at line 269 of file PoolDBOutputService.cc.

References m_logheaders.

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

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

void PoolDBOutputService::postEndJob

(

)

Definition at line 109 of file PoolDBOutputService.cc.

References cond::persistency::Transaction::commit(), m_dbstarted, m_session, and cond::persistency::Session::transaction().

Referenced by PoolDBOutputService().

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

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

private

Definition at line 125 of file PoolDBOutputService.cc.

References s_streamIndex.

Referenced by PoolDBOutputService().

                                                                                         {
  s_streamIndex = -1;
}

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

private

Definition at line 116 of file PoolDBOutputService.cc.

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

Referenced by PoolDBOutputService().

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

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

private

Definition at line 136 of file PoolDBOutputService.cc.

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

Referenced by PoolDBOutputService().

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

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

private

Definition at line 130 of file PoolDBOutputService.cc.

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

Referenced by PoolDBOutputService().

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

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

private

Definition at line 120 of file PoolDBOutputService.cc.

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

Referenced by PoolDBOutputService().

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

cond::persistency::Session PoolDBOutputService::session

(

)

const

Definition at line 83 of file PoolDBOutputService.cc.

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

{ return m_session; }

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

Definition at line 293 of file PoolDBOutputService.cc.

References lookUpUserLogInfo(), cond::UserLogInfo::provenance, and cond::UserLogInfo::usertext.

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

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

std::string PoolDBOutputService::tag

(

const std::string &

recordName

)

Definition at line 85 of file PoolDBOutputService.cc.

References lookUpRecord(), and cond::service::PoolDBOutputService::Record::m_tag.

Referenced by PCLMetadataWriter::endRun(), popcon::PopCon::initialize(), l1t::DataWriter::payloadToken(), l1t::DataWriterExt::payloadToken(), l1t::DataWriter::updateIOV(), and l1t::DataWriterExt::updateIOV().

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

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

Definition at line 302 of file PoolDBOutputService.cc.

References cond::persistency::IOVProxy::getLast(), dqmdumpme::last, cond::TagInfo_t::lastInterval, cond::TagInfo_t::lastPayloadToken, CommonMethods::lock(), lookUpRecord(), m_mutex, m_session, cond::service::PoolDBOutputService::Record::m_tag, cond::TagInfo_t::name, cond::Iov_t::payloadId, cond::persistency::Session::readIov(), record, cond::persistency::IOVProxy::sequenceSize(), cond::Iov_t::since, cond::TagInfo_t::size, and cond::Iov_t::till.

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

                                                                                               {
  //
  std::lock_guard<std::recursive_mutex> lock(m_mutex);
  Record& record = lookUpRecord(recordName);
  result.name = record.m_tag;
  //use iovproxy to find out.
  cond::persistency::IOVProxy iov = m_session.readIov(record.m_tag);
  result.size = iov.sequenceSize();
  if (result.size > 0) {
    cond::Iov_t last = iov.getLast();
    result.lastInterval = cond::ValidityInterval(last.since, last.till);
    result.lastPayloadToken = last.payloadId;
  }
}

template<typename T >

void cond::service::PoolDBOutputService::writeOne ( T *  payload, Time_t  time, const std::string &  recordName, bool  withlogging = false  )

inline

Definition at line 53 of file PoolDBOutputService.h.

References CommonMethods::lock(), HLT_2018_cff::payloadType, AlCaHLTBitMon_QueryRunRegistry::string, and cond::persistency::throwException().

Referenced by EcalDQMStatusWriter::analyze(), L1MuonOverlapParamsDBProducer::analyze(), SurveyInputTrackerFromDB::analyze(), GBRForestWriter::analyze(), PPSTimingCalibrationWriter::analyze(), BufferedBoostIODBWriter::analyze(), TrackerSystematicMisalignments::analyze(), CTPPSRPAlignmentInfoAnalyzer::analyze(), WriteCTPPSPixelAnalysisMask::analyze(), WriteCTPPSPixelDAQMapping::analyze(), WriteCTPPSBeamParameters::analyze(), AlignPCLThresholdsWriter::analyze(), BoostIODBWriter< DataType >::analyze(), FFTJetCorrectorDBWriter::analyze(), SiStripApvGainRescaler::analyze(), SiStripChannelGainFromDBMiscalibrator::analyze(), SiStripNoisesFromDBMiscalibrator::analyze(), TrackerGeometryCompare::analyze(), MCMisalignmentScaler::analyze(), JetResolutionDBWriter::beginJob(), DTCCablingMapTestProducer::beginJob(), DTUserKeyedConfigHandler::chkConfigList(), DTKeyedConfigHandler::chkConfigList(), SiPixelStatusHarvester::constructTag(), EcalDBCopy::copyToDB(), ECALpedestalPCLHarvester::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(), MisalignedTrackerESProducer::produce(), MuonAlignment::saveCSCSurveyToDB(), MuonAlignment::saveCSCtoDB(), MuonAlignment::saveDTSurveyToDB(), MuonAlignment::saveDTtoDB(), TrackerAlignment::saveToDB(), MisalignedMuonESProducer::saveToDB(), ConditionDBWriter< SiStripApvGain >::storeOnDb(), WriteESAlignments::write(), AlignmentProducerBase::writeDB(), GlobalTrackerMuonAlignment::writeGlPosRcd(), popcon::PopCon::writeOne(), DTCalibDBUtils::writeToDB(), and CreateIdealTkAlRecords::writeToDB().

                                                                                                    {
        if (!payload)
          throwException("Provided payload pointer is invalid.", "PoolDBOutputService::writeOne");
        std::lock_guard<std::recursive_mutex> lock(m_mutex);
        if (!m_dbstarted)
          this->initDB();
        Hash payloadId = m_session.storePayload(*payload);
        std::string payloadType = cond::demangledName(typeid(T));
        if (isNewTagRequest(recordName)) {
          createNewIOV(payloadId, payloadType, time, endOfTime(), recordName, withlogging);
        } else {
          appendSinceTime(payloadId, time, recordName, withlogging);
        }
      }

Member Data Documentation

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

private

Definition at line 195 of file PoolDBOutputService.h.

Referenced by fillRecord(), lookUpRecord(), and PoolDBOutputService().

bool cond::service::PoolDBOutputService::m_closeIOV

private

Definition at line 197 of file PoolDBOutputService.h.

Referenced by fillRecord(), and PoolDBOutputService().

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

private

Definition at line 190 of file PoolDBOutputService.h.

Referenced by currentTime(), PoolDBOutputService(), preEventProcessing(), preGlobalBeginLumi(), and preGlobalBeginRun().

bool cond::service::PoolDBOutputService::m_dbstarted

private

Definition at line 193 of file PoolDBOutputService.h.

Referenced by forceInit(), initDB(), lookUpRecord(), PoolDBOutputService(), postEndJob(), and ~PoolDBOutputService().

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

private

Definition at line 198 of file PoolDBOutputService.h.

Referenced by fillRecord(), lookUpUserLogInfo(), and PoolDBOutputService().

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

private

Definition at line 187 of file PoolDBOutputService.h.

Referenced by appendSinceTime(), closeIOV(), createNewIOV(), forceInit(), initDB(), lookUpRecord(), and tagInfo().

std::vector<std::pair<std::string, std::string> > cond::service::PoolDBOutputService::m_newtags

private

Definition at line 196 of file PoolDBOutputService.h.

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

private

Definition at line 192 of file PoolDBOutputService.h.

Referenced by appendSinceTime(), closeIOV(), createNewIOV(), initDB(), lookUpRecord(), PoolDBOutputService(), postEndJob(), session(), tagInfo(), and ~PoolDBOutputService().

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

private

Definition at line 188 of file PoolDBOutputService.h.

Referenced by beginOfTime(), endOfTime(), and PoolDBOutputService().

std::string cond::service::PoolDBOutputService::m_timetypestr

private

Definition at line 189 of file PoolDBOutputService.h.

Referenced by fillRecord(), and PoolDBOutputService().