Belle II Software development
DQMHistAnalysisTOP.cc
1/**************************************************************************
2 * basf2 (Belle II Analysis Software Framework) *
3 * Author: The Belle II Collaboration *
4 * *
5 * See git log for contributors and copyright holders. *
6 * This file is licensed under LGPL-3.0, see LICENSE.md. *
7 **************************************************************************/
8
9#include <dqm/analysis/modules/DQMHistAnalysisTOP.h>
10#include <boost/format.hpp>
11#include <boost/algorithm/string.hpp>
12#include <TClass.h>
13#include <TF1.h>
14#include <TROOT.h>
15#include <TStyle.h>
16#include <TProfile.h>
17#include <TProfile2D.h>
18#include <TString.h>
19#include <map>
20
21using namespace std;
22using namespace Belle2;
23using boost::format;
24
25//-----------------------------------------------------------------
26// Register the Module
27//-----------------------------------------------------------------
28REG_MODULE(DQMHistAnalysisTOP);
29
30//-----------------------------------------------------------------
31// Implementation
32//-----------------------------------------------------------------
33
35{
36 // Set description
37 setDescription("Histogram analysis module for TOP DQM.");
38
39 // Add parameters
40 addParam("asicWindowsBand", m_asicWindowsBand,
41 "lower and upper bin of a band denoting good windows", m_asicWindowsBand);
42 addParam("asicWindowsAlarmLevels", m_asicWindowsAlarmLevels,
43 "alarm levels for the fraction of windows outside the band (yellow, red)", m_asicWindowsAlarmLevels);
44 addParam("eventMonitorAlarmLevels", m_eventMonitorAlarmLevels,
45 "alarm levels for the fraction of desynchronized digits (yellow, red)", m_eventMonitorAlarmLevels);
46 addParam("junkHitsAlarmLevels", m_junkHitsAlarmLevels,
47 "alarm levels for the fraction of junk hits (yellow, red)", m_junkHitsAlarmLevels);
48 addParam("deadChannelsAlarmLevels", m_deadChannelsAlarmLevels,
49 "alarm levels for the fraction of dead + hot channels (yellow, red)", m_deadChannelsAlarmLevels);
50 addParam("backgroundAlarmLevels", m_backgroundAlarmLevels,
51 "alarm levels for background rates [MHz/PMT] (yellow, red)", m_backgroundAlarmLevels);
52 addParam("photonYieldsAlarmLevels", m_photonYieldsAlarmLevels,
53 "alarm levels for the number of photons per track (red, yellow)", m_photonYieldsAlarmLevels);
54 addParam("excludedBoardstacks", m_excludedBoardstacks,
55 "boarstacks to be excluded from alarming. Names are given like '5c', '13d' etc.", m_excludedBoardstacks);
56 addParam("pvPrefix", m_pvPrefix, "Epics PV prefix", std::string("TOP:"));
57 addParam("injectionBGAlarmLevels", m_injectionBGAlarmLevels,
58 "alarm levels for injection background (in % of events)", m_injectionBGAlarmLevels);
59 addParam("timingAlarmLevels", m_timingAlarmLevels,
60 "alarm levels for time distribution (residual fraction w.r.t reference plot)", m_timingAlarmLevels);
61 addParam("eventT0MeanAlarmLevels", m_eventT0MeanAlarmLevels,
62 "alarm levels for mean of event T0 [ns]", m_eventT0MeanAlarmLevels);
63 addParam("eventT0RmsAlarmLevels", m_eventT0RmsAlarmLevels,
64 "alarm levels for r.m.s. of event T0 [ns]", m_eventT0RmsAlarmLevels);
65 addParam("offsetMeanAlarmLevels", m_offsetMeanAlarmLevels,
66 "alarm levels for mean of bunch offset [ns]", m_offsetMeanAlarmLevels);
67 addParam("offsetRmsAlarmLevels", m_offsetRmsAlarmLevels,
68 "alarm levels for r.m.s. of bunch offset [ns]", m_offsetRmsAlarmLevels);
69
70 B2DEBUG(20, "DQMHistAnalysisTOP: Constructor done.");
71}
72
73
75
76
78{
79
80 // check module parameters
81
82 if (m_asicWindowsBand.size() != 2) B2ERROR("Parameter list 'asicWindowsBand' must contain two numbers");
83 if (m_asicWindowsAlarmLevels.size() != 2) B2ERROR("Parameter list 'asicWindowsAlarmLevels' must contain two numbers");
84 if (m_eventMonitorAlarmLevels.size() != 2) B2ERROR("Parameter list 'eventMonitorAlarmLevels' must contain two numbers");
85 if (m_junkHitsAlarmLevels.size() != 2) B2ERROR("Parameter list 'junkHitsAlarmLevels' must contain two numbers");
86 if (m_deadChannelsAlarmLevels.size() != 2) B2ERROR("Parameter list 'deadChannelsAlarmLevels' must contain two numbers");
87 if (m_backgroundAlarmLevels.size() != 2) B2ERROR("Parameter list 'backgroundAlarmLevels' must contain two numbers");
88 if (m_photonYieldsAlarmLevels.size() != 2) B2ERROR("Parameter list 'photonYieldsAlarmLevels' must contain two numbers");
89 if (m_injectionBGAlarmLevels.size() != 2) B2ERROR("Parameter list 'injectionBGAlarmLevels' must contain two numbers");
90 if (m_timingAlarmLevels.size() != 2) B2ERROR("Parameter list 'timingAlarmLevels' must contain two numbers");
91 if (m_eventT0MeanAlarmLevels.size() != 2) B2ERROR("Parameter list 'eventT0MeanAlarmLevels' must contain two numbers");
92 if (m_eventT0RmsAlarmLevels.size() != 2) B2ERROR("Parameter list 'eventT0RmsAlarmLevels' must contain two numbers");
93 if (m_offsetMeanAlarmLevels.size() != 2) B2ERROR("Parameter list 'offsetMeanAlarmLevels' must contain two numbers");
94 if (m_offsetRmsAlarmLevels.size() != 2) B2ERROR("Parameter list 'offsetRmsAlarmLevels' must contain two numbers");
95
96 // make a map of boardstack names to ID's
97
98 int id = 1;
99 for (int slot = 1; slot <= 16; slot++) {
100 string slotstr = to_string(slot);
101 for (std::string bs : {"a", "b", "c", "d"}) {
102 m_bsmap[slotstr + bs] = id;
103 id++;
104 }
105 }
106
107 // parse excluded boardstacks
108
110
111 // MiraBelle monitoring
112
114
115 // Epics used to pass values to shifter's page (output only)
116
117 registerEpicsPV(m_pvPrefix + "badBoardstacks", "badBoardstacks");
118 registerEpicsPV(m_pvPrefix + "badCarriers", "badCarriers");
119 registerEpicsPV(m_pvPrefix + "badAsics", "badAsics");
120 registerEpicsPV(m_pvPrefix + "badPMTs", "badPMTs");
121 registerEpicsPV(m_pvPrefix + "numExcludedBS", "numExcludedBS");
122 registerEpicsPV(m_pvPrefix + "histoAlarmState", "histoAlarmState"); // to pass overall state to central alarm overview panel
123
124 // Epics used to get limits from configuration file - override module parameters (input only)
125
126 registerEpicsPV(m_pvPrefix + "asicWindowsBand", "asicWindowsBand");
127 registerEpicsPV(m_pvPrefix + "asicWindowsAlarmLevels", "asicWindowsAlarmLevels");
128 registerEpicsPV(m_pvPrefix + "eventMonitorAlarmLevels", "eventMonitorAlarmLevels");
129 registerEpicsPV(m_pvPrefix + "junkHitsAlarmLevels", "junkHitsAlarmLevels");
130 registerEpicsPV(m_pvPrefix + "deadChannelsAlarmLevels", "deadChannelsAlarmLevels");
131 registerEpicsPV(m_pvPrefix + "backgroundAlarmLevels", "backgroundAlarmLevels"); // also output
132 registerEpicsPV(m_pvPrefix + "photonYieldsAlarmLevels", "photonYieldsAlarmLevels");
133 registerEpicsPV(m_pvPrefix + "excludedBoardstacks", "excludedBoardstacks");
134
135 registerEpicsPV(m_pvPrefix + "injectionBGAlarmLevels", "injectionBGAlarmLevels"); // also output
136 registerEpicsPV(m_pvPrefix + "timingAlarmLevels", "timingAlarmLevels");
137 registerEpicsPV(m_pvPrefix + "eventT0MeanAlarmLevels", "eventT0MeanAlarmLevels");
138 registerEpicsPV(m_pvPrefix + "eventT0RmsAlarmLevels", "eventT0RmsAlarmLevels");
139 registerEpicsPV(m_pvPrefix + "offsetMeanAlarmLevels", "offsetMeanAlarmLevels");
140 registerEpicsPV(m_pvPrefix + "offsetRmsAlarmLevels", "offsetRmsAlarmLevels");
141
142 // new canvases, histograms and graphic primitives
143
144 gROOT->cd();
145
146 m_c_photonYields = new TCanvas("TOP/c_photonYields", "c_photonYields");
147 m_c_backgroundRates = new TCanvas("TOP/c_backgroundRates", "c_backgroundRates");
148
149 m_deadFraction = new TH1F("TOP/deadFraction", "Fraction of dead channels in included boardstacks", 16, 0.5, 16.5);
150 m_deadFraction->SetXTitle("slot number");
151 m_deadFraction->SetYTitle("fraction");
152 m_hotFraction = new TH1F("TOP/hotFraction", "Fraction of hot channels in included boardstacks", 16, 0.5, 16.5);
153 m_hotFraction->SetXTitle("slot number");
154 m_hotFraction->SetYTitle("fraction");
155 m_excludedFraction = new TH1F("TOP/excludedFraction", "Fraction of hot and dead channels in excluded bordstacks", 16, 0.5, 16.5);
156 m_excludedFraction->SetXTitle("slot number");
157 m_excludedFraction->SetYTitle("fraction");
158 m_activeFraction = new TH1F("TOP/activeFraction", "Fraction of active channels", 16, 0.5, 16.5);
159 m_activeFraction->SetXTitle("slot number");
160 m_activeFraction->SetYTitle("fraction");
161 m_c_deadAndHot = new TCanvas("TOP/c_deadAndHotChannels", "c_deadAndHotChannels");
162
163 m_junkFraction = new TH1F("TOP/junkFraction", "Fraction of junk hits per boardstack", 64, 0.5, 16.5);
164 m_junkFraction->SetXTitle("slot number");
165 m_junkFraction->SetYTitle("fraction");
166 // note: titles are intentionally the same since this one is plotted first
167 m_excludedBSHisto = new TH1F("TOP/excludedBSHisto", "Fraction of junk hits per boardstack", 64, 0.5, 16.5);
168 m_excludedBSHisto->SetXTitle("slot number");
169 m_excludedBSHisto->SetYTitle("fraction");
170 m_c_junkFraction = new TCanvas("TOP/c_junkFraction", "c_junkFraction");
171
172 for (int slot = 1; slot <= 16; slot++) {
173 string hname = "TOP/pmtHitRates_" + to_string(slot);
174 string htitle = "PMT hits per event for slot #" + to_string(slot);
175 auto* h = new TH1F(hname.c_str(), htitle.c_str(), 32, 0.5, 32.5);
176 h->SetXTitle("PMT number");
177 h->SetYTitle("Number of good hits per event");
178 m_pmtHitRates.push_back(h);
179 string cname = "TOP/c_pmtHitRates_" + to_string(slot);
180 string ctitle = "c_pmtHitRates_" + to_string(slot);
181 m_c_pmtHitRates.push_back(new TCanvas(cname.c_str(), ctitle.c_str()));
182 }
183
184 for (std::string name : {
185 "nhitInjLER", "nhitInjHER", "nhitInjLERcut", "nhitInjHERcut",
186 "eventInjLER", "eventInjHER", "eventInjLERcut", "eventInjHERcut"
187 }) {
188 for (std::string proj : {"_px", "_py"}) {
189 std::string cname = "TOP/c_" + name + proj;
190 m_c_injBGs[cname] = new TCanvas(cname.c_str(), (name + proj).c_str());
191 }
192 }
193
194 m_text1 = new TPaveText(0.125, 0.8, 0.675, 0.88, "NDC");
195 m_text1->SetFillColorAlpha(kWhite, 0);
196 m_text1->SetBorderSize(0);
197 m_text2 = new TPaveText(0.55, 0.8, 0.85, 0.89, "NDC");
198 m_text2->SetFillColorAlpha(kWhite, 0);
199 m_text2->SetBorderSize(0);
200 m_text3 = new TPaveText(0.47, 0.8, 0.85, 0.89, "NDC");
201 m_text3->SetFillColorAlpha(kWhite, 0);
202 m_text3->SetBorderSize(0);
203 m_text4 = new TPaveText(0.125, 0.8, 0.675, 0.88, "NDC");
204 m_text4->SetFillColorAlpha(kWhite, 0);
205 m_text4->SetBorderSize(0);
206
207 for (int slot = 1; slot < 16; slot++) {
208 auto* line = new TLine(slot + 0.5, 0, slot + 0.5, 1);
209 line->SetLineWidth(1);
210 line->SetLineStyle(2);
211 m_verticalLines.push_back(line);
212 }
213
215
216 B2DEBUG(20, "DQMHistAnalysisTOP: initialized.");
217}
218
219
221{
222 m_mirabelleVariables.clear();
223
224 B2DEBUG(20, "DQMHistAnalysisTOP: beginRun called.");
225}
226
227
229{
230 // get type of the run (TODO: to be replaced with base class function when fixed)
231 auto* rtype = findHist("DQMInfo/rtype");
232 m_runType = rtype ? rtype->GetTitle() : "";
233 m_IsNullRun = (m_runType == "null");
234
235 // get number of events processed with TOPDQM module
236 auto* goodHitsPerEvent = findHist("TOP/goodHitsPerEventAll");
237 m_numEvents = goodHitsPerEvent ? goodHitsPerEvent->GetEntries() : 0;
238
239 bool zeroSupp = gStyle->GetHistMinimumZero();
240 gStyle->SetHistMinimumZero(true);
241
242 // update alarm levels and other parameters from EpicsPVs
243 updateLimits();
244
245 // reset overall alarm state
246 m_alarmStateOverall = c_Gray;
247
248 // Update window_vs_slot canvas w/ alarming
250
251 // Update event desynchronization monitor w/ alarming
253
254 // Update number of good hits per event w/ alarming (injection BG)
256
257 // Update event T0 w/ alarming
259
260 // Update bunch offset w/ alarming
262
263 // Fraction of dead and hot channels
264 const auto* activeFraction = makeDeadAndHotFractionsPlot();
265
266 // Photon yields and background rates, corrected for dead and hot channels
267 makePhotonYieldsAndBGRatePlots(activeFraction);
268
269 // Fractions of junk hits
271
272 // Set z-axis range to 3 times the average for good hits, 30 times the average for junk hits
273 setZAxisRange("TOP/good_hits_xy_", 3);
274 setZAxisRange("TOP/bad_hits_xy_", 30);
275 setZAxisRange("TOP/good_hits_asics_", 3);
276 setZAxisRange("TOP/bad_hits_asics_", 30);
277
278 // Background subtracted time distributions (only for physics runs)
279 if (m_runType == "physics") {
280 auto* trackHits = (TH2F*) findHist("TOP/trackHits");
281 makeBGSubtractedTimingPlot("goodHitTimes", trackHits, 0);
282 for (int slot = 1; slot <= 16; slot++) {
283 makeBGSubtractedTimingPlot("good_timing_" + to_string(slot), trackHits, slot);
284 }
285 }
286
287 // Update timing plot w/ alarming
289
290 // PMT hit rates
292
293 // Injection BG
295
296 // Set Epics variables
298
299 gStyle->SetHistMinimumZero(zeroSupp);
300}
301
302
304{
305 // these two histograms do not exist anymore since file is closed, therefore
306 m_photonYields = nullptr;
307 m_backgroundRates = nullptr;
308
309 // add MiraBelle monitoring
310
311 for (const auto& var : m_mirabelleVariables) {
312 m_monObj->setVariable(var.first, var.second);
313 B2DEBUG(20, var.first << " " << var.second);
314 }
315
316 B2DEBUG(20, "DQMHistAnalysisTOP : endRun called");
317}
318
319
321{
322 B2DEBUG(20, "terminate called");
323}
324
325
327{
328 int alarmState = c_Gray;
329 m_text1->Clear();
330
331 auto* hraw = (TH2F*) findHist("TOP/window_vs_slot");
332 if (hraw) {
333 auto* px = hraw->ProjectionX("tmp_px");
334 auto* band = hraw->ProjectionX("TOP/windowFractions", m_asicWindowsBand[0], m_asicWindowsBand[1]);
335 band->Add(px, band, 1, -1);
336 double total = px->Integral();
337 double totalWindowFraction = (total != 0) ? band->Integral() / total : 0;
338 band->Divide(band, px);
339 setMiraBelleVariables("RateBadRaw_slot", band);
340 m_mirabelleVariables["RateBadRaw_all"] = totalWindowFraction;
341 if (total > 0) {
342 alarmState = getAlarmState(totalWindowFraction, m_asicWindowsAlarmLevels);
343 m_text1->AddText(Form("Fraction outside red lines: %.2f %%", totalWindowFraction * 100.0));
344 }
345 delete px;
346 delete band;
347 }
348
349 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
350
351 auto* canvas = findCanvas("TOP/c_window_vs_slot");
352 if (canvas) {
353 canvas->Clear();
354 canvas->cd();
355 if (hraw) hraw->Draw();
356 m_text1->Draw();
357 for (auto* line : m_asicWindowsBandLines) line->Draw();
358 canvas->Pad()->SetFrameFillColor(10);
359 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
360 canvas->Modified();
361 }
362}
363
364
366{
367 int alarmState = c_Gray;
368 m_text2->Clear();
369
370 auto* evtMonitor = (TH1F*) findHist("TOP/BoolEvtMonitor");
371 if (evtMonitor) {
372 double totalEvts = evtMonitor->Integral();
373 double badEvts = evtMonitor->GetBinContent(2);
374 if (totalEvts > 0) {
375 double badRatio = badEvts / totalEvts;
376 alarmState = getAlarmState(badRatio, m_eventMonitorAlarmLevels);
377 m_text2->AddText(Form("Fraction: %.4f %%", badRatio * 100.0));
378 }
379 }
380
381 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
382
383 auto* canvas = findCanvas("TOP/c_BoolEvtMonitor");
384 if (canvas) {
385 canvas->cd();
386 m_text2->Draw();
387 canvas->Pad()->SetFrameFillColor(10);
388 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
389 canvas->Modified();
390 }
391}
392
393
395{
396 int alarmState = c_Gray;
397 m_text4->Clear();
398
399 double fract = 0;
400 double xcut = 0;
401 double ymax = 0;
402 auto* h = (TH1F*) findHist("TOP/goodHitsPerEventAll");
403 if (h) {
404 double totalEvts = h->GetEntries();
405 if (totalEvts > 1000) {
406 // fraction of events with more than xcut hits - these are mostly containing injection BG
407 xcut = h->GetBinCenter(h->GetMaximumBin()) + 900;
408 ymax = h->GetMaximum() / 2;
409 fract = h->Integral(h->FindBin(xcut), h->GetNbinsX() + 1) / totalEvts * 100; // in %
410 alarmState = getAlarmState(fract, m_injectionBGAlarmLevels);
411 m_text4->AddText(Form("Events w/ Injection BG: %.2f %%", fract));
412 }
413 }
414
415 setEpicsPV("injectionBGAlarmLevels", fract);
416 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
417
418 auto* canvas = findCanvas("TOP/c_goodHitsPerEventAll");
419 if (canvas) {
420 canvas->cd();
421 if (not m_injBGCutLine) {
422 m_injBGCutLine = new TLine(xcut, 0, xcut, ymax);
423 m_injBGCutLine->SetLineWidth(2);
424 m_injBGCutLine->SetLineColor(kRed);
425 m_injBGCutLine->Draw("same");
426 } else {
427 m_injBGCutLine->SetX1(xcut);
428 m_injBGCutLine->SetX2(xcut);
429 m_injBGCutLine->SetY2(ymax);
430 }
431 m_text4->Draw();
432 canvas->Pad()->SetFrameFillColor(10);
433 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
434 canvas->Modified();
435 }
436}
437
438
440{
441 int alarmState = c_Gray;
442
443 auto* h = (TH1F*) findHist("TOP/eventT0");
444 if (h) {
445 double totalEvts = h->GetEntries();
446 if (totalEvts > 100) {
447 double mean = h->GetMean();
448 double rms = h->GetRMS();
449 alarmState = std::max(getAlarmState(fabs(mean), m_eventT0MeanAlarmLevels), getAlarmState(rms, m_eventT0RmsAlarmLevels));
450 }
451 }
452
453 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
454
455 auto* canvas = findCanvas("TOP/c_eventT0");
456 if (canvas) {
457 canvas->cd();
458 canvas->Pad()->SetFrameFillColor(10);
459 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
460 canvas->Modified();
461 }
462}
463
464
466{
467 int alarmState = c_Gray;
468
469 auto* h = (TH1F*) findHist("TOP/bunchOffset");
470 if (h) {
471 double totalEvts = h->GetEntries();
472 if (totalEvts > 100) {
473 double mean = h->GetMean();
474 double rms = h->GetRMS();
475 alarmState = std::max(getAlarmState(fabs(mean), m_offsetMeanAlarmLevels), getAlarmState(rms, m_offsetRmsAlarmLevels));
476 }
477 }
478
479 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
480
481 auto* canvas = findCanvas("TOP/c_bunchOffset");
482 if (canvas) {
483 canvas->cd();
484 canvas->Pad()->SetFrameFillColor(10);
485 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
486 canvas->Modified();
487 }
488}
489
490
492{
493 int alarmState = c_Gray;
494
495 auto* h = (TH1F*) findHist("TOP/goodHitTimes");
496 auto* href = (TH1F*) findRefHist("TOP/goodHitTimes");
497 if (h and href) {
498 double n = h->Integral();
499 double nref = href->Integral();
500 if (n > 0 and nref > 0 and sameHistDefinition(h, href)) {
501 auto* h_clone = (TH1F*) h->Clone("tmp");
502 auto* href_clone = (TH1F*) href->Clone("tmpref");
503 h_clone->Scale(1 / n);
504 href_clone->Scale(1 / nref);
505 h_clone->Add(h_clone, href_clone, 1, -1);
506 double sumDiff = 0;
507 double errDiff = 0;
508 for (int i = 1; i <= h_clone->GetNbinsX(); i++) {
509 sumDiff += fabs(h_clone->GetBinContent(i));
510 errDiff += pow(h_clone->GetBinError(i), 2);
511 }
512 errDiff = sqrt(errDiff);
513 if (sumDiff < 5 * errDiff) sumDiff = 0; // difference not significant
514 alarmState = getAlarmState(sumDiff, m_timingAlarmLevels);
515 delete h_clone;
516 delete href_clone;
517 }
518 }
519
520 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
521
522 auto* canvas = findCanvas("TOP/c_goodHitTimes");
523 if (canvas) {
524 canvas->cd();
525 canvas->Pad()->SetFrameFillColor(10);
526 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
527 canvas->Modified();
528 }
529}
530
532{
533 if (h1->GetNbinsX() != h2->GetNbinsX()) return false;
534 if (h1->GetXaxis()->GetXmin() != h2->GetXaxis()->GetXmin()) return false;
535 if (h1->GetXaxis()->GetXmax() != h2->GetXaxis()->GetXmax()) return false;
536 return true;
537}
538
540{
541 m_deadFraction->Reset();
542 m_hotFraction->Reset();
543 m_excludedFraction->Reset();
544 m_activeFraction->Reset();
545 double inactiveFract = 0; // max inactive channel fraction when some boardstacks are excluded from alarming
546
547 for (int slot = 1; slot <= 16; slot++) {
548 auto* h = (TH1F*) findHist("TOP/good_channel_hits_" + std::to_string(slot));
549 if (not h) continue;
550
551 auto cuts = getDeadAndHotCuts(h);
552 double deadCut = cuts.first;
553 double hotCut = cuts.second;
554 double deadFract = 0;
555 double hotFract = 0;
556 double deadFractIncl = 0;
557 double hotFractIncl = 0;
558 for (int chan = 0; chan < h->GetNbinsX(); chan++) {
559 double y = h->GetBinContent(chan + 1);
560 int bs = chan / 128 + (slot - 1) * 4;
561 bool included = m_includedBoardstacks[bs];
562 if (y <= deadCut) {
563 deadFract += 1;
564 if (included) deadFractIncl += 1;
565 } else if (y > hotCut) {
566 hotFract += 1;
567 if (included) hotFractIncl += 1;
568 }
569 }
570 deadFract /= h->GetNbinsX();
571 hotFract /= h->GetNbinsX();
572 deadFractIncl /= h->GetNbinsX();
573 hotFractIncl /= h->GetNbinsX();
574 m_deadFraction->SetBinContent(slot, deadFractIncl);
575 m_hotFraction->SetBinContent(slot, hotFractIncl);
576 m_excludedFraction->SetBinContent(slot, deadFract - deadFractIncl + hotFract - hotFractIncl);
577 m_activeFraction->SetBinContent(slot, 1 - deadFract - hotFract);
578 inactiveFract = std::max(inactiveFract, deadFractIncl + hotFractIncl);
579 }
580
581 setMiraBelleVariables("ActiveChannelFraction_slot", m_activeFraction);
582
583 int alarmState = c_Gray;
584 if (m_activeFraction->Integral() > 0) {
585 alarmState = getAlarmState(inactiveFract, m_deadChannelsAlarmLevels);
586 }
587
588 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
589
590 m_deadFraction->SetFillColor(1);
591 m_deadFraction->SetLineColor(1);
592 m_deadFraction->GetXaxis()->SetNdivisions(16);
593
594 m_hotFraction->SetFillColor(2);
595 m_hotFraction->SetLineColor(2);
596 m_hotFraction->GetXaxis()->SetNdivisions(16);
597
598 m_excludedFraction->SetFillColor(kGray);
599 m_excludedFraction->SetLineColor(kGray);
600 m_excludedFraction->GetXaxis()->SetNdivisions(16);
601
602 m_activeFraction->SetFillColor(0);
603 m_activeFraction->GetXaxis()->SetNdivisions(16);
604
605 auto* canvas = m_c_deadAndHot;
606 canvas->Clear();
607 canvas->cd();
608 canvas->Pad()->SetFrameFillColor(10);
609 if (not m_stack) {
610 m_stack = new THStack("TOP/stack", "Fraction of dead and hot channels");
615 }
616 m_stack->Draw();
617
618 for (auto* line : m_deadChannelsAlarmLines) line->Draw("same");
619
620 if (not m_legend) {
621 m_legend = new TLegend(0.8, 0.87, 0.99, 0.99);
622 m_legend->AddEntry(m_hotFraction, "hot");
623 m_legend->AddEntry(m_deadFraction, "dead");
624 m_legend->AddEntry(m_excludedFraction, "excluded");
625 }
626 m_legend->Draw("same");
627
628 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
629 canvas->Modified();
630
631 return m_activeFraction;
632}
633
634
636{
637 for (auto* canvas : {m_c_photonYields, m_c_backgroundRates}) {
638 canvas->Clear();
639 canvas->Pad()->SetFrameFillColor(10);
640 canvas->Pad()->SetFillColor(getAlarmColor(c_Gray));
641 canvas->Modified();
642 }
643 m_averageRate = 0;
644
645 auto* signalHits = (TProfile*) findHist("TOP/signalHits");
646 if (not signalHits) return;
647
648 auto* backgroundHits = (TProfile*) findHist("TOP/backgroundHits");
649 if (not backgroundHits) return;
650
651 if (m_photonYields) delete m_photonYields;
652 m_photonYields = signalHits->ProjectionX("TOP/photonYields");
654 m_backgroundRates = backgroundHits->ProjectionX("TOP/backgroundRates");
655 auto* activeFract = (TH1F*) activeFraction->Clone("tmp");
656 for (int i = 1; i <= activeFract->GetNbinsX(); i++) activeFract->SetBinError(i, 0);
657
659 m_photonYields->Divide(m_photonYields, activeFract);
660 setMiraBelleVariables("PhotonsPerTrack_slot", m_photonYields);
661
662 int alarmState = c_Gray;
663 if (signalHits->GetEntries() > 0 and activeFraction->Integral() > 0) {
664 double hmin = 1000;
665 for (int i = 1; i <= m_photonYields->GetNbinsX(); i++) {
666 if (signalHits->GetBinEntries(i) < 10) continue;
667 hmin = std::min(hmin, m_photonYields->GetBinContent(i) + 3 * m_photonYields->GetBinError(i));
668 }
669 if (hmin < 1000) alarmState = getAlarmState(hmin, m_photonYieldsAlarmLevels, false);
670 }
671 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
672
673 m_photonYields->SetTitle("Number of photons per track");
674 m_photonYields->SetYTitle("photons per track");
675 m_photonYields->SetMarkerStyle(24);
676 m_photonYields->GetXaxis()->SetNdivisions(16);
677
678 auto* canvas = m_c_photonYields;
679 canvas->cd();
680 m_photonYields->SetMinimum(0);
681 m_photonYields->Draw();
682 for (auto* line : m_photonYieldsAlarmLines) line->Draw("same");
683 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
684 canvas->Modified();
685
686 m_backgroundRates->Scale(1.0 / 50.0e-3 / 32); // measured in 50 ns window, 32 PMT's ==> rate in MHz/PMT
687 m_backgroundRates->Divide(m_backgroundRates, activeFract);
688 setMiraBelleVariables("BackgroundRate_slot", m_backgroundRates);
689
690 alarmState = c_Gray;
691 m_text3->Clear();
692 if (backgroundHits->GetEntries() > 100 and activeFraction->Integral() > 0) {
693 int status = m_backgroundRates->Fit("pol0", "Q0");
694 if (status == 0) {
695 auto* fun = m_backgroundRates->GetFunction("pol0");
696 if (fun) {
697 m_averageRate = fun->GetParameter(0);
698 double error = fun->GetParError(0);
699 alarmState = getAlarmState(m_averageRate - 3 * error, m_backgroundAlarmLevels);
700 m_text3->AddText(Form("Average: %.2f MHz/PMT", m_averageRate));
701 }
702 }
703 }
704 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
705
706 m_backgroundRates->SetTitle("Background rates");
707 m_backgroundRates->SetYTitle("background rate [MHz/PMT]");
708 m_backgroundRates->SetMarkerStyle(24);
709 m_backgroundRates->GetXaxis()->SetNdivisions(16);
710
711 canvas = m_c_backgroundRates;
712 canvas->cd();
713 m_backgroundRates->SetMinimum(0);
714 m_backgroundRates->Draw();
715 for (auto* line : m_backgroundAlarmLines) line->Draw("same");
716 m_text3->Draw();
717 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
718 canvas->Modified();
719
720 delete activeFract;
721}
722
723
725{
726 m_junkFraction->Reset();
727 m_excludedBSHisto->Reset();
728 auto* allHits = (TH1D*) m_junkFraction->Clone("tmp");
729 for (int slot = 1; slot <= 16; slot++) {
730 auto* good = (TH1F*) findHist("TOP/good_channel_hits_" + std::to_string(slot));
731 if (not good) continue;
732 auto* bad = (TH1F*) findHist("TOP/bad_channel_hits_" + std::to_string(slot));
733 if (not bad) continue;
734 for (int i = 0; i < 512; i++) {
735 int bs = i / 128;
736 allHits->Fill(slot + bs / 4. - 0.5, good->GetBinContent(i + 1) + bad->GetBinContent(i + 1));
737 m_junkFraction->Fill(slot + bs / 4. - 0.5, bad->GetBinContent(i + 1));
738 }
739 }
740
741 m_junkFraction->Divide(m_junkFraction, allHits, 1, 1, "B");
742
743 int alarmState = c_Gray;
744 if (allHits->Integral() > 0) {
745 double hmax = 0;
746 for (size_t i = 0; i < m_includedBoardstacks.size(); i++) {
747 if (m_includedBoardstacks[i]) hmax = std::max(hmax, m_junkFraction->GetBinContent(i + 1));
748 else m_excludedBSHisto->SetBinContent(i + 1, 1);
749 }
750 alarmState = getAlarmState(hmax, m_junkHitsAlarmLevels);
751 }
752 delete allHits;
753 m_alarmStateOverall = std::max(m_alarmStateOverall, alarmState);
754
755 auto* canvas = m_c_junkFraction;
756 canvas->Clear();
757 canvas->cd();
758 canvas->Pad()->SetFrameFillColor(10);
759 canvas->Pad()->SetFillColor(getAlarmColor(alarmState));
760 m_excludedBSHisto->SetFillColor(kGray);
761 m_excludedBSHisto->SetLineColor(kGray);
762 m_excludedBSHisto->GetXaxis()->SetNdivisions(16);
763 m_excludedBSHisto->GetYaxis()->SetRangeUser(0, 1);
764 m_excludedBSHisto->Draw();
765 m_junkFraction->SetMarkerStyle(24);
766 m_junkFraction->GetXaxis()->SetNdivisions(16);
767 m_junkFraction->GetYaxis()->SetRangeUser(0, 1); // Note: m_junkFraction->GetMaximum() will now give 1 and not the histogram maximum!
768 m_junkFraction->Draw("same");
769 for (auto* line : m_verticalLines) line->Draw("same");
770 for (auto* line : m_junkHitsAlarmLines) line->Draw("same");
771 canvas->Modified();
772}
773
774
775void DQMHistAnalysisTOPModule::setZAxisRange(const std::string& name, double scale)
776{
777 double totalHits = 0;
778 std::vector<TH2F*> histos;
779 for (int slot = 1; slot <= 16; slot++) {
780 TH2F* h = (TH2F*) findHist(name + std::to_string(slot));
781 if (not h) continue;
782 histos.push_back(h);
783 totalHits += h->Integral();
784 }
785 if (histos.empty()) return;
786 double average = totalHits / 512 / histos.size(); // per pixel or asic channel
787
788 for (auto* h : histos) h->GetZaxis()->SetRangeUser(0, std::max(average * scale, 1.0));
789}
790
791
792void DQMHistAnalysisTOPModule::makeBGSubtractedTimingPlot(const std::string& name, const TH2F* trackHits, int slot)
793{
794 auto* canvas = findCanvas("TOP/c_" + name);
795 if (not canvas) return;
796
797 auto* h = (TH1F*) findHist("TOP/" + name);
798 if (not h) return;
799
800 auto* hb = (TH1F*) findHist("TOP/" + name + "BG");
801 if (not hb) return;
802
803 if (trackHits) {
804 // use the ratio of events w/ and w/o track in the slot to scale the background
805 double s = (slot == 0) ? trackHits->Integral(1, 16, 2, 2) : trackHits->GetBinContent(slot, 2);
806 if (s == 0) return;
807 double sb = (slot == 0) ? trackHits->Integral(1, 16, 1, 1) : trackHits->GetBinContent(slot, 1);
808 if (sb == 0) return;
809 h->Add(h, hb, 1, -s / sb);
810 } else {
811 // use the content of bins at t < 0 to scale the background
812 int i0 = h->GetXaxis()->FindBin(0.); // bin at t = 0
813 double s = h->Integral(1, i0);
814 if (s == 0) return;
815 double sb = hb->Integral(1, i0);
816 if (sb == 0) return;
817 if (s / sb > 1) return; // this can happen due to low statistics and is not reliable
818 h->Add(h, hb, 1, -s / sb);
819 }
820
821 TString title = TString(h->GetTitle()) + " (BG subtracted)";
822 h->SetTitle(title);
823
824 canvas->Clear();
825 canvas->cd();
826 h->Draw();
827 canvas->Modified();
828}
829
830
832{
833 auto* h0 = (TH1F*) findHist("TOP/goodHitsPerEventAll");
834 if (not h0) return;
835 double numEvents = h0->GetEntries();
836 if (numEvents == 0) return;
837
838 int numSlots = m_pmtHitRates.size();
839 for (int slot = 1; slot <= numSlots; slot++) {
840 string name = "TOP/good_hits_xy_" + to_string(slot);
841 auto* hxy = (TH2F*) findHist(name);
842 if (not hxy) continue;
843 std::vector<double> pmts(32, 0);
844 for (int row = 0; row < 8; row++) {
845 for (int col = 0; col < 64; col++) {
846 int pmt = col / 4 + (row / 4) * 16;
847 pmts[pmt] += hxy->GetBinContent(col + 1, row + 1);
848 }
849 }
850 auto* h = m_pmtHitRates[slot - 1];
851 for (size_t i = 0; i < pmts.size(); i++) {
852 h->SetBinContent(i + 1, pmts[i] / numEvents);
853 }
854 auto* canvas = m_c_pmtHitRates[slot - 1];
855 canvas->Clear();
856 canvas->cd();
857 h->SetMinimum(0);
858 h->Draw();
859 canvas->Modified();
860 }
861}
862
863
865{
866 for (std::string name : {"nhitInjLER", "nhitInjHER", "nhitInjLERcut", "nhitInjHERcut"}) {
867 std::string hname = "TOP/" + name;
868 auto* h = (TProfile2D*) findHist(hname);
869 if (not h) continue;
870 for (std::string proj : {"_px", "_py"}) {
871 std::string cname = "TOP/c_" + name + proj;
872 auto* canvas = m_c_injBGs[cname];
873 if (not canvas) continue;
874 canvas->Clear();
875 canvas->cd();
876 auto& hproj = m_profiles[cname];
877 if (hproj) delete hproj;
878 hproj = (proj == "_px") ? h->ProfileX((hname + proj).c_str()) : h->ProfileY((hname + proj).c_str());
879 std::string xtitle = (proj == "_px") ? h->GetXaxis()->GetTitle() : h->GetYaxis()->GetTitle();
880 hproj->SetXTitle(xtitle.c_str());
881 hproj->SetYTitle(h->GetZaxis()->GetTitle());
882 hproj->SetMinimum(0);
883 hproj->Draw("hist");
884 canvas->Modified();
885 }
886 }
887
888 for (std::string name : {"eventInjLER", "eventInjHER", "eventInjLERcut", "eventInjHERcut"}) {
889 std::string hname = "TOP/" + name;
890 auto* h = (TH2F*) findHist(hname);
891 if (not h) continue;
892 for (std::string proj : {"_px", "_py"}) {
893 std::string cname = "TOP/c_" + name + proj;
894 auto* canvas = m_c_injBGs[cname];
895 if (not canvas) continue;
896 canvas->Clear();
897 canvas->cd();
898 auto& hproj = m_projections[cname];
899 if (hproj) delete hproj;
900 hproj = (proj == "_px") ? h->ProjectionX((hname + proj).c_str()) : h->ProjectionY((hname + proj).c_str());
901 std::string xtitle = (proj == "_px") ? h->GetXaxis()->GetTitle() : h->GetYaxis()->GetTitle();
902 hproj->SetXTitle(xtitle.c_str());
903 hproj->SetYTitle(h->GetZaxis()->GetTitle());
904 hproj->SetMinimum(0);
905 hproj->Draw("hist");
906 canvas->Modified();
907 }
908 }
909
910}
911
912
913void DQMHistAnalysisTOPModule::setMiraBelleVariables(const std::string& variableName, const TH1* histogram)
914{
915 for (int slot = 1; slot <= 16; slot++) {
916 auto vname = variableName + std::to_string(slot);
917 double value = histogram ? histogram->GetBinContent(slot) : 0;
918 m_mirabelleVariables[vname] = value;
919 }
920}
921
922
923int DQMHistAnalysisTOPModule::getAlarmState(double value, const std::vector<double>& alarmLevels, bool bigRed) const
924{
925 if (m_IsNullRun or m_numEvents < 1000) return c_Gray;
926
927 if (bigRed) {
928 if (value < alarmLevels[0]) return c_Green;
929 else if (value < alarmLevels[1]) return c_Yellow;
930 else return c_Red;
931 } else {
932 if (value < alarmLevels[0]) return c_Red;
933 else if (value < alarmLevels[1]) return c_Yellow;
934 else return c_Green;
935 }
936}
937
938
939void DQMHistAnalysisTOPModule::setAlarmLines(const std::vector<double>& alarmLevels, double xmin, double xmax,
940 std::vector<TLine*>& alarmLines, bool bigRed)
941{
942 std::vector<int> colors = {kOrange, kRed};
943 if (not bigRed) std::reverse(colors.begin(), colors.end());
944 for (size_t i = 0; i < std::min(colors.size(), alarmLevels.size()); i++) {
945 if (i < alarmLines.size()) {
946 auto* line = alarmLines[i];
947 line->SetX1(xmin);
948 line->SetX2(xmax);
949 line->SetY1(alarmLevels[i]);
950 line->SetY2(alarmLevels[i]);
951 } else {
952 auto* line = new TLine(xmin, alarmLevels[i], xmax, alarmLevels[i]);
953 line->SetLineWidth(2);
954 line->SetLineStyle(2);
955 line->SetLineColor(colors[i]);
956 alarmLines.push_back(line);
957 }
958 }
959}
960
961
963{
964 for (size_t i = 0; i < m_asicWindowsBand.size(); i++) {
965 double y = m_asicWindowsBand[i];
966 if (i < m_asicWindowsBandLines.size()) {
967 auto* line = m_asicWindowsBandLines[i];
968 line->SetY1(y);
969 line->SetY2(y);
970 } else {
971 auto* line = new TLine(0.5, y, 16.5, y);
972 line->SetLineWidth(2);
973 line->SetLineColor(kRed);
974 m_asicWindowsBandLines.push_back(line);
975 }
976 }
977
982}
983
984
985std::pair<double, double> DQMHistAnalysisTOPModule::getDeadAndHotCuts(const TH1* h)
986{
987 std::vector<double> binContents;
988 for (int k = 1; k <= h->GetNbinsY(); k++) {
989 for (int i = 1; i <= h->GetNbinsX(); i++) {
990 binContents.push_back(h->GetBinContent(i, k));
991 }
992 }
993
994 double mean = 0;
995 double rms = h->GetMaximum();
996 for (int iter = 0; iter < 5; iter++) {
997 double sumy = 0;
998 double sumyy = 0;
999 int n = 0;
1000 for (auto y : binContents) {
1001 if (y == 0 or fabs(y - mean) > 3 * rms) continue;
1002 sumy += y;
1003 sumyy += y * y;
1004 n++;
1005 }
1006 if (n == 0) continue;
1007 mean = sumy / n;
1008 rms = sqrt(sumyy / n - mean * mean);
1009 }
1010
1011 return std::make_pair(mean / 5, std::max(mean * 2, mean + 6 * rms));
1012}
1013
1014
1016{
1017 int badBoardstacks = 0;
1018 int badCarriers = 0;
1019 int badAsics = 0;
1020 for (int slot = 1; slot <= 16; slot++) {
1021 std::string hname = "TOP/good_hits_asics_" + to_string(slot);
1022 auto* h = (TH2F*) findHist(hname);
1023 if (not h) continue;
1024
1025 auto cuts = getDeadAndHotCuts(h);
1026 double deadCut = cuts.first;
1027 double hotCut = cuts.second;
1028 std::vector<int> asics(64, 0);
1029 std::vector<int> carriers(16, 0);
1030 std::vector<int> boardstacks(4, 0);
1031 for (int asic = 0; asic < 64; asic++) {
1032 int carrier = asic / 4;
1033 int boardstack = carrier / 4;
1034 for (int chan = 0; chan < 8; chan++) {
1035 double y = h->GetBinContent(asic + 1, chan + 1);
1036 if (y > deadCut and y <= hotCut) {
1037 asics[asic]++;
1038 carriers[carrier]++;
1039 boardstacks[boardstack]++;
1040 }
1041 }
1042 }
1043 for (int n : asics) if (n == 0) badAsics++;
1044 for (int n : carriers) if (n == 0) badCarriers++;
1045 for (int n : boardstacks) if (n == 0) badBoardstacks++;
1046 }
1047 badAsics -= badCarriers * 4;
1048 badCarriers -= badBoardstacks * 4;
1049
1050 int badPMTs = 0;
1051 for (int slot = 1; slot <= 16; slot++) {
1052 std::string hname = "TOP/good_hits_xy_" + to_string(slot);
1053 auto* h = (TH2F*) findHist(hname);
1054 if (not h) continue;
1055
1056 auto cuts = getDeadAndHotCuts(h);
1057 double deadCut = cuts.first;
1058 double hotCut = cuts.second;
1059 std::vector<int> pmts(32, 0);
1060 for (int row = 0; row < 8; row++) {
1061 for (int col = 0; col < 64; col++) {
1062 int pmt = col / 4 + (row / 4) * 16;
1063 double y = h->GetBinContent(col + 1, row + 1);
1064 if (y > deadCut and y <= hotCut) pmts[pmt]++;
1065 }
1066 }
1067 for (int n : pmts) if (n == 0) badPMTs++;
1068 }
1069 badPMTs -= badBoardstacks * 8;
1070
1071 setEpicsPV("badBoardstacks", badBoardstacks);
1072 setEpicsPV("badCarriers", badCarriers);
1073 setEpicsPV("badAsics", badAsics);
1074 setEpicsPV("badPMTs", badPMTs);
1075 int numBS = 0;
1076 for (auto included : m_includedBoardstacks) if (not included) numBS++;
1077 setEpicsPV("numExcludedBS", numBS);
1079 setEpicsPV("backgroundAlarmLevels", m_averageRate);
1080
1081 B2DEBUG(20, "badBoardstacks: " << badBoardstacks);
1082 B2DEBUG(20, "badCarriers: " << badCarriers);
1083 B2DEBUG(20, "badAsics: " << badAsics);
1084 B2DEBUG(20, "badPMTs: " << badPMTs);
1085 B2DEBUG(20, "excludedBS: " << numBS);
1086 B2DEBUG(20, "histoAlarmState: " << getOffcialAlarmStatus(m_alarmStateOverall));
1087 B2DEBUG(20, "backgroundAlarmLevels" << m_averageRate);
1088}
1089
1091{
1092 double unused = 0;
1093
1094 double yLo = m_asicWindowsBand[0];
1095 double yHi = m_asicWindowsBand[1];
1096 requestLimitsFromEpicsPVs("asicWindowsBand", yLo, unused, unused, yHi);
1097 m_asicWindowsBand[0] = yLo;
1098 m_asicWindowsBand[1] = yHi;
1099
1100 requestLimitsFromEpicsPVs("asicWindowsAlarmLevels", unused, unused, m_asicWindowsAlarmLevels[0], m_asicWindowsAlarmLevels[1]);
1101 requestLimitsFromEpicsPVs("eventMonitorAlarmLevels", unused, unused, m_eventMonitorAlarmLevels[0], m_eventMonitorAlarmLevels[1]);
1102 requestLimitsFromEpicsPVs("junkHitsAlarmLevels", unused, unused, m_junkHitsAlarmLevels[0], m_junkHitsAlarmLevels[1]);
1103 requestLimitsFromEpicsPVs("deadChannelsAlarmLevels", unused, unused, m_deadChannelsAlarmLevels[0], m_deadChannelsAlarmLevels[1]);
1104 requestLimitsFromEpicsPVs("backgroundAlarmLevels", unused, unused, m_backgroundAlarmLevels[0], m_backgroundAlarmLevels[1]);
1105 requestLimitsFromEpicsPVs("photonYieldsAlarmLevels", m_photonYieldsAlarmLevels[0], m_photonYieldsAlarmLevels[1], unused, unused);
1106
1107 requestLimitsFromEpicsPVs("injectionBGAlarmLevels", unused, unused, m_injectionBGAlarmLevels[0], m_injectionBGAlarmLevels[1]);
1108 requestLimitsFromEpicsPVs("timingAlarmLevels", unused, unused, m_timingAlarmLevels[0], m_timingAlarmLevels[1]);
1109 requestLimitsFromEpicsPVs("eventT0MeanAlarmLevels", unused, unused, m_eventT0MeanAlarmLevels[0], m_eventT0MeanAlarmLevels[1]);
1110 requestLimitsFromEpicsPVs("eventT0RmsAlarmLevels", unused, unused, m_eventT0RmsAlarmLevels[0], m_eventT0RmsAlarmLevels[1]);
1111 requestLimitsFromEpicsPVs("offsetMeanAlarmLevels", unused, unused, m_offsetMeanAlarmLevels[0], m_offsetMeanAlarmLevels[1]);
1112 requestLimitsFromEpicsPVs("offsetRmsAlarmLevels", unused, unused, m_offsetRmsAlarmLevels[0], m_offsetRmsAlarmLevels[1]);
1113
1114 setAlarmLines();
1115
1116 bool status = false;
1117 std::string excludedBS = getEpicsStringPV("excludedBoardstacks", status);
1118
1119 if (status) {
1120 m_excludedBoardstacks.clear();
1121 std::string name;
1122 for (auto c : excludedBS) {
1123 if (isspace(c)) continue;
1124 else if (ispunct(c)) {
1125 if (not name.empty()) {
1126 m_excludedBoardstacks.push_back(name);
1127 name.clear();
1128 }
1129 } else name.push_back(c);
1130 }
1131 if (not name.empty()) {
1132 m_excludedBoardstacks.push_back(name);
1133 }
1135 }
1136
1137 B2DEBUG(20, "asicWindowsBand: [" << m_asicWindowsBand[0] << ", " << m_asicWindowsBand[1] << "]");
1138 B2DEBUG(20, "asicWindowsAlarmLevels: [" << m_asicWindowsAlarmLevels[0] << ", " << m_asicWindowsAlarmLevels[1] << "]");
1139 B2DEBUG(20, "eventMonitorAlarmLevels: [" << m_eventMonitorAlarmLevels[0] << ", " << m_eventMonitorAlarmLevels[1] << "]");
1140 B2DEBUG(20, "junkHitsAlarmLevels: [" << m_junkHitsAlarmLevels[0] << ", " << m_junkHitsAlarmLevels[1] << "]");
1141 B2DEBUG(20, "deadChannelsAlarmLevels: [" << m_deadChannelsAlarmLevels[0] << ", " << m_deadChannelsAlarmLevels[1] << "]");
1142 B2DEBUG(20, "backgroundAlarmLevels: [" << m_backgroundAlarmLevels[0] << ", " << m_backgroundAlarmLevels[1] << "]");
1143 B2DEBUG(20, "photonYieldsAlarmLevels: [" << m_photonYieldsAlarmLevels[0] << ", " << m_photonYieldsAlarmLevels[1] << "]");
1144
1145 B2DEBUG(20, "injectionBGAlarmLevels: [" << m_injectionBGAlarmLevels[0] << ", " << m_injectionBGAlarmLevels[1] << "]");
1146 B2DEBUG(20, "timingAlarmLevels: [" << m_timingAlarmLevels[0] << ", " << m_timingAlarmLevels[1] << "]");
1147 B2DEBUG(20, "eventT0MeanAlarmLevels: [" << m_eventT0MeanAlarmLevels[0] << ", " << m_eventT0MeanAlarmLevels[1] << "]");
1148 B2DEBUG(20, "eventT0RmsAlarmLevels: [" << m_eventT0RmsAlarmLevels[0] << ", " << m_eventT0RmsAlarmLevels[1] << "]");
1149 B2DEBUG(20, "offsetMeanAlarmLevels: [" << m_offsetMeanAlarmLevels[0] << ", " << m_offsetMeanAlarmLevels[1] << "]");
1150 B2DEBUG(20, "offsetRmsAlarmLevels: [" << m_offsetRmsAlarmLevels[0] << ", " << m_offsetRmsAlarmLevels[1] << "]");
1151
1152 std::string ss;
1153 for (const auto& s : m_excludedBoardstacks) ss += "'" + s + "', ";
1154 if (ss.size() > 2) {ss.pop_back(); ss.pop_back();}
1155 B2DEBUG(20, "excludedBoardstacks: [" << ss << "]");
1156
1157}
1158
1159void DQMHistAnalysisTOPModule::setIncludedBoardstacks(const std::vector<std::string>& excludedBoardstacks)
1160{
1161 m_includedBoardstacks.clear();
1162 m_includedBoardstacks.resize(64, true);
1163
1164 for (const auto& bsname : excludedBoardstacks) {
1165 int id = m_bsmap[bsname];
1166 if (id > 0) m_includedBoardstacks[id - 1] = false;
1167 else B2ERROR("Invalid boardstack name: " << bsname);
1168 }
1169}
The base class for the histogram analysis module.
TCanvas * findCanvas(TString cname)
Find canvas by name.
static TH1 * findRefHist(const std::string &histname, ERefScaling scaling=ERefScaling::c_RefScaleNone, const TH1 *hist=nullptr)
Get referencehistogram from list (no other search).
static MonitoringObject * getMonitoringObject(const std::string &name)
Get MonitoringObject with given name (new object is created if non-existing)
static TH1 * findHist(const std::string &histname, bool onlyIfUpdated=false)
Get histogram from list (no other search).
std::string getEpicsStringPV(std::string keyname, bool &status)
Read value from a EPICS PV.
void setEpicsPV(std::string keyname, double value)
Write value to a EPICS PV.
int registerEpicsPV(std::string pvname, std::string keyname="")
EPICS related Functions.
bool requestLimitsFromEpicsPVs(chid id, double &lowerAlarm, double &lowerWarn, double &upperWarn, double &upperAlarm)
Get Alarm Limits from EPICS PV.
void updateEventMonitorCanvas()
Updates canvas of event desynchronization monitor w/ alarming.
std::vector< int > m_asicWindowsBand
lower and upper bin of a band denoting good windows
void setZAxisRange(const std::string &name, double scale)
Sets z-axis range of 2D histograms.
TCanvas * m_c_photonYields
Canvas: photon yields per slot.
std::vector< double > m_offsetRmsAlarmLevels
alarm levels for r.m.s.
void initialize() override final
Initializer.
void makePMTHitRatesPlots()
Makes plots of the number of PMT hits per event.
TH1F * m_excludedFraction
fraction of dead and hot channels per slot in excluded boardstacks only
void updateEventT0Canvas()
Updates canvas of event T0 w/ alarming.
std::vector< double > m_deadChannelsAlarmLevels
alarm levels for the fraction of dead + hot channels
std::vector< double > m_asicWindowsAlarmLevels
alarm levels for fraction of windows outside the band
TPaveText * m_text2
text to be written to event desynchonization monitor
TCanvas * m_c_junkFraction
Canvas: fraction of junk hits per boardstack.
THStack * m_stack
stack for drawing dead, hot and active channel fractions
const TH1F * makeDeadAndHotFractionsPlot()
Makes a plot of dead and hot channel fractions per slot.
void makeBGSubtractedTimingPlot(const std::string &name, const TH2F *trackHits, int slot)
Makes background subtracted time distribution plot.
void updateTimingCanvas()
Updates canvas of timing plot w/ alarming.
TPaveText * m_text3
text to be written to background rates
std::vector< TLine * > m_deadChannelsAlarmLines
lines representing alarm levels
std::vector< TCanvas * > m_c_pmtHitRates
Canvases of PMT hits per event (index = slot - 1)
int m_alarmStateOverall
overall alarm state of histograms to be sent by EpicsPV
TPaveText * m_text1
text to be written to window_vs_slot
std::vector< TLine * > m_photonYieldsAlarmLines
lines representing alarm levels
std::pair< double, double > getDeadAndHotCuts(const TH1 *h)
Returns cut levels for dead and hot channels.
std::vector< double > m_offsetMeanAlarmLevels
alarm levels for mean of bunch offset [ns]
std::vector< bool > m_includedBoardstacks
boardstacks included in alarming
bool sameHistDefinition(TH1 *h1, TH1 *h2)
Checks if histograms are defined in the same way (nbins, xmin, xmax)
TPaveText * m_text4
text to be written to number of good hits per event
std::vector< TLine * > m_verticalLines
vertical lines splitting slots
std::string m_pvPrefix
Epics PV prefix.
TH1D * m_photonYields
photon yields per slot
TH1D * m_backgroundRates
background rates per slot
MonitoringObject * m_monObj
MiraBelle monitoring object.
TCanvas * m_c_backgroundRates
Canvas: background rates per slot.
std::map< std::string, TCanvas * > m_c_injBGs
Canvases for projections of injection BG histograms.
std::vector< double > m_eventMonitorAlarmLevels
alarm levels for fraction of desynchronized digits
void terminate() override final
This method is called at the end of the event processing.
std::map< std::string, double > m_mirabelleVariables
variables for MiraBelle
void setAlarmLines()
Sets all alarm lines.
TH1F * m_activeFraction
fraction of active channels per slot
int getAlarmColor(unsigned alarmState) const
Converts alarm state to color.
std::vector< double > m_eventT0MeanAlarmLevels
alarm levels for mean of event T0 [ns]
void event() override final
This method is called for each event.
void makeInjectionBGPlots()
Makes projections of injection BG plots.
std::vector< double > m_photonYieldsAlarmLevels
alarm levels for the number of photons per track
std::vector< TLine * > m_junkHitsAlarmLines
lines representing alarm levels
void setIncludedBoardstacks(const std::vector< std::string > &excludedBoardstacks)
Sets flags for boardstacks to be included in alarming.
std::vector< double > m_injectionBGAlarmLevels
alarm levels for injection background (in % of events)
TH1F * m_deadFraction
fraction of dead channels per slot (included boardstacks only)
double m_averageRate
average BG rate (to pass to EpicsPV)
TH1F * m_hotFraction
fraction of hot channels per slot (included boardstacks only)
std::vector< std::string > m_excludedBoardstacks
list of boarstacks to be excluded from alarming
void makePhotonYieldsAndBGRatePlots(const TH1F *activeFraction)
Make plots of dead-and-hot-channel corrected photon yields and BG rates per slot.
TH1F * m_junkFraction
fraction of junk hits per boardstack
void endRun() override final
This method is called if the current run ends.
int getAlarmState(double value, const std::vector< double > &alarmLevels, bool bigRed=true) const
Returns alarm state.
std::vector< double > m_eventT0RmsAlarmLevels
alarm levels for r.m.s.
std::vector< TLine * > m_asicWindowsBandLines
lines denoting a band of good windows
void makeJunkFractionPlot()
Makes a plot of fractions of junk hits per boardstack.
void beginRun() override final
Called when entering a new run.
TLegend * m_legend
legend for dead and hot channels
TCanvas * m_c_deadAndHot
Canvas: fractin of dead and hot channels.
std::vector< TLine * > m_backgroundAlarmLines
lines representing alarm levels
void updateWindowVsSlotCanvas()
Updates canvas of window_vs_slot w/ alarming.
double m_numEvents
number of events processed with TOPDQM module
std::map< std::string, int > m_bsmap
a map of boardstack names to ID's
std::vector< double > m_backgroundAlarmLevels
alarm levels for background rates [MHz/PMT]
std::map< std::string, TH1D * > m_projections
projections of injection BG
void updateBunchOffsetCanvas()
Updates canvas of bunch offset w/ alarming.
void setEpicsVariables()
Calculates and sets epics variables.
std::vector< double > m_junkHitsAlarmLevels
alarm levels for the fraction of junk hits
bool m_IsNullRun
Run type flag for null runs.
void updateNGoodHitsCanvas()
Updates canvas of number of good hits per event w/ alarming (injection BG)
TLine * m_injBGCutLine
a line denoting the cut on the number of hits for injection BG counting
std::vector< double > m_timingAlarmLevels
alarm levels for time distribution (fraction of area difference)
int getOffcialAlarmStatus(unsigned alarmState) const
Converts alarm state to official status (see EStatus of the base class)
std::vector< TH1F * > m_pmtHitRates
histograms of PMT hits per event (index = slot - 1)
TH1F * m_excludedBSHisto
histogram to show excluded boardstacks on junk fraction plot
std::map< std::string, TProfile * > m_profiles
profiles of injection BG
void updateLimits()
Updates limits defined by module parameters using EpicsPVs.
void setMiraBelleVariables(const std::string &variableName, const TH1 *histogram)
Sets MiraBelle variables from the histogram with bins corresponding to slot numbers.
void setDescription(const std::string &description)
Sets the description of the module.
Definition: Module.cc:214
void setVariable(const std::string &var, float val, float upErr=-1., float dwErr=-1)
set value to float variable (new variable is made if not yet existing)
void addParam(const std::string &name, T &paramVariable, const std::string &description, const T &defaultValue)
Adds a new parameter to the module.
Definition: Module.h:560
#define REG_MODULE(moduleName)
Register the given module (without 'Module' suffix) with the framework.
Definition: Module.h:650
double sqrt(double a)
sqrt for double
Definition: beamHelpers.h:28
Abstract base class for different kinds of events.
STL namespace.