#include <FastMonitor.h>
Public Member Functions | |
void | addFastPathDefinition (std::string const &defPathFast, std::string const defGroupFast, bool strict) |
void | commit (std::vector< unsigned int > *streamLumisPtr) |
void | discardCollected (unsigned int forLumi) |
FastMonitor (std::string const &defPath, std::string const defGroup, bool strictChecking, bool useSource=true, bool useDefinition=true) | |
FastMonitor (DataPointDefinition *dpd, bool strictChecking, bool useSource=true, bool useDefinition=true) | |
std::string | getCSVString (int sid=-1) |
void | getHostAndPID (std::string &sHPid) |
JsonMonitorable * | getMergedIntJForLumi (std::string const &name, unsigned int forLumi) |
void | outputCSV (std::string const &path, std::string const &csvString) |
bool | outputFullJSON (std::string const &path, unsigned int lumi) |
bool | outputFullJSONs (std::string const &pathstem, std::string const &ext, unsigned int lumi) |
void | registerFastGlobalMonitorable (JsonMonitorable *newMonitorable) |
void | registerGlobalMonitorable (JsonMonitorable *newMonitorable, bool NAifZeroUpdates, unsigned int *nBins=nullptr) |
void | registerStreamMonitorableUIntVec (std::string const &name, std::vector< unsigned int > *inputs, bool NAifZeroUpdates, unsigned int *nBins=nullptr) |
void | registerStreamMonitorableUIntVecAtomic (std::string const &name, std::vector< AtomicMonUInt * > *inputs, bool NAifZeroUpdates, unsigned int *nBins=nullptr) |
void | setDefPath (std::string const &dpath) |
void | setNStreams (unsigned int nStreams) |
void | snap (unsigned int ls) |
void | snapGlobal (unsigned int ls) |
void | snapStreamAtomic (unsigned int ls, unsigned int streamID) |
virtual | ~FastMonitor () |
Private Attributes | |
std::vector< DataPoint * > | dataPoints_ |
std::vector< DataPoint * > | dataPointsFastOnly_ |
std::string | defPath_ |
std::string | defPathFast_ |
bool | deleteDef_ =false |
bool | deleteDefFast_ =false |
DataPointDefinition * | dpd_ |
DataPointDefinition * | dpdFast_ |
std::map< std::string, unsigned int > | dpNameMap_ |
bool | fastPathStrictChecking_ |
unsigned int | fregDpCount_ = 0 |
bool | haveFastPath_ =false |
std::vector< unsigned int > | jsonDpIndex_ |
std::vector< DataPoint * > | jsonDpIndexFast_ |
unsigned int | nStreams_ |
std::vector< DataPoint * > | orphanedDps_ |
unsigned int | recentSnaps_ = 0 |
unsigned int | recentSnapsTimer_ = 0 |
unsigned int | regDpCount_ = 0 |
std::string | sourceInfo_ |
bool | strictChecking_ |
std::unordered_set< std::string > | uids_ |
bool | useDefinition_ |
bool | useSource_ |
Definition at line 19 of file FastMonitor.h.
FastMonitor::FastMonitor | ( | std::string const & | defPath, |
std::string const | defGroup, | ||
bool | strictChecking, | ||
bool | useSource = true , |
||
bool | useDefinition = true |
||
) |
Definition at line 23 of file FastMonitor.cc.
References defPath_, dpd_, jsoncollector::DataPointDefinition::getDataPointDefinitionFor(), getHostAndPID(), and sourceInfo_.
FastMonitor::FastMonitor | ( | DataPointDefinition * | dpd, |
bool | strictChecking, | ||
bool | useSource = true , |
||
bool | useDefinition = true |
||
) |
Definition at line 37 of file FastMonitor.cc.
References getHostAndPID(), and sourceInfo_.
|
virtual |
Definition at line 45 of file FastMonitor.cc.
References dataPoints_, deleteDef_, deleteDefFast_, reco::dp, dpd_, and dpdFast_.
void FastMonitor::addFastPathDefinition | ( | std::string const & | defPathFast, |
std::string const | defGroupFast, | ||
bool | strict | ||
) |
Definition at line 52 of file FastMonitor.cc.
References defPathFast_, deleteDefFast_, dpdFast_, fastPathStrictChecking_, jsoncollector::DataPointDefinition::getDataPointDefinitionFor(), and haveFastPath_.
void FastMonitor::commit | ( | std::vector< unsigned int > * | streamLumisPtr | ) |
Definition at line 110 of file FastMonitor.cc.
References assert(), dataPoints_, dataPointsFastOnly_, defPath_, defPathFast_, dpd_, dpdFast_, fastPathStrictChecking_, fregDpCount_, jsoncollector::DataPointDefinition::getNames(), jsoncollector::DataPointDefinition::getOperationFor(), haveFastPath_, i, j, jsonDpIndex_, jsonDpIndexFast_, regDpCount_, sourceInfo_, strictChecking_, and jsoncollector::DataPoint::trackDummy().
Referenced by RawEventFileWriterForBU::RawEventFileWriterForBU(), and evf::FastMonitoringThread::MonitorData::registerVariables().
void FastMonitor::discardCollected | ( | unsigned int | forLumi | ) |
Definition at line 290 of file FastMonitor.cc.
References dataPoints_, and reco::dp.
Referenced by RawEventFileWriterForBU::endOfLS(), and RawEventFileWriterForBU::finishFileWrite().
std::string FastMonitor::getCSVString | ( | int | sid = -1 | ) |
Definition at line 218 of file FastMonitor.cc.
References j, jsonDpIndexFast_, and contentValuesCheck::ss.
void FastMonitor::getHostAndPID | ( | std::string & | sHPid | ) |
Definition at line 295 of file FastMonitor.cc.
References sysUtil::pid.
Referenced by FastMonitor().
JsonMonitorable * FastMonitor::getMergedIntJForLumi | ( | std::string const & | name, |
unsigned int | forLumi | ||
) |
Definition at line 243 of file FastMonitor.cc.
References assert(), dataPoints_, and dpNameMap_.
void FastMonitor::outputCSV | ( | std::string const & | path, |
std::string const & | csvString | ||
) |
Definition at line 232 of file FastMonitor.cc.
References defPathFast_, GenerateHcalLaserBadRunList::out, download_sqlite_cfg::outputFile, and estimatePileup_makeJSON::trunc.
bool FastMonitor::outputFullJSON | ( | std::string const & | path, |
unsigned int | lumi | ||
) |
Definition at line 273 of file FastMonitor.cc.
References dataPoints_, j, jsonDpIndex_, LogDebug, recentSnaps_, recentSnapsTimer_, mps_fire::result, AlCaHLTBitMon_QueryRunRegistry::string, Json::StyledWriter::write(), and jsoncollector::FileIO::writeStringToFile().
Referenced by RawEventFileWriterForBU::endOfLS(), RawEventFileWriterForBU::finishFileWrite(), RawEventFileWriterForBU::handler(), and RawEventFileWriterForBU::stop().
bool FastMonitor::outputFullJSONs | ( | std::string const & | pathstem, |
std::string const & | ext, | ||
unsigned int | lumi | ||
) |
Definition at line 250 of file FastMonitor.cc.
References dataPoints_, i, j, jsonDpIndex_, LogDebug, nStreams_, fed_dqm_sourceclient-live_cfg::path, recentSnaps_, recentSnapsTimer_, mps_fire::result, AlCaHLTBitMon_QueryRunRegistry::string, Json::StyledWriter::write(), and jsoncollector::FileIO::writeStringToFile().
void FastMonitor::registerFastGlobalMonitorable | ( | JsonMonitorable * | newMonitorable | ) |
Definition at line 76 of file FastMonitor.cc.
References dataPointsFastOnly_, defPathFast_, reco::dp, sourceInfo_, and jsoncollector::DataPoint::trackMonitorable().
Referenced by evf::FastMonitoringThread::MonitorData::registerVariables().
void FastMonitor::registerGlobalMonitorable | ( | JsonMonitorable * | newMonitorable, |
bool | NAifZeroUpdates, | ||
unsigned int * | nBins = nullptr |
||
) |
Definition at line 63 of file FastMonitor.cc.
References assert(), dataPoints_, defPath_, reco::dp, dpNameMap_, jsoncollector::JsonMonitorable::getName(), edm::second(), jsoncollector::DataPoint::setNBins(), sourceInfo_, jsoncollector::DataPoint::trackMonitorable(), and uids_.
Referenced by RawEventFileWriterForBU::RawEventFileWriterForBU(), and evf::FastMonitoringThread::MonitorData::registerVariables().
void FastMonitor::registerStreamMonitorableUIntVec | ( | std::string const & | name, |
std::vector< unsigned int > * | inputs, | ||
bool | NAifZeroUpdates, | ||
unsigned int * | nBins = nullptr |
||
) |
Definition at line 84 of file FastMonitor.cc.
References assert(), dataPoints_, defPath_, reco::dp, dpNameMap_, mergeVDriftHistosByStation::name, jsoncollector::DataPoint::setNBins(), sourceInfo_, jsoncollector::DataPoint::trackVectorUInt(), and uids_.
Referenced by evf::FastMonitoringThread::MonitorData::registerVariables().
void FastMonitor::registerStreamMonitorableUIntVecAtomic | ( | std::string const & | name, |
std::vector< AtomicMonUInt * > * | inputs, | ||
bool | NAifZeroUpdates, | ||
unsigned int * | nBins = nullptr |
||
) |
Definition at line 96 of file FastMonitor.cc.
References assert(), dataPoints_, defPath_, reco::dp, dpNameMap_, mergeVDriftHistosByStation::name, jsoncollector::DataPoint::setNBins(), sourceInfo_, AlCaHLTBitMon_QueryRunRegistry::string, jsoncollector::DataPoint::trackVectorUIntAtomic(), uids_, and useDefinition_.
Referenced by evf::FastMonitoringThread::MonitorData::registerVariables().
|
inline |
Definition at line 30 of file FastMonitor.h.
References dataPoints_, defPath_, and reco::dp.
Referenced by RawEventFileWriterForBU::writeJsds().
|
inline |
void FastMonitor::snap | ( | unsigned int | ls | ) |
Definition at line 191 of file FastMonitor.cc.
References dataPoints_, i, recentSnaps_, recentSnapsTimer_, and regDpCount_.
Referenced by RawEventFileWriterForBU::endOfLS(), RawEventFileWriterForBU::finishFileWrite(), RawEventFileWriterForBU::handler(), and RawEventFileWriterForBU::stop().
void FastMonitor::snapGlobal | ( | unsigned int | ls | ) |
Definition at line 201 of file FastMonitor.cc.
References dataPoints_, i, recentSnaps_, and regDpCount_.
void FastMonitor::snapStreamAtomic | ( | unsigned int | ls, |
unsigned int | streamID | ||
) |
Definition at line 210 of file FastMonitor.cc.
References dataPoints_, i, recentSnaps_, and regDpCount_.
|
private |
Definition at line 101 of file FastMonitor.h.
Referenced by commit(), discardCollected(), getMergedIntJForLumi(), outputFullJSON(), outputFullJSONs(), registerGlobalMonitorable(), registerStreamMonitorableUIntVec(), registerStreamMonitorableUIntVecAtomic(), setDefPath(), snap(), snapGlobal(), snapStreamAtomic(), and ~FastMonitor().
|
private |
Definition at line 102 of file FastMonitor.h.
Referenced by commit(), and registerFastGlobalMonitorable().
|
private |
Definition at line 85 of file FastMonitor.h.
Referenced by commit(), FastMonitor(), registerGlobalMonitorable(), registerStreamMonitorableUIntVec(), registerStreamMonitorableUIntVecAtomic(), and setDefPath().
|
private |
Definition at line 86 of file FastMonitor.h.
Referenced by addFastPathDefinition(), commit(), outputCSV(), and registerFastGlobalMonitorable().
|
private |
Definition at line 98 of file FastMonitor.h.
Referenced by ~FastMonitor().
|
private |
Definition at line 99 of file FastMonitor.h.
Referenced by addFastPathDefinition(), and ~FastMonitor().
|
private |
Definition at line 96 of file FastMonitor.h.
Referenced by commit(), FastMonitor(), and ~FastMonitor().
|
private |
Definition at line 97 of file FastMonitor.h.
Referenced by addFastPathDefinition(), commit(), and ~FastMonitor().
|
private |
Definition at line 106 of file FastMonitor.h.
Referenced by getMergedIntJForLumi(), registerGlobalMonitorable(), registerStreamMonitorableUIntVec(), and registerStreamMonitorableUIntVecAtomic().
|
private |
Definition at line 88 of file FastMonitor.h.
Referenced by addFastPathDefinition(), and commit().
|
private |
Definition at line 111 of file FastMonitor.h.
Referenced by commit().
|
private |
Definition at line 91 of file FastMonitor.h.
Referenced by addFastPathDefinition(), and commit().
|
private |
Definition at line 103 of file FastMonitor.h.
Referenced by commit(), outputFullJSON(), and outputFullJSONs().
|
private |
Definition at line 104 of file FastMonitor.h.
Referenced by commit(), and getCSVString().
|
private |
Definition at line 93 of file FastMonitor.h.
Referenced by outputFullJSONs(), and setNStreams().
|
private |
Definition at line 105 of file FastMonitor.h.
|
private |
Definition at line 108 of file FastMonitor.h.
Referenced by outputFullJSON(), outputFullJSONs(), snap(), snapGlobal(), and snapStreamAtomic().
|
private |
Definition at line 109 of file FastMonitor.h.
Referenced by outputFullJSON(), outputFullJSONs(), and snap().
|
private |
Definition at line 110 of file FastMonitor.h.
Referenced by commit(), snap(), snapGlobal(), and snapStreamAtomic().
|
private |
Definition at line 95 of file FastMonitor.h.
Referenced by commit(), FastMonitor(), registerFastGlobalMonitorable(), registerGlobalMonitorable(), registerStreamMonitorableUIntVec(), and registerStreamMonitorableUIntVecAtomic().
|
private |
Definition at line 87 of file FastMonitor.h.
Referenced by commit().
|
private |
Definition at line 113 of file FastMonitor.h.
Referenced by registerGlobalMonitorable(), registerStreamMonitorableUIntVec(), and registerStreamMonitorableUIntVecAtomic().
|
private |
Definition at line 90 of file FastMonitor.h.
Referenced by registerStreamMonitorableUIntVecAtomic().
|
private |
Definition at line 89 of file FastMonitor.h.