|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
|
#include "CondTools/DQM/interface/DQMXMLFileSourceHandler.h"
#include "FWCore/MessageLogger/interface/MessageLogger.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/ParameterSet/interface/ParameterSetfwd.h"
#include <iostream>
#include <sstream>
#include <vector>
namespace popcon {
DQMXMLFileSourceHandler::DQMXMLFileSourceHandler(const edm::ParameterSet& pset)
: 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::~DQMXMLFileSourceHandler() {}
void DQMXMLFileSourceHandler::getNewObjects() {
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;
}
std::string DQMXMLFileSourceHandler::id() const { return m_name; }
} // namespace popcon
|