RunInfoUpdate Class Reference

#include <RunInfoUpdate.h>

Public Member Functions
void	appendNewRun (const RunInfo &run)
size_t	import (size_t maxEntries, const std::string &tag, cond::persistency::Session &sourceSession)
	RunInfoUpdate (cond::persistency::Session &dbSession)
	~RunInfoUpdate ()

Private Attributes
cond::persistency::Session &	m_dbSession

Detailed Description

Definition at line 12 of file RunInfoUpdate.h.

Constructor & Destructor Documentation

RunInfoUpdate::RunInfoUpdate ( cond::persistency::Session &  dbSession )

explicit

Definition at line 29 of file RunInfoUpdate.cc.

: m_dbSession(dbSession) {}

RunInfoUpdate::~RunInfoUpdate

(

)

Definition at line 31 of file RunInfoUpdate.cc.

{}

Member Function Documentation

void RunInfoUpdate::appendNewRun

(

const RunInfo &

run

)

Definition at line 33 of file RunInfoUpdate.cc.

References cond::persistency::Session::editRunInfo(), dataset::end, cond::persistency::RunInfoEditor::flush(), cond::persistency::RunInfoEditor::insertNew(), m_dbSession, RunInfo::m_run, and command_line::start.

Referenced by RunInfoHandler::getNewObjects().

                                                       {
  cond::persistency::RunInfoEditor runInfoWriter = m_dbSession.editRunInfo();
  boost::posix_time::ptime start;
  boost::posix_time::ptime end;
  getRunTimeParams(runInfo, start, end);
  edm::LogInfo("RunInfoUpdate") << "[RunInfoUpdate::" << __func__ << "]: Checking run " << runInfo.m_run
                                << " for insertion in Condition DB" << std::endl;
  runInfoWriter.insertNew(runInfo.m_run, start, end);
  size_t newRuns = runInfoWriter.flush();
  edm::LogInfo("RunInfoUpdate") << "[RunInfoUpdate::" << __func__ << "]: " << newRuns << " new run(s) inserted."
                                << std::endl;
}

size_t RunInfoUpdate::import	(	size_t	maxEntries,
		const std::string &	tag,
		cond::persistency::Session &	sourceSession
	)

Definition at line 47 of file RunInfoUpdate.cc.

References gather_cfg::cout, cond::persistency::Session::editRunInfo(), dataset::end, cond::persistency::Session::fetchPayload(), cond::persistency::RunInfoEditor::flush(), cond::persistency::RunInfoEditor::getLastInserted(), h, cond::persistency::RunInfoEditor::insert(), run_AlCaRecoTriggerBitsUpdateWorkflow::iovs, MergeJob_cfg::lastRun, m_dbSession, cond::persistency::Session::readIov(), cond::persistency::IOVProxy::selectAll(), and command_line::start.

                                                                    {
  cond::persistency::RunInfoEditor editor;
  std::cout << "# Loading tag " << sourceTag << "..." << std::endl;
  cond::persistency::IOVProxy runInfoTag = sourceSession.readIov(sourceTag);
  auto iovs = runInfoTag.selectAll();
  editor = m_dbSession.editRunInfo();
  cond::Time_t lastRun = editor.getLastInserted();
  std::cout << "# Last run found in RunInfo db : " << lastRun << std::endl;
  auto it = iovs.begin();
  if (lastRun > 0) {
    it = iovs.find(lastRun + 1);
  }
  if (it == iovs.end() || (*it).since == lastRun) {
    std::cout << "# No more run found to be imported." << std::endl;
    return 0;
  }
  size_t n_entries = 0;
  while (it != iovs.end() && n_entries <= maxEntries) {
    auto h = (*it).payloadId;
    std::shared_ptr<RunInfo> runInfo = sourceSession.fetchPayload<RunInfo>(h);
    if (runInfo->m_run != -1) {
      n_entries++;
      std::cout << "# Inserting run #" << runInfo->m_run << " (from since=" << (*it).since << ")" << std::endl;
      boost::posix_time::ptime start;
      boost::posix_time::ptime end;
      getRunTimeParams(*runInfo, start, end);
      editor.insert(runInfo->m_run, start, end);
    } else {
      std::cout << "# Skipping fake run #" << std::endl;
    }
    it++;
  }
  editor.flush();
  return n_entries;
}

Member Data Documentation

cond::persistency::Session& RunInfoUpdate::m_dbSession

private

Definition at line 22 of file RunInfoUpdate.h.

Referenced by appendNewRun(), and import().