ATLAS Offline Software
Loading...
Searching...
No Matches
CounterThread Class Reference

Concrete implimentation of Counter to monitor all algorithms executing on a single thread. More...

#include <CounterThread.h>

Inheritance diagram for CounterThread:
Collaboration diagram for CounterThread:

Public Member Functions

 CounterThread ()=delete
 Forbid default constructor.
 CounterThread (const std::string &name, const MonitorBase *parent)
 Construct counter.
virtual ~CounterThread ()=default
 Default destructor.
CounterThreadoperator= (const CounterThread &)=delete
 Forbid assignment.
 CounterThread (const CounterThread &)=delete
 Forbid copy.
virtual StatusCode newEvent (const CostData &data, size_t index, const float weight=1.0) override
 Concrete implementation.
StatusCode postProcess (float weight=1.0)
 Apply post-processing to the Counter, before endEvent is called.
uint64_t getLowTimestamp () const
 Get the lowest timestamp of this single thread.
uint64_t getHighTimestamp () const
 Get the highest timestamp of this single thread.
void setAllThreadsTimestamps (uint64_t low, uint64_t high)
 Set the low and high timestamps over all threads.
const std::string & getName () const
 Getter for Counter's name.
const MonitorBasegetParent () const
 Return cached non-owning const ptr to this Counter's parent Monitor.
bool variableExists (const std::string &name) const
 Check if a variable of a given name exists.
VariablegetVariable (std::string_view name)
 Returns a mutable reference to a named Variable.
StatusCode fill (std::string_view name, float value, float weight=1.0)
 Fill (for per-Call) or accumulate in a buffer (for per-Event) a quantity histogrammed by a named Variable.
StatusCode fill (std::string_view name, float xvalue, float yvalue, float weight)
 Fill (for per-Call) or accumulate in a buffer (for per-Event) a quantity histogrammed by a named Variable.
StatusCode increment (std::string_view name, float weight=1.0)
 Convenience function.
StatusCode setDenominator (const std::string &name, float value)
 Optional for per-Event Variables.
virtual StatusCode endEvent (float weight=1.0)
 Called by the framework.

Public Attributes

uint64_t m_lowTimestamp
 Records the lowest timestamp seen on this single thread in an event.
uint64_t m_highTimestamp
 Records the highest timestamp seen on this single thread in an event.
uint64_t m_globalLowTimestamp
 Records the lowest timestamp seen over all threads in an event.
uint64_t m_globalHighTimestamp
 Records the highest timestamp seen over all threads in an event.

Protected Member Functions

void regHistogram (const std::string &name, const std::string &title, const VariableType type=VariableType::kPerCall, const LogType xaxis=kLog, const float min=0.1, const float max=1000000., const size_t bins=70)
 Book a histogram for this Counter, to be filled in per-event monitoring.
void regHistogram (const std::string &name, const std::string &title, const VariableType type, const LogType xaxis, const float xmin, const float xmax, const size_t xbins, const LogType yaxis, const float ymin, const float ymax, const size_t ybins)
 Book a 2D histogram for this Counter, to be filled in per-event monitoring.
void regTProfile (const std::string &name, const std::string &title, const VariableType type=VariableType::kPerCall, const LogType xaxis=kLog, const float min=0.1, const float max=1000000., const size_t bins=70)
 Book a TProfile for this Counter, to be filled in per-event monitoring.
TH1 * bookGetPointer (TH1 *hist, const std::string &tDir="") const
 Appends Counter name (to histogram path) and forwards histogram book request to parent Monitor.
float timeToMilliSec (const uint64_t start, const uint64_t stop) const
 Helper function.

Private Attributes

const std::string m_name
 Counter's name.
const MonitorBasem_parent {}
 Counter's parent Monitor.
std::unordered_map< std::string, Variable, CxxUtils::TransparentStringHash, std::equal_to<> > m_variables
 Store of Counter's Variables.

Detailed Description

Concrete implimentation of Counter to monitor all algorithms executing on a single thread.

Definition at line 14 of file CounterThread.h.

Constructor & Destructor Documentation

◆ CounterThread() [1/3]

CounterThread::CounterThread ( )
delete

Forbid default constructor.

◆ CounterThread() [2/3]

CounterThread::CounterThread ( const std::string & name,
const MonitorBase * parent )

Construct counter.

Parameters
[in]nameCounter's name
[in]parentCounter's parent monitor, cached non-owning pointer.

Definition at line 9 of file CounterThread.cxx.

10 : CounterBase(name, parent), m_lowTimestamp(std::numeric_limits<uint64_t>::max()), m_highTimestamp(0),
11 m_globalLowTimestamp(std::numeric_limits<uint64_t>::max()), m_globalHighTimestamp(0)
12{
13 regHistogram("AlgTime_perEvent", "Algorithm CPU Time/Event;Time [ms];Events", VariableType::kPerEvent);
14 regHistogram("FrameworkTime_perEvent", "Framework CPU Time/Event;Time [ms];Events", VariableType::kPerEvent);
15 regHistogram("UnmonitoredTime_perEvent", "Unmonitored CPU Time/Event;Time [ms];Events", VariableType::kPerEvent);
16 regHistogram("WallTime_perEvent", "Total walltime from HLT start to stop/Event;Time [ms];Events", VariableType::kPerEvent);
17
18 regHistogram("AlgTime_perEventFractional", "Algorithm CPU Time Fractional;Fractional Time;Events", VariableType::kPerEvent, kLinear, 0., 1.);
19 regHistogram("FrameworkTime_perEventFractional", "Framework Time/Event CPU Time Fractional;Fractional Time;Events", VariableType::kPerEvent, kLinear, 0., 1.);
20 regHistogram("FrameworkTime_perEventFractional_vs_TotalTime_perEvent", "Framework Fractional Time vs Total Time/Event;Framework Time/Event CPU Time Fractional;Total Time/Event CPU Time Fractional;Events", VariableType::kPerEvent, kLinear, 0., 1., 70, kLog, 0.1, 1000000., 70);
21 regHistogram("AlgTime_perEventFractional_vs_TotalTime_perEvent", "Algorithm Fractional Time vs Total Time/Event;Algorithm Time/Event CPU Time Fractional;Total Time/Event CPU Time Fractional;Events", VariableType::kPerEvent, kLinear, 0., 1., 70, kLog, 0.1, 1000000., 70);
22 regHistogram("UnmonitoredTime_perEventFractional", "Unmonitored CPU Time Fractional;Fractional Time;Events", VariableType::kPerEvent, kLinear, 0., 1.);
23
24 regHistogram("AlgCalls_perEvent", "Algorithm Calls/Event;Calls;Events", VariableType::kPerEvent, kLog, 0.5, 10000.5, 500);
25 regHistogram("ThisAlgCalls_perEvent", "This Event Algorithm Calls/Event;Calls;Events", VariableType::kPerEvent, kLog, 0.5, 10000.5, 500);
26 regHistogram("OtherAlgCalls_perEvent", "Other Event Algorithm Calls/Event;Calls;Events", VariableType::kPerEvent, kLog, 0.5, 10000.5, 500);
27 regHistogram("AlgSlot_perCall", "Algorithm Slot/Call;Slot;Calls", VariableType::kPerCall, kLinear, -0.5, 20.5, 21);
28
29}
@ kPerEvent
Variable should buffer fill calls in an accumulator and fill the underlying histogram once at the end...
Definition Variable.h:21
@ kPerCall
Variable should fill underlying histogram on each fill.
Definition Variable.h:20
@ kLinear
Linear x-binning.
Definition Variable.h:29
@ kLog
Logarithmic x-binning.
Definition Variable.h:30
CounterBase()=delete
Forbid default constructor.
void regHistogram(const std::string &name, const std::string &title, const VariableType type=VariableType::kPerCall, const LogType xaxis=kLog, const float min=0.1, const float max=1000000., const size_t bins=70)
Book a histogram for this Counter, to be filled in per-event monitoring.
uint64_t m_globalLowTimestamp
Records the lowest timestamp seen over all threads in an event.
uint64_t m_highTimestamp
Records the highest timestamp seen on this single thread in an event.
uint64_t m_lowTimestamp
Records the lowest timestamp seen on this single thread in an event.
uint64_t m_globalHighTimestamp
Records the highest timestamp seen over all threads in an event.

◆ ~CounterThread()

virtual CounterThread::~CounterThread ( )
virtualdefault

Default destructor.

◆ CounterThread() [3/3]

CounterThread::CounterThread ( const CounterThread & )
delete

Forbid copy.

Member Function Documentation

◆ bookGetPointer()

TH1 * CounterBase::bookGetPointer ( TH1 * hist,
const std::string & tDir = "" ) const
protectedinherited

Appends Counter name (to histogram path) and forwards histogram book request to parent Monitor.

Parameters
[in]histBare pointer to histogram. Ownership transferred to THistSvc.
[in]tDirHistogram name & directory.
Returns
Cached pointer to histogram. Used to fill histogram without having to perform THishSvc lookup.

Definition at line 235 of file CounterBase.cxx.

235 {
236 std::string dir = getName();
237 if (tDir != "") {
238 dir += "/";
239 dir += tDir;
240 }
241 return getParent()->bookGetPointer(hist, dir);
242}
const MonitorBase * getParent() const
Return cached non-owning const ptr to this Counter's parent Monitor.
const std::string & getName() const
Getter for Counter's name.
TH1 * bookGetPointer(TH1 *hist, const std::string &tDir="") const
Appends Monitor name (to histogram path) and forwards histogram book request to parent Range.

◆ endEvent()

StatusCode CounterBase::endEvent ( float weight = 1.0)
virtualinherited

Called by the framework.

Causes per-Event Variables to fill their histograms with their accumulated data.

Definition at line 227 of file CounterBase.cxx.

227 {
228 for (auto& nameVariablePair : m_variables) {
229 ATH_CHECK( nameVariablePair.second.endEvent() );
230 }
231 return StatusCode::SUCCESS;
232}
#define ATH_CHECK
Evaluate an expression and check for errors.
std::unordered_map< std::string, Variable, CxxUtils::TransparentStringHash, std::equal_to<> > m_variables
Store of Counter's Variables.

◆ fill() [1/2]

StatusCode CounterBase::fill ( std::string_view name,
float value,
float weight = 1.0 )
inherited

Fill (for per-Call) or accumulate in a buffer (for per-Event) a quantity histogrammed by a named Variable.

Parameters
[in]nameVariable to increment
[in]valueThe payload value
[in]weightGlobal event weight

Definition at line 193 of file CounterBase.cxx.

193 {
194 auto it = m_variables.find(name);
195 if (it == m_variables.end()) {
196 return StatusCode::FAILURE;
197 }
198 ATH_CHECK( it->second.fill(value, weight) );
199 return StatusCode::SUCCESS;
200}

◆ fill() [2/2]

StatusCode CounterBase::fill ( std::string_view name,
float xvalue,
float yvalue,
float weight )
inherited

Fill (for per-Call) or accumulate in a buffer (for per-Event) a quantity histogrammed by a named Variable.

Parameters
[in]nameVariable to increment
[in]xvalueThe payload x-axis value
[in]yvalueThe payload y-axis value
[in]weightGlobal event weight

Definition at line 202 of file CounterBase.cxx.

202 {
203 auto it = m_variables.find(name);
204 if (it == m_variables.end()) {
205 return StatusCode::FAILURE;
206 }
207 ATH_CHECK( it->second.fill(xvalue, yvalue, weight) );
208 return StatusCode::SUCCESS;
209}

◆ getHighTimestamp()

uint64_t CounterThread::getHighTimestamp ( ) const

Get the highest timestamp of this single thread.

Definition at line 102 of file CounterThread.cxx.

102 {
103 return m_highTimestamp;
104}

◆ getLowTimestamp()

uint64_t CounterThread::getLowTimestamp ( ) const

Get the lowest timestamp of this single thread.

Definition at line 97 of file CounterThread.cxx.

97 {
98 return m_lowTimestamp;
99}

◆ getName()

const std::string & CounterBase::getName ( ) const
inherited

Getter for Counter's name.

Returns
Counter's name const string reference.

Definition at line 19 of file CounterBase.cxx.

19 {
20 return m_name;
21}
const std::string m_name
Counter's name.

◆ getParent()

const MonitorBase * CounterBase::getParent ( ) const
inherited

Return cached non-owning const ptr to this Counter's parent Monitor.

Returns
Cached pointer parent Monitor.

Definition at line 24 of file CounterBase.cxx.

24 {
25 return m_parent;
26}
const MonitorBase * m_parent
Counter's parent Monitor.

◆ getVariable()

Variable & CounterBase::getVariable ( std::string_view name)
inherited

Returns a mutable reference to a named Variable.

Throws if no such Variable exists. Used when more complicated logic is needed on a Variable than simply using the fill() method.

Parameters
[in]nameVariable to return
Returns
Mutable reference to Variable

Definition at line 184 of file CounterBase.cxx.

184 {
185 auto it = m_variables.find(name);
186 if (it == m_variables.end()) {
187 throw std::runtime_error( std::format("CounterBase::getVariable: No variable with name {}", name) );
188 }
189 return (it->second);
190}

◆ increment()

StatusCode CounterBase::increment ( std::string_view name,
float weight = 1.0 )
inherited

Convenience function.

Equivalent to fill(name, 1.0, weight);

Parameters
[in]nameVariable to increment
[in]weightGlobal event weight

Definition at line 222 of file CounterBase.cxx.

222 {
223 return fill(name, 1.0, weight);
224}
StatusCode fill(std::string_view name, float value, float weight=1.0)
Fill (for per-Call) or accumulate in a buffer (for per-Event) a quantity histogrammed by a named Vari...

◆ newEvent()

StatusCode CounterThread::newEvent ( const CostData & data,
size_t index,
const float weight = 1.0 )
overridevirtual

Concrete implementation.

Monitores algorithm at specified index for this counter's thread.

Parameters
[in]dataAccess to event data
[in]indexIndex within appropriate event data container which is to be analysed by this Counter
[in]weightGlobal event weight

Implements CounterBase.

Definition at line 32 of file CounterThread.cxx.

32 {
33 const xAOD::TrigComposite* alg = data.costCollection().at(index);
34
35 const uint64_t start = alg->getDetail<uint64_t>("start"); // in mus
36 const uint64_t stop = alg->getDetail<uint64_t>("stop"); // in mus
37 const uint32_t slot = alg->getDetail<uint32_t>("slot");
38 const float cpuTime = timeToMilliSec(start, stop);
39 ATH_CHECK( fill("AlgTime_perEvent", cpuTime, weight) );
40 ATH_CHECK( fill("AlgTime_perEventFractional", cpuTime, weight) );
41 ATH_CHECK( increment("AlgCalls_perEvent", weight) );
42 if (slot == 0) {
43 ATH_CHECK( increment("ThisAlgCalls_perEvent", weight) );
44 } else {
45 ATH_CHECK( increment("OtherAlgCalls_perEvent", weight) );
46 }
47 ATH_CHECK( fill("AlgSlot_perCall", slot, weight) );
48 m_lowTimestamp = std::min(m_lowTimestamp, start);
49 m_highTimestamp = std::max(m_highTimestamp, stop);
50
51 return StatusCode::SUCCESS;
52}
float timeToMilliSec(const uint64_t start, const uint64_t stop) const
Helper function.
StatusCode increment(std::string_view name, float weight=1.0)
Convenience function.
TrigComposite_v1 TrigComposite
Declare the latest version of the class.
setEventNumber uint32_t

◆ operator=()

CounterThread & CounterThread::operator= ( const CounterThread & )
delete

Forbid assignment.

◆ postProcess()

StatusCode CounterThread::postProcess ( float weight = 1.0)

Apply post-processing to the Counter, before endEvent is called.

Parameters
[in]weightGlobal event weight

Definition at line 54 of file CounterThread.cxx.

54 {
55 // Total time from start of HLTSeeding to "stop" of SummaryMaker.
57
58 // We know that we may loose data on algs which started executing before the HLTSeeding triggered the data collection.
59 // But we truncate the data for algs which are running still when we stop collecting data.
60 float unmonitoredTime = 0;
61 if (m_highTimestamp > 0) {
62 const float unmonitoredStart = timeToMilliSec(m_globalLowTimestamp, m_lowTimestamp);
63 const float unmonitoredEnd = timeToMilliSec(m_highTimestamp, m_globalHighTimestamp);
64 unmonitoredTime = unmonitoredStart + unmonitoredEnd;
65 // As of T12, unmonitoredEnd should be zero due to truncating this record online.
66 }
67
68 // Time spent outside of any algorithm. E.g. in Gaudi
69 const float frameworkTime = eventTime - unmonitoredTime - getVariable("AlgTime_perEvent").getAccumulator();
70
71 ATH_CHECK( fill("UnmonitoredTime_perEvent", unmonitoredTime, weight) );
72 ATH_CHECK( fill("UnmonitoredTime_perEventFractional", unmonitoredTime, weight) );
73
74 ATH_CHECK( fill("FrameworkTime_perEvent", frameworkTime, weight) );
75 ATH_CHECK( fill("FrameworkTime_perEventFractional", frameworkTime, weight) );
76
77 ATH_CHECK( fill("WallTime_perEvent", eventTime, weight) );
78
79 ATH_CHECK( setDenominator("AlgTime_perEventFractional", eventTime) );
80 ATH_CHECK( setDenominator("FrameworkTime_perEventFractional", eventTime) );
81 ATH_CHECK( setDenominator("UnmonitoredTime_perEventFractional", eventTime) );
82
83 ATH_CHECK( fill("FrameworkTime_perEventFractional_vs_TotalTime_perEvent", frameworkTime, eventTime, weight) );
84 ATH_CHECK( fill("AlgTime_perEventFractional_vs_TotalTime_perEvent", getVariable("AlgTime_perEvent").getAccumulator(), eventTime, weight) );
85 ATH_CHECK( setDenominator("FrameworkTime_perEventFractional_vs_TotalTime_perEvent", eventTime) );
86 ATH_CHECK( setDenominator("AlgTime_perEventFractional_vs_TotalTime_perEvent", eventTime) );
87
88 m_lowTimestamp = std::numeric_limits<uint64_t>::max();
90 m_globalLowTimestamp = std::numeric_limits<uint64_t>::max();
92
93 return StatusCode::SUCCESS;
94}
Variable & getVariable(std::string_view name)
Returns a mutable reference to a named Variable.
StatusCode setDenominator(const std::string &name, float value)
Optional for per-Event Variables.
float getAccumulator() const
Getter for accumulated value of a kPerEvent Variable.
Definition Variable.cxx:35

◆ regHistogram() [1/2]

void CounterBase::regHistogram ( const std::string & name,
const std::string & title,
const VariableType type,
const LogType xaxis,
const float xmin,
const float xmax,
const size_t xbins,
const LogType yaxis,
const float ymin,
const float ymax,
const size_t ybins )
protectedinherited

Book a 2D histogram for this Counter, to be filled in per-event monitoring.

Parameters
[in]nameThe name of the histogram (and corresponding Variable)
[in]titleROOT histogram title string in format "title;xaxis;yaxis"
[in]xaxisControls if the x-axis should use fixed-width or logarithmic bin boundaries.
[in]xminX-axis minimum bound.
[in]xmaxX-axis maximum bound.
[in]xbinsNumber of histogram bins.
[in]yaxisControls if the y-axis should use fixed-width or logarithmic bin boundaries.
[in]yminY-axis minimum bound.
[in]ymaxY-axis maximum bound.
[in]ybinsNumber of histogram bins.

Definition at line 111 of file CounterBase.cxx.

122{
123 std::string hisSvcName = getParent()->getParent()->getName() + "_" + getParent()->getName() + "_" + getName() + "_" + name;
124 std::unique_ptr<TH2F> hist;
125
126 if (xmax <= xmin || ymax <= ymin || xbins == 0 || ybins == 0) {
127 throw std::runtime_error("CounterBase::regHistogram: Cannot have max <= min or bins == 0");
128 }
129
130 if (xaxis == kLinear && yaxis == kLinear) {
131 hist = std::make_unique<TH2F>(hisSvcName.c_str(), title.c_str(), xbins, xmin, xmax, ybins, ymin, ymax);
132 } else if (xaxis == kLog || yaxis == kLog) {
133 if ( (xaxis == kLog && xmin <= 0) || (yaxis == kLog && ymin <= 0) ) {
134 throw std::runtime_error("CounterBase::regHistogram: Cannot have min <= 0 with log binning");
135 }
136 std::unique_ptr<double[]> xlogbins = std::make_unique<double[]>(xbins+1);
137 std::unique_ptr<double[]> ylogbins = std::make_unique<double[]>(ybins+1);
138 if (xaxis == kLog){
139 const double xlogmin = log10(xmin);
140 const double xlogmax = log10(xmax);
141 const double dlogx = (xlogmax-xlogmin)/((double)xbins);
142 for (size_t i = 0; i <= xbins; ++i) {
143 const double xlog = xlogmin + i*dlogx;
144 xlogbins[i] = exp( log(10) * xlog );
145 }
146 } else {
147 const double dx = (xmax-xmin)/((double)xbins);
148 for (size_t i = 0; i <= xbins; ++i) {
149 xlogbins[i] = xmin + i*dx;
150 }
151 }
152
153 if (yaxis == kLog){
154 const double ylogmin = log10(ymin);
155 const double ylogmax = log10(ymax);
156 const double dlogy = (ylogmax-ylogmin)/((double)ybins);
157 for (size_t i = 0; i <= ybins; ++i) {
158 const double ylog = ylogmin + i*dlogy;
159 ylogbins[i] = exp( log(10) * ylog );
160 }
161 } else {
162 const double dy = (ymax-ymin)/((double)ybins);
163 for (size_t i = 0; i <= ybins; ++i) {
164 ylogbins[i] = ymin + i*dy;
165 }
166 }
167
168 hist = std::make_unique<TH2F>(hisSvcName.c_str(), title.c_str(), xbins, xlogbins.get(), ybins, ylogbins.get());
169 } else {
170 throw std::runtime_error("CounterBase::regHistogram: Unknown logarithm flag");
171 }
172
173 m_variables.emplace(std::piecewise_construct,
174 std::forward_as_tuple(name),
175 std::forward_as_tuple(name, bookGetPointer(hist.release()), type)
176 );
177 // Histogram is now owned by THistSvc. A cache of the ptr is kept in the Variable
178}
TH1 * bookGetPointer(TH1 *hist, const std::string &tDir="") const
Appends Counter name (to histogram path) and forwards histogram book request to parent Monitor.
const MonitoredRange * getParent() const
Return cached non-owning const ptr to this Monitor's parent Range.
const std::string & getName() const
Getter for Monitor's name.
const std::string & getName() const
Getter for Range's name.
double xmax
Definition listroot.cxx:61
double ymin
Definition listroot.cxx:63
double xmin
Definition listroot.cxx:60
double ymax
Definition listroot.cxx:64

◆ regHistogram() [2/2]

void CounterBase::regHistogram ( const std::string & name,
const std::string & title,
const VariableType type = VariableType::kPerCall,
const LogType xaxis = kLog,
const float min = 0.1,
const float max = 1000000.,
const size_t bins = 70 )
protectedinherited

Book a histogram for this Counter, to be filled in per-event monitoring.

Parameters
[in]nameThe name of the histogram (and corresponding Variable)
[in]titleROOT histogram title string in format "title;xaxis;yaxis"
[in]xaxisControls if the x-axis should use fixed-width or logarithmic bin boundaries.
[in]minX-axis minimum bound.
[in]maxX-axis maximum bound.
[in]binsNumber of histogram bins.

Definition at line 29 of file CounterBase.cxx.

36{
37 std::string hisSvcName = getParent()->getParent()->getName() + "_" + getParent()->getName() + "_" + getName() + "_" + name;
38 std::unique_ptr<TH1F> hist;
39
40 if (max <= min || bins == 0) {
41 throw std::runtime_error("CounterBase::regHistogram: Cannot have max <= min or bins == 0");
42 }
43
44 if (xaxis == kLinear) {
45 hist = std::make_unique<TH1F>(hisSvcName.c_str(), title.c_str(), bins, min, max);
46 } else if (xaxis == kLog) {
47 if (min <= 0) {
48 throw std::runtime_error("CounterBase::regHistogram: Cannot have min <= 0 with log binning");
49 }
50 std::unique_ptr<double[]> xbins = std::make_unique<double[]>(bins+1);
51 const double xlogmin = log10(min);
52 const double xlogmax = log10(max);
53 const double dlogx = (xlogmax-xlogmin)/((double)bins);
54 for (size_t i = 0; i <= bins; ++i) {
55 const double xlog = xlogmin + i*dlogx;
56 xbins[i] = exp( log(10) * xlog );
57 }
58 hist = std::make_unique<TH1F>(hisSvcName.c_str(), title.c_str(), bins, xbins.get());
59 } else {
60 throw std::runtime_error("CounterBase::regHistogram: Unknown logarithm flag");
61 }
62
63 m_variables.emplace(std::piecewise_construct,
64 std::forward_as_tuple(name),
65 std::forward_as_tuple(name, bookGetPointer(hist.release()), type)
66 );
67 // Histogram is now owned by THistSvc. A cache of the ptr is kept in the Variable
68}
static const std::vector< std::string > bins
#define min(a, b)
Definition cfImp.cxx:40
#define max(a, b)
Definition cfImp.cxx:41

◆ regTProfile()

void CounterBase::regTProfile ( const std::string & name,
const std::string & title,
const VariableType type = VariableType::kPerCall,
const LogType xaxis = kLog,
const float min = 0.1,
const float max = 1000000.,
const size_t bins = 70 )
protectedinherited

Book a TProfile for this Counter, to be filled in per-event monitoring.

Parameters
[in]nameThe name of the histogram (and corresponding Variable)
[in]titleROOT histogram title string in format "title;xaxis;yaxis"
[in]xaxisControls if the x-axis should use fixed-width or logarithmic bin boundaries.
[in]minX-axis minimum bound.
[in]maxX-axis maximum bound.
[in]binsNumber of histogram bins.

Definition at line 70 of file CounterBase.cxx.

77{
78 std::string hisSvcName = getParent()->getParent()->getName() + "_" + getParent()->getName() + "_" + getName() + "_" + name;
79 std::unique_ptr<TProfile> hist;
80
81 if (max <= min || bins == 0) {
82 throw std::runtime_error("CounterBase::regTProfile: Cannot have max <= min or bins == 0");
83 }
84
85 if (xaxis == kLinear) {
86 hist = std::make_unique<TProfile>(hisSvcName.c_str(), title.c_str(), bins, min, max);
87 } else if (xaxis == kLog) {
88 if (min <= 0) {
89 throw std::runtime_error("CounterBase::regTProfile: Cannot have min <= 0 with log binning");
90 }
91 std::unique_ptr<double[]> xbins = std::make_unique<double[]>(bins+1);
92 const double xlogmin = log10(min);
93 const double xlogmax = log10(max);
94 const double dlogx = (xlogmax-xlogmin)/((double)bins);
95 for (size_t i = 0; i <= bins; ++i) {
96 const double xlog = xlogmin + i*dlogx;
97 xbins[i] = exp( log(10) * xlog );
98 }
99 hist = std::make_unique<TProfile>(hisSvcName.c_str(), title.c_str(), bins, xbins.get());
100 } else {
101 throw std::runtime_error("CounterBase::regTProfile: Unknown logarithm flag");
102 }
103
104 m_variables.emplace(std::piecewise_construct,
105 std::forward_as_tuple(name),
106 std::forward_as_tuple(name, bookGetPointer(hist.release()), type)
107 );
108 // Histogram is now owned by THistSvc. A cache of the ptr is kept in the Variable
109}

◆ setAllThreadsTimestamps()

void CounterThread::setAllThreadsTimestamps ( uint64_t low,
uint64_t high )

Set the low and high timestamps over all threads.

Definition at line 107 of file CounterThread.cxx.

107 {
110}

◆ setDenominator()

StatusCode CounterBase::setDenominator ( const std::string & name,
float value )
inherited

Optional for per-Event Variables.

Sets a denominator to divide the value through by before filling.

Parameters
[in]nameVariable to set the denominator for.
[in]valueThe denominator

Definition at line 212 of file CounterBase.cxx.

212 {
213 auto it = m_variables.find(name);
214 if (it == m_variables.end()) {
215 return StatusCode::FAILURE;
216 }
217 it->second.setDenominator(value);
218 return StatusCode::SUCCESS;
219}

◆ timeToMilliSec()

float CounterBase::timeToMilliSec ( const uint64_t start,
const uint64_t stop ) const
protectedinherited

Helper function.

Compute the time difference in discreet microseconds and covert to fractional milliseconds.

Returns
Time difference in milliseconds, floating point.

Definition at line 245 of file CounterBase.cxx.

245 {
246 if (stop < start) {
247 throw std::runtime_error("Asked for a stop time " + std::to_string(stop) + " which is before the start time " + std::to_string(start));
248 }
249 const uint64_t difference = stop - start;
250 return (difference * 1e-3); // micro to ms
251}
difference(file_1="Geometry_1.json", file_2="Geometry_2.json", output_file="Geometry_diff.json")

◆ variableExists()

bool CounterBase::variableExists ( const std::string & name) const
inherited

Check if a variable of a given name exists.

Parameters
[in]nameName of Variable.
Returns
True if variable already exists.

Definition at line 180 of file CounterBase.cxx.

180 {
181 return m_variables.contains(name);
182}

Member Data Documentation

◆ m_globalHighTimestamp

uint64_t CounterThread::m_globalHighTimestamp

Records the highest timestamp seen over all threads in an event.

Definition at line 76 of file CounterThread.h.

◆ m_globalLowTimestamp

uint64_t CounterThread::m_globalLowTimestamp

Records the lowest timestamp seen over all threads in an event.

Definition at line 75 of file CounterThread.h.

◆ m_highTimestamp

uint64_t CounterThread::m_highTimestamp

Records the highest timestamp seen on this single thread in an event.

Definition at line 73 of file CounterThread.h.

◆ m_lowTimestamp

uint64_t CounterThread::m_lowTimestamp

Records the lowest timestamp seen on this single thread in an event.

Definition at line 72 of file CounterThread.h.

◆ m_name

const std::string CounterBase::m_name
privateinherited

Counter's name.

Definition at line 210 of file CounterBase.h.

◆ m_parent

const MonitorBase* CounterBase::m_parent {}
privateinherited

Counter's parent Monitor.

Cached non-owning const pointer.

Definition at line 211 of file CounterBase.h.

211{};

◆ m_variables

std::unordered_map< std::string, Variable, CxxUtils::TransparentStringHash, std::equal_to<> > CounterBase::m_variables
privateinherited

Store of Counter's Variables.

These wrap a histogram pointer. Keyed by name.

Definition at line 212 of file CounterBase.h.


The documentation for this class was generated from the following files: