#include <DQMXMLFileSourceHandler.h>

Inheritance diagram for popcon::DQMXMLFileSourceHandler:

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

void	getNewObjects () override

std::string	id () const override

	~DQMXMLFileSourceHandler () override

Public Member Functions inherited from popcon::PopConSourceHandler< FileBlob >
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
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::map< Time_t, std::shared_ptr< FileBlob > >	Container

typedef std::unique_ptr< FileBlob >	Ref

typedef PopConSourceHandler< FileBlob >	self

typedef cond::Time_t	Time_t

typedef FileBlob	value_type

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

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

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

std::string	m_userTextLog

Detailed Description

Definition at line 11 of file DQMXMLFileSourceHandler.h.

Constructor & Destructor Documentation

◆ DQMXMLFileSourceHandler()

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

Definition at line 10 of file DQMXMLFileSourceHandler.cc.

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

◆ ~DQMXMLFileSourceHandler()

popcon::DQMXMLFileSourceHandler::~DQMXMLFileSourceHandler ( )

override

Definition at line 17 of file DQMXMLFileSourceHandler.cc.

17 {}

Member Function Documentation

◆ getNewObjects()

void popcon::DQMXMLFileSourceHandler::getNewObjects ( )

overridevirtual

Implements popcon::PopConSourceHandler< FileBlob >.

Definition at line 19 of file DQMXMLFileSourceHandler.cc.

                                               {
     edm::LogInfo("DQMXMLFileSourceHandler")
         << "[DQMXMLFileSourceHandler::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"
            << "last object valid since " << this->tagInfo().lastInterval.since << ",\n token "
            << this->tagInfo().lastInterval.payloadId << ",\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("DQMXMLFileSourceHandler") << ss.str();
     }
     edm::LogInfo("DQMXMLFileSourceHandler") << "runnumber/first since = " << m_since << std::endl;
     if (this->tagInfo().size > 0 && m_since <= this->tagInfo().lastInterval.since) {
       edm::LogInfo("DQMXMLFileSourceHandler")
           << "[DQMXMLFileSourceHandler::getNewObjects] \nthe current starting iov " << m_since
           << "\nis not compatible with the last iov (" << this->tagInfo().lastInterval.since << ") open for the object "
           << this->logDBEntry().payloadClass << " \nin the db " << this->logDBEntry().destinationDB
           << " \n NO TRANSFER NEEDED" << std::endl;
       return;
     }
     edm::LogInfo("DQMXMLFileSourceHandler")
         << "[DQMXMLFileSourceHandler::getNewObjects] " << m_name << " getting data to be transferred " << std::endl;
     FileBlob* XMLFile = 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 (XMLFile->size() != 0) {
       edm::LogInfo("DQMXMLFileSourceHandler") << "setting runnumber/first since = " << m_since << std::endl;
       this->m_to_transfer.push_back(std::make_pair(XMLFile, m_since));
     } else {
       edm::LogError("DQMSummarySourceHandler") << "XML file " << m_file << " does not exist" << std::endl;
       delete XMLFile;
     }
     edm::LogInfo("DQMSummarySourceHandler") << "------- " << m_name << " - > getNewObjects" << std::endl;
   }