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 33 of file RunInfoUpdate.cc.

{}

Member Function Documentation

void RunInfoUpdate::appendNewRun

(

const RunInfo &

run

)

Definition at line 35 of file RunInfoUpdate.cc.

References cond::persistency::Session::editRunInfo(), 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 cond::persistency::IOVProxy::begin(), gather_cfg::cout, idDealer::editor, cond::persistency::Session::editRunInfo(), end, cond::persistency::IOVProxy::end(), cond::persistency::Session::fetchPayload(), cond::persistency::IOVProxy::find(), cond::persistency::RunInfoEditor::flush(), cond::persistency::RunInfoEditor::getLastInserted(), h, cond::persistency::RunInfoEditor::insert(), ntuplemaker::lastRun, m_dbSession, maxEntries, cond::persistency::Session::readIov(), and command_line::start.

                                                                                                                  {
  cond::persistency::RunInfoEditor editor;
  std::cout << "# Loading tag "<<sourceTag<<"..."<<std::endl;
  cond::persistency::IOVProxy runInfoTag = sourceSession.readIov( sourceTag, true );
  editor = m_dbSession.editRunInfo();
  cond::Time_t lastRun = editor.getLastInserted();
  std::cout <<"# Last run found in RunInfo db : "<<lastRun<<std::endl;
  cond::persistency::IOVProxy::Iterator it = runInfoTag.begin();
  if( lastRun>0 ){
    it = runInfoTag.find( lastRun+1 );
  }
  if( it == runInfoTag.end() || (*it).since==lastRun ){
    std::cout <<"# No more run found to be imported."<<std::endl;
    return 0;
  }
  size_t n_entries = 0;
  while( it != runInfoTag.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 21 of file RunInfoUpdate.h.

Referenced by appendNewRun(), and import().