#include <DTLVStatusHandler.h>

Inheritance diagram for DTLVStatusHandler:

Public Member Functions
	DTLVStatusHandler (const edm::ParameterSet &ps)

void	getNewObjects () override

std::string	id () const override

	~DTLVStatusHandler () override

Public Member Functions inherited from popcon::PopConSourceHandler< DTLVStatus >
void	initialize (const cond::persistency::Session &dbSession, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry)

Ref	lastPayload () const

cond::LogDBEntry_t const &	logDBEntry () const

std::pair< Container const *, std::string const >	operator() (const cond::persistency::Session &session, cond::TagInfo_t const &tagInfo, cond::LogDBEntry_t const &logDBEntry) const

	PopConSourceHandler ()

Container const &	returnData ()

cond::TagInfo_t const &	tagInfo () const

std::string const &	userTextLog () const

virtual	~PopConSourceHandler ()

Private Attributes
cond::persistency::Session	buff_session

std::string	bufferConnect

DTLVStatus *	ccbStatus

std::string	dataTag

cond::persistency::Session	omds_session

std::string	onlineAuthentication

std::string	onlineConnect

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< DTLVStatus >
typedef std::map< Time_t, std::shared_ptr< DTLVStatus > >	Container

typedef std::unique_ptr < DTLVStatus >	Ref

typedef PopConSourceHandler < DTLVStatus >	self

typedef cond::Time_t	Time_t

typedef DTLVStatus	value_type

Protected Member Functions inherited from popcon::PopConSourceHandler< DTLVStatus >
cond::persistency::Session &	dbSession () const

Protected Attributes inherited from popcon::PopConSourceHandler< DTLVStatus >
Container	m_iovs

std::vector< std::pair < DTLVStatus *, Time_t > >	m_to_transfer

std::string	m_userTextLog

Detailed Description

Description: Class to copy CCB DCS-status via PopCon

Date:: 2010/07/21 16:06:53

Revision:: 1.2

Author: Paolo Ronchese INFN Padova

Definition at line 35 of file DTLVStatusHandler.h.

Constructor & Destructor Documentation

DTLVStatusHandler::DTLVStatusHandler ( const edm::ParameterSet & ps )

Constructor

Definition at line 41 of file DTLVStatusHandler.cc.

References gather_cfg::cout.

     : dataTag(ps.getParameter<std::string>("tag")),
       onlineConnect(ps.getParameter<std::string>("onlineDB")),
       onlineAuthentication(ps.getParameter<std::string>("onlineAuthentication")),
       bufferConnect(ps.getParameter<std::string>("bufferDB")),
       omds_session(),
       buff_session() {
   std::cout << " PopCon application for DT DCS data (CCB status) export " << std::endl;
 }

DTLVStatusHandler::~DTLVStatusHandler ( )

override

Destructor

Definition at line 54 of file DTLVStatusHandler.cc.

54 {}

Member Function Documentation

void DTLVStatusHandler::getNewObjects ( )

overridevirtual

Operations

Implements popcon::PopConSourceHandler< DTLVStatus >.

Definition at line 59 of file DTLVStatusHandler.cc.

References buff_session, bufferConnect, cond::persistency::Session::close(), cond::persistency::Transaction::commit(), cond::persistency::ConnectionPool::configure(), gather_cfg::cout, cond::persistency::ConnectionPool::createSession(), dataTag, dqmdumpme::last, cond::TagInfo_t::lastInterval, MergeJob_cfg::lastRun, popcon::PopConSourceHandler< DTLVStatus >::m_to_transfer, omds_session, onlineAuthentication, onlineConnect, cond::persistency::ConnectionPool::setAuthenticationPath(), cond::Iov_t::since, cond::persistency::Transaction::start(), popcon::PopConSourceHandler< DTLVStatus >::tagInfo(), and cond::persistency::Session::transaction().

                                       {
   // online DB connection
   std::cout << "configure omds DbConnection" << std::endl;
   cond::persistency::ConnectionPool connection;
   connection.setAuthenticationPath(onlineAuthentication);
   connection.configure();
   std::cout << "create omds DbSession" << std::endl;
   omds_session = connection.createSession(onlineConnect);
   std::cout << "start omds transaction" << std::endl;
   omds_session.transaction().start();
   std::cout << "" << std::endl;
 
   // buffer DB connection
   std::cout << "create buffer DbSession" << std::endl;
   cond::persistency::Session buff_session = connection.createSession(bufferConnect);
   std::cout << "start buffer transaction" << std::endl;
   buff_session.transaction().start();
 
   // offline info
 
   //to access the information on the tag inside the offline database:
   cond::TagInfo_t const& ti = tagInfo();
   cond::Time_t last = ti.lastInterval.since;
   std::cout << "latest DCS data (CCB status) already copied for run: " << last << std::endl;
 
   if (last == 0) {
     DTLVStatus* dummyConf = new DTLVStatus(dataTag);
     cond::Time_t snc = 1;
     m_to_transfer.push_back(std::make_pair(dummyConf, snc));
   }
 
   //to access the information on last successful log entry for this tag:
   //  cond::LogDBEntry const & lde = logDBEntry();
 
   //to access the lastest payload (Ref is a smart pointer)
   //  Ref payload = lastPayload();
 
   unsigned lastRun = last;
   std::cout << "check for new runs since " << lastRun << std::endl;
 
   buff_session.transaction().commit();
   buff_session.close();
   omds_session.close();
 
   return;
 }