|
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
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
|
#include "DQMServices/Core/interface/DQMEDHarvester.h"
#include "FWCore/Version/interface/GetReleaseVersion.h"
class DQMHarvestingMetadata : public DQMEDHarvester {
public:
/// Constructor
DQMHarvestingMetadata(const edm::ParameterSet& ps);
/// Destructor
~DQMHarvestingMetadata() override;
protected:
/// Analyze
void dqmEndRun(DQMStore::IBooker& ibooker,
DQMStore::IGetter& igetter,
edm::Run const& iRun,
edm::EventSetup const& /* iSetup */) override;
void dqmEndLuminosityBlock(DQMStore::IBooker& ibooker,
DQMStore::IGetter& igetter,
edm::LuminosityBlock const& iLumi,
edm::EventSetup const& /* iSetup */) override;
void dqmEndJob(DQMStore::IBooker&, DQMStore::IGetter&) override {}
private:
std::string eventInfoFolder_;
std::string subsystemname_;
MonitorElement* runId_;
MonitorElement* runList_;
MonitorElement* runStartTimeStamp_; ///UTC time of the run start
MonitorElement* lumisecId_;
MonitorElement* firstLumisecId_;
MonitorElement* lastLumisecId_;
MonitorElement* processTimeStamp_; ///The UTC time of the job initialization
MonitorElement* hostName_; ///Hostname of the local machine
MonitorElement* workingDir_; ///Current working directory of the job
MonitorElement* cmsswVer_; ///CMSSW version run for this job
double currentTime_;
};
static inline double stampToReal(edm::Timestamp time) {
return (time.value() >> 32) + 1e-6 * (time.value() & 0xffffffff);
}
static inline double stampToReal(const timeval& time) { return time.tv_sec + 1e-6 * time.tv_usec; }
DQMHarvestingMetadata::DQMHarvestingMetadata(const edm::ParameterSet& ps) {
struct timeval now;
gettimeofday(&now, nullptr);
currentTime_ = stampToReal(now);
// read config parms
std::string folder = ps.getUntrackedParameter<std::string>("eventInfoFolder", "EventInfo");
subsystemname_ = ps.getUntrackedParameter<std::string>("subSystemFolder", "YourSubsystem");
eventInfoFolder_ = subsystemname_ + "/" + folder;
}
DQMHarvestingMetadata::~DQMHarvestingMetadata() = default;
void DQMHarvestingMetadata::dqmEndRun(DQMStore::IBooker& ibooker,
DQMStore::IGetter& igetter,
edm::Run const& iRun,
edm::EventSetup const& /* iSetup */) {
ibooker.setCurrentFolder(eventInfoFolder_);
runList_ = ibooker.bookString("Run", "");
runId_ = ibooker.bookInt("iRun");
runStartTimeStamp_ = ibooker.bookFloat("runStartTimeStamp");
if (runList_->getStringValue().empty()) {
std::string run = std::to_string(iRun.id().run());
runList_->Fill(run);
runId_->Fill(iRun.id().run());
// in case of multiple runs, record start time of the first.
runStartTimeStamp_->Fill(stampToReal(iRun.beginTime()));
} else {
std::string run = runList_->getStringValue() + "," + std::to_string(iRun.id().run());
runList_->Fill(run);
// this is the agreed-upon pseudo-runnumber for multi-run harvesting.
runId_->Fill(999999);
}
processTimeStamp_ = ibooker.bookFloat("processTimeStamp");
processTimeStamp_->Fill(currentTime_);
char hostname[65];
gethostname(hostname, 64);
hostname[64] = 0;
hostName_ = ibooker.bookString("hostName", hostname);
char* pwd = getcwd(nullptr, 0);
workingDir_ = ibooker.bookString("workingDir", pwd);
free(pwd);
cmsswVer_ = ibooker.bookString("CMSSW_Version", edm::getReleaseVersion());
}
void DQMHarvestingMetadata::dqmEndLuminosityBlock(DQMStore::IBooker& ibooker,
DQMStore::IGetter& igetter,
edm::LuminosityBlock const& iLumi,
edm::EventSetup const& /* iSetup */) {
int lumi = iLumi.luminosityBlock();
ibooker.setCurrentFolder(eventInfoFolder_);
firstLumisecId_ = ibooker.bookInt("firstLumiSection");
lastLumisecId_ = ibooker.bookInt("lastLumiSection");
lumisecId_ = ibooker.bookInt("iLumiSection");
lumisecId_->Fill(lumi);
if (firstLumisecId_->getIntValue() == 0 || firstLumisecId_->getIntValue() > lumi) {
firstLumisecId_->Fill(lumi);
}
if (lastLumisecId_->getIntValue() == 0 || lastLumisecId_->getIntValue() > lumi) {
lastLumisecId_->Fill(lumi);
}
}
#include "FWCore/Framework/interface/MakerMacros.h"
DEFINE_FWK_MODULE(DQMHarvestingMetadata);
|