#include <DQMReferenceHistogramRootFileSourceHandler.h>

Inheritance diagram for popcon::DQMReferenceHistogramRootFileSourceHandler:

Public Member Functions
	DQMReferenceHistogramRootFileSourceHandler (const edm::ParameterSet &pset)

void	getNewObjects ()

std::string	id () const

	~DQMReferenceHistogramRootFileSourceHandler ()

Public Member Functions inherited from popcon::PopConSourceHandler< FileBlob >
void	convertFromOld ()

Summary *	dummySummary (typename OldContainer::value_type const &) const

void	initialize (cond::DbSession dbSession, cond::TagInfo const &tagInfo, cond::LogDBEntry const &logDBEntry)

Ref	lastPayload () const

cond::LogDBEntry const &	logDBEntry () const

std::pair< Container const *, std::string const >	operator() (cond::DbSession session, cond::TagInfo const &tagInfo, cond::LogDBEntry const &logDBEntry) const

	PopConSourceHandler ()

Container const &	returnData ()

void	sort ()

cond::TagInfo const &	tagInfo () const

std::string const &	userTextLog () const

virtual	~PopConSourceHandler ()

Private Attributes
bool	m_debugMode

std::string	m_file

std::string	m_name

unsigned long long	m_since

bool	m_zip

Additional Inherited Members
Public Types inherited from popcon::PopConSourceHandler< FileBlob >
typedef std::vector< Triplet >	Container

typedef std::vector< std::pair < FileBlob *, cond::Time_t > >	OldContainer

typedef PopConSourceHandler < FileBlob >	self

typedef cond::Summary	Summary

typedef cond::Time_t	Time_t

typedef FileBlob	value_type

Protected Member Functions inherited from popcon::PopConSourceHandler< FileBlob >
int	add (value_type payload, Summary summary, Time_t time)

Protected Attributes inherited from popcon::PopConSourceHandler< FileBlob >
OldContainer	m_to_transfer

std::string	m_userTextLog

Detailed Description

Definition at line 11 of file DQMReferenceHistogramRootFileSourceHandler.h.

Constructor & Destructor Documentation

popcon::DQMReferenceHistogramRootFileSourceHandler::DQMReferenceHistogramRootFileSourceHandler ( const edm::ParameterSet & pset )

Definition at line 10 of file DQMReferenceHistogramRootFileSourceHandler.cc.

                                                                                                                     :
     m_name(pset.getUntrackedParameter<std::string>("name","DQMReferenceHistogramRootFileSourceHandler")),
     m_file(pset.getUntrackedParameter<std::string>("ROOTFile","./file.root")),
     m_zip(pset.getUntrackedParameter<bool>("zip",false)),
     m_since(pset.getUntrackedParameter<unsigned long long>("firstSince",1)),
     m_debugMode(pset.getUntrackedParameter<bool>("debug",false)) {
   }

popcon::DQMReferenceHistogramRootFileSourceHandler::~DQMReferenceHistogramRootFileSourceHandler ( )

Definition at line 18 of file DQMReferenceHistogramRootFileSourceHandler.cc.

18 {}

Member Function Documentation

void popcon::DQMReferenceHistogramRootFileSourceHandler::getNewObjects ( )

virtual

Implements popcon::PopConSourceHandler< FileBlob >.

Definition at line 20 of file DQMReferenceHistogramRootFileSourceHandler.cc.

                                                                  {
     edm::LogInfo("DQMReferenceHistogramRootFileSourceHandler") << "[DQMReferenceHistogramRootFileSourceHandler::getNewObjects] for PopCon application " << m_name;
     if(m_debugMode){
     std::stringstream ss;
     ss << "\n------- " << m_name 
        << " - > getNewObjects\n";
     if (this->tagInfo().size > 0){
       //check what is already inside of the database
       ss << "\ngot offlineInfo "<< this->tagInfo().name 
          << ",\n size " << this->tagInfo().size 
          << ",\n" << this->tagInfo().token 
          << ",\n last object valid since " << this->tagInfo().lastInterval.first 
          << ",\n token " << this->tagInfo().lastPayloadToken 
          << ",\n UserText " << this->userTextLog()
          << ";\n last entry info regarding the payload (if existing):" 
          << ",\n logId"<<this->logDBEntry().logId 
          << ",\n last record with the correct tag (if existing) has been written in the db " << this->logDBEntry().destinationDB
          << ",\n provenance " << this->logDBEntry().provenance
          << ",\n usertext " << this->logDBEntry().usertext
          << ",\n iovtag " << this->logDBEntry().iovtag
          << ",\n timetype " << this->logDBEntry().iovtimetype
          << ",\n payload index " << this->logDBEntry().payloadIdx
          << ",\n payload class " << this->logDBEntry().payloadClass 
          << ",\n payload token " << this->logDBEntry().payloadToken
          << ",\n execution time " << this->logDBEntry().exectime
          << ",\n execution message " << this->logDBEntry().execmessage
          << std::endl;
       Ref payload = this->lastPayload();
       ss << "size of last payload " << payload->size() << std::endl;
     } else {
       ss << " First object for this tag " << std::endl;
     }
     edm::LogInfo("DQMReferenceHistogramRootFileSourceHandler") << ss.str();
     }
     edm::LogInfo("DQMReferenceHistogramRootFileSourceHandler") << "runnumber/first since = " << m_since << std::endl;
     if(m_since<=this->tagInfo().lastInterval.first){
       edm::LogInfo("DQMReferenceHistogramRootFileSourceHandler") 
     << "[DQMReferenceHistogramRootFileSourceHandler::getNewObjects] \nthe current starting iov " << m_since
     << "\nis not compatible with the last iov ("  
     << this->tagInfo().lastInterval.first << ") open for the object " 
     << this->logDBEntry().payloadClass << " \nin the db " 
     << this->logDBEntry().destinationDB << " \n NO TRANSFER NEEDED"
     << std::endl;
       return;
       }
     edm::LogInfo("DQMReferenceHistogramRootFileSourceHandler") 
       << "[DQMReferenceHistogramRootFileSourceHandler::getNewObjects] " << m_name << " getting data to be transferred "  << std::endl;
     FileBlob* rootFile = new FileBlob(m_file,m_zip);
     /*if(!this->tagInfo().size)
       m_since=1;
     else
       if (m_debugMode)
       m_since=this->tagInfo().lastInterval.first+1; */
     if(rootFile->size() != 0){
       edm::LogInfo("DQMReferenceHistogramRootFileSourceHandler") << "setting runnumber/first since = " << m_since << std::endl;
       this->m_to_transfer.push_back(std::make_pair(rootFile,m_since));
     } else {
       edm::LogError("DQMSummarySourceHandler") << "Root file " << m_file << " does not exist" << std::endl;
     }
     edm::LogInfo("DQMSummarySourceHandler") << "------- " 
                         << m_name << " - > getNewObjects" 
                         << std::endl;
   }