DTLVStatusHandler Class Reference

#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	convertFromOld ()
Summary *	dummySummary (typename OldContainer::value_type const &) const
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 ()
void	sort ()
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::vector< Triplet >	Container
typedef std::vector< std::pair< DTLVStatus *, cond::Time_t > >	OldContainer
typedef PopConSourceHandler< DTLVStatus >	self
typedef cond::Summary	Summary
typedef cond::Time_t	Time_t
typedef DTLVStatus	value_type
Protected Member Functions inherited from popcon::PopConSourceHandler< DTLVStatus >
int	add (value_type *payload, Summary *summary, Time_t time)
cond::persistency::Session &	dbSession () const
Protected Attributes inherited from popcon::PopConSourceHandler< DTLVStatus >
OldContainer	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::DTLVStatusHandler

(

const edm::ParameterSet &

ps

)

Constructor

Definition at line 41 of file DTLVStatusHandler.cc.

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

References gather_cfg::cout.

~DTLVStatusHandler()

DTLVStatusHandler::~DTLVStatusHandler ( )

override

Destructor

Definition at line 54 of file DTLVStatusHandler.cc.

{}

Member Function Documentation

getNewObjects()

void DTLVStatusHandler::getNewObjects ( )

overridevirtual

Operations

Implements popcon::PopConSourceHandler< DTLVStatus >.

Definition at line 59 of file DTLVStatusHandler.cc.

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

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, BeamSpotPI::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().

id()

std::string DTLVStatusHandler::id ( ) const

overridevirtual

Implements popcon::PopConSourceHandler< DTLVStatus >.

Definition at line 106 of file DTLVStatusHandler.cc.

{ return dataTag; }

References dataTag.

Member Data Documentation

buff_session

cond::persistency::Session DTLVStatusHandler::buff_session

private

Definition at line 59 of file DTLVStatusHandler.h.

Referenced by getNewObjects().

bufferConnect

std::string DTLVStatusHandler::bufferConnect

private

Definition at line 55 of file DTLVStatusHandler.h.

Referenced by getNewObjects().

ccbStatus

DTLVStatus* DTLVStatusHandler::ccbStatus

private

Definition at line 56 of file DTLVStatusHandler.h.

dataTag

std::string DTLVStatusHandler::dataTag

private

Definition at line 52 of file DTLVStatusHandler.h.

Referenced by getNewObjects(), and id().

omds_session

cond::persistency::Session DTLVStatusHandler::omds_session

private

Definition at line 58 of file DTLVStatusHandler.h.

Referenced by getNewObjects().

onlineAuthentication

std::string DTLVStatusHandler::onlineAuthentication

private

Definition at line 54 of file DTLVStatusHandler.h.

Referenced by getNewObjects().

onlineConnect

std::string DTLVStatusHandler::onlineConnect

private

Definition at line 53 of file DTLVStatusHandler.h.

Referenced by getNewObjects().