|
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
|
/*
* \file EcalBarrelMonitorDbModule.cc
*
* \author G. Della Ricca
*
*/
#include "DQM/EcalMonitorDbModule/interface/EcalBarrelMonitorDbModule.h"
#include <unistd.h>
#include <cmath>
#include <iostream>
#include "DQMServices/Core/interface/DQMStore.h"
#include "FWCore/ServiceRegistry/interface/Service.h"
#include "RelationalAccess/IConnectionService.h"
#include "RelationalAccess/IConnectionServiceConfiguration.h"
#include "CoralBase/Attribute.h"
#include "CoralKernel/Context.h"
#include "DQM/EcalMonitorDbModule/interface/MonitorElementsDb.h"
#include "FWCore/Framework/interface/MakerMacros.h"
EcalBarrelMonitorDbModule::EcalBarrelMonitorDbModule(const edm::ParameterSet &ps) {
usesResource("DQMStore");
dqmStore_ = edm::Service<DQMStore>().operator->();
prefixME_ = ps.getUntrackedParameter<std::string>("prefixME", "");
xmlFile_ = ps.getUntrackedParameter<std::string>("xmlFile", "");
if (!xmlFile_.empty()) {
std::cout << "Monitor Elements from DB xml source file is " << xmlFile_ << std::endl;
}
sleepTime_ = ps.getUntrackedParameter<int>("sleepTime", 0);
std::cout << "Sleep time is " << sleepTime_ << " second(s)." << std::endl;
// html output directory
htmlDir_ = ps.getUntrackedParameter<std::string>("htmlDir", ".");
if (!htmlDir_.empty()) {
std::cout << " HTML output will go to"
<< " htmlDir = " << htmlDir_ << std::endl;
} else {
std::cout << " HTML output is disabled" << std::endl;
}
ME_Db_ = new MonitorElementsDb(ps, xmlFile_);
icycle_ = 0;
session_ = nullptr;
}
EcalBarrelMonitorDbModule::~EcalBarrelMonitorDbModule() {
if (ME_Db_)
delete ME_Db_;
}
void EcalBarrelMonitorDbModule::beginJob(void) {
icycle_ = 0;
if (ME_Db_)
ME_Db_->beginJob();
}
void EcalBarrelMonitorDbModule::endJob(void) {
if (ME_Db_)
ME_Db_->endJob();
std::cout << "EcalBarrelMonitorDbModule: endJob, icycle = " << icycle_ << std::endl;
}
void EcalBarrelMonitorDbModule::analyze(const edm::Event &e, const edm::EventSetup &c) {
icycle_++;
std::cout << "EcalBarrelMonitorDbModule: icycle = " << icycle_ << std::endl;
try {
coral::Context &context = coral::Context::instance();
context.loadComponent("CORAL/Services/ConnectionService");
context.loadComponent("CORAL/Services/EnvironmentAuthenticationService");
coral::IHandle<coral::IConnectionService> connectionService =
context.query<coral::IConnectionService>("CORAL/Services/ConnectionService");
context.loadComponent("CORAL/RelationalPlugins/oracle");
// Set configuration parameters
coral::IConnectionServiceConfiguration &config = connectionService->configuration();
config.setConnectionRetrialPeriod(1);
config.setConnectionRetrialTimeOut(10);
session_ = connectionService->connect("ECAL CondDB", coral::ReadOnly);
if (ME_Db_)
ME_Db_->analyze(e, c, session_);
} catch (coral::Exception &e) {
std::cerr << "CORAL Exception : " << e.what() << std::endl;
} catch (std::exception &e) {
std::cerr << "Standard C++ exception : " << e.what() << std::endl;
}
if (!htmlDir_.empty()) {
ME_Db_->htmlOutput(htmlDir_);
}
delete session_;
sleep(sleepTime_);
}
DEFINE_FWK_MODULE(EcalBarrelMonitorDbModule);
|