cond::service::OnlineDBOutputService Class Reference

#include <OnlineDBOutputService.h>

Inheritance diagram for cond::service::OnlineDBOutputService:

Public Member Functions
	OnlineDBOutputService (const edm::ParameterSet &iConfig, edm::ActivityRegistry &iAR)
cond::Iov_t	preLoadIov (const std::string &recordName, cond::Time_t targetTime)
template<typename PayloadType >
bool	writeForNextLumisection (const PayloadType *payload, const std::string &recordName)
	~OnlineDBOutputService () override
Public Member Functions inherited from cond::service::PoolDBOutputService
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)
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 ()
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
cond::Time_t	getLastLumiProcessed ()
cond::persistency::Session	getReadOnlyCache (cond::Time_t targetTime)

Private Attributes
bool	m_debug
std::string	m_lastLumiFile
std::string	m_lastLumiUrl
size_t	m_latencyInLumisections
std::string	m_omsServiceUrl
std::string	m_preLoadConnectionString
cond::Time_t	m_runNumber

Detailed Description

Definition at line 30 of file OnlineDBOutputService.h.

Constructor & Destructor Documentation

OnlineDBOutputService()

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

Definition at line 80 of file OnlineDBOutputService.cc.

    : PoolDBOutputService(iConfig, iAR),
      m_runNumber(iConfig.getUntrackedParameter<unsigned long long>("runNumber", 0)),
      m_latencyInLumisections(iConfig.getUntrackedParameter<unsigned int>("latency", 1)),
      m_omsServiceUrl(iConfig.getUntrackedParameter<std::string>("omsServiceUrl", "")),
      m_lastLumiUrl(iConfig.getUntrackedParameter<std::string>("lastLumiUrl", "")),
      m_preLoadConnectionString(iConfig.getUntrackedParameter<std::string>("preLoadConnectionString", "")),
      m_debug(iConfig.getUntrackedParameter<bool>("debugLogging", false)) {
  if (m_omsServiceUrl.empty()) {
    if (!m_lastLumiUrl.empty()) {
      startTransaction();
      auto lastRun = PoolDBOutputService::session().getLastRun();
      if (lastRun.isOnGoing()) {
        m_runNumber = lastRun.run;
      }
    } else {
      m_lastLumiFile = iConfig.getUntrackedParameter<std::string>("lastLumiFile", "");
    }
  }
}

References cond::persistency::Session::getLastRun(), edm::ParameterSet::getUntrackedParameter(), SiStripBadComponentsDQMServiceTemplate_cfg::lastRun, m_lastLumiFile, m_lastLumiUrl, m_omsServiceUrl, m_runNumber, cond::service::PoolDBOutputService::session(), cond::service::PoolDBOutputService::startTransaction(), and AlCaHLTBitMon_QueryRunRegistry::string.

~OnlineDBOutputService()

OnlineDBOutputService::~OnlineDBOutputService ( )

override

Definition at line 102 of file OnlineDBOutputService.cc.

{}

Member Function Documentation

getLastLumiProcessed()

cond::Time_t OnlineDBOutputService::getLastLumiProcessed ( )

private

Definition at line 104 of file OnlineDBOutputService.cc.

                                                                  {
  cond::Time_t lastLumiProcessed = cond::time::MIN_VAL;
  std::string info("");
  if (!m_omsServiceUrl.empty()) {
    lastLumiProcessed = cond::getLastLumiFromOMS(m_omsServiceUrl);
    logger().logInfo() << "Last lumi: " << lastLumiProcessed
                       << " Current run: " << cond::time::unpack(lastLumiProcessed).first
                       << " lumi id:" << cond::time::unpack(lastLumiProcessed).second;
  } else {
    if (!m_lastLumiUrl.empty()) {
      std::string info("");
      if (!getInfoFromDAQ(m_lastLumiUrl, info))
        throw Exception("Can't get last Lumisection from DAQ.");
      unsigned int lastL = boost::lexical_cast<unsigned int>(info);
      lastLumiProcessed = cond::time::lumiTime(m_runNumber, lastL);
      logger().logInfo() << "Last lumi: " << lastLumiProcessed << " Current run: " << m_runNumber
                         << " lumi id:" << lastL;
    } else {
      if (m_lastLumiFile.empty()) {
        throw Exception("File name for last lumi has not been provided.");
      } else {
        lastLumiProcessed = cond::getLatestLumiFromFile(m_lastLumiFile);
        auto upkTime = cond::time::unpack(lastLumiProcessed);
        logger().logInfo() << "Last lumi: " << lastLumiProcessed << " Current run: " << upkTime.first
                           << " lumi id:" << upkTime.second;
      }
    }
  }
  return lastLumiProcessed;
}

References getInfoFromDAQ(), cond::getLastLumiFromOMS(), cond::getLatestLumiFromFile(), info(), fwlog::logger(), cond::time::lumiTime(), cond::time::MIN_VAL(), AlCaHLTBitMon_QueryRunRegistry::string, and cond::time::unpack().

Referenced by writeForNextLumisection().

getReadOnlyCache()

cond::persistency::Session OnlineDBOutputService::getReadOnlyCache ( cond::Time_t  targetTime )

private

Definition at line 145 of file OnlineDBOutputService.cc.

                                                                                               {
  return PoolDBOutputService::newReadOnlySession(m_preLoadConnectionString, std::to_string(targetTime));
}

References cond::service::PoolDBOutputService::newReadOnlySession().

preLoadIov()

cond::Iov_t OnlineDBOutputService::preLoadIov	(	const std::string &	recordName,
		cond::Time_t	targetTime
	)

Definition at line 135 of file OnlineDBOutputService.cc.

                                                                                                         {
  cond::persistency::Session session = getReadOnlyCache(targetTime);
  cond::persistency::TransactionScope transaction(session.transaction());
  transaction.start(true);
  cond::persistency::IOVProxy proxy = session.readIov(PoolDBOutputService::tag(recordName));
  auto iov = proxy.getInterval(targetTime);
  transaction.commit();
  return iov;
}

References cond::persistency::IOVProxy::getInterval(), cond::persistency::Session::readIov(), align_cfg::recordName, cond::persistency::TransactionScope::start(), cond::service::PoolDBOutputService::tag(), and cond::persistency::Session::transaction().

Referenced by writeForNextLumisection().

writeForNextLumisection()

template<typename PayloadType >

bool cond::service::OnlineDBOutputService::writeForNextLumisection ( const PayloadType *  payload, const std::string &  recordName  )

inline

Definition at line 40 of file OnlineDBOutputService.h.

                                                                                            {
        cond::Time_t targetTime = getLastLumiProcessed() + m_latencyInLumisections;
        auto t0 = std::chrono::high_resolution_clock::now();
        logger().logInfo() << "Updating lumisection " << targetTime;
        cond::Hash payloadId = PoolDBOutputService::writeOne<PayloadType>(payload, targetTime, recordName);
        bool ret = true;
        if (payloadId.empty()) {
          return false;
        }
        auto t1 = std::chrono::high_resolution_clock::now();
        auto w_lat = std::chrono::duration_cast<std::chrono::microseconds>(t1 - t0).count();
        logger().logInfo() << "Update has taken " << w_lat << " microsecs.";
        // check for late updates...
        cond::Time_t lastProcessed = getLastLumiProcessed();
        logger().logInfo() << "Last lumisection processed after update: " << lastProcessed;
        // check the pre-loaded iov
        logger().logInfo() << "Preloading lumisection " << targetTime;
        auto t2 = std::chrono::high_resolution_clock::now();
        cond::Iov_t usedIov = preLoadIov(recordName, targetTime);
        auto t3 = std::chrono::high_resolution_clock::now();
        logger().logInfo() << "Iov for preloaded lumisection " << targetTime << " is " << usedIov.since;
        auto p_lat = std::chrono::duration_cast<std::chrono::microseconds>(t3 - t2).count();
        logger().logInfo() << "Preload has taken " << p_lat << " microsecs.";
        if (usedIov.since < targetTime) {
          logger().logWarning() << "Found a late update for lumisection " << targetTime << "(found since "
                                << usedIov.since << "). A revert is required.";
          PoolDBOutputService::eraseSinceTime(payloadId, targetTime, recordName);
          PoolDBOutputService::commitTransaction();
          ret = false;
        }
        auto t4 = std::chrono::high_resolution_clock::now();
        auto t_lat = std::chrono::duration_cast<std::chrono::microseconds>(t4 - t0).count();
        logger().logInfo() << "Total update time: " << t_lat << " microsecs.";
        return ret;
      }

References cond::service::PoolDBOutputService::commitTransaction(), cond::service::PoolDBOutputService::eraseSinceTime(), getLastLumiProcessed(), cond::service::PoolDBOutputService::logger(), cond::persistency::Logger::logInfo(), cond::persistency::Logger::logWarning(), m_latencyInLumisections, fileCollector::now, jets_cff::payload, preLoadIov(), align_cfg::recordName, runTheMatrix::ret, cond::Iov_t::since, FrontierCondition_GT_autoExpress_cfi::t0, RandomServiceHelper::t1, RandomServiceHelper::t2, and RandomServiceHelper::t3.

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

Member Data Documentation

m_debug

bool cond::service::OnlineDBOutputService::m_debug

private

Definition at line 88 of file OnlineDBOutputService.h.

m_lastLumiFile

std::string cond::service::OnlineDBOutputService::m_lastLumiFile

private

Definition at line 86 of file OnlineDBOutputService.h.

Referenced by OnlineDBOutputService().

m_lastLumiUrl

std::string cond::service::OnlineDBOutputService::m_lastLumiUrl

private

Definition at line 85 of file OnlineDBOutputService.h.

Referenced by OnlineDBOutputService().

m_latencyInLumisections

size_t cond::service::OnlineDBOutputService::m_latencyInLumisections

private

Definition at line 83 of file OnlineDBOutputService.h.

Referenced by writeForNextLumisection().

m_omsServiceUrl

std::string cond::service::OnlineDBOutputService::m_omsServiceUrl

private

Definition at line 84 of file OnlineDBOutputService.h.

Referenced by OnlineDBOutputService().

m_preLoadConnectionString

std::string cond::service::OnlineDBOutputService::m_preLoadConnectionString

private

Definition at line 87 of file OnlineDBOutputService.h.

m_runNumber

cond::Time_t cond::service::OnlineDBOutputService::m_runNumber

private

Definition at line 82 of file OnlineDBOutputService.h.

Referenced by OnlineDBOutputService().