CMS 3D CMS Logo

List of all members | Public Member Functions | Public Attributes
evf::FastMonitoringThread::MonitorData Struct Reference

#include <FastMonitoringThread.h>

Public Member Functions

 MonitorData ()
 
void registerVariables (jsoncollector::FastMonitor *fm, unsigned int nStreams, unsigned int nThreads)
 

Public Attributes

jsoncollector::DoubleJ fastAvgLeadTimeJ_
 
jsoncollector::IntJ fastEventsProcessedJ_
 
jsoncollector::IntJ fastFilesProcessedJ_
 
jsoncollector::IntJ fastLockCountJ_
 
jsoncollector::DoubleJ fastLockWaitJ_
 
jsoncollector::IntJ fastMacrostateJ_
 
jsoncollector::IntJ fastPathProcessedJ_
 
jsoncollector::DoubleJ fastThroughputJ_
 
std::vector< unsigned int > inputState_
 
unsigned int inputstateBins_
 
unsigned int macrostateBins_
 
unsigned int microstateBins_
 
std::vector< unsigned int > microstateEncoded_
 
unsigned int ministateBins_
 
std::vector< unsigned int > ministateEncoded_
 
std::vector< jsoncollector::AtomicMonUInt * > processed_
 
std::vector< unsigned int > streamLumi_
 
std::vector< unsigned int > threadMicrostateEncoded_
 
unsigned int varIndexThrougput_
 

Detailed Description

Definition at line 41 of file FastMonitoringThread.h.

Constructor & Destructor Documentation

evf::FastMonitoringThread::MonitorData::MonitorData ( )
inline

Definition at line 73 of file FastMonitoringThread.h.

References jsoncollector::JsonMonitorable::setName(), and evf::FastMonitoringThread::sInit.

73  {
74 
76  fastThroughputJ_ = 0;
79  fastLockWaitJ_ = 0;
80  fastLockCountJ_ = 0;
81  fastMacrostateJ_.setName("Macrostate");
82  fastThroughputJ_.setName("Throughput");
83  fastAvgLeadTimeJ_.setName("AverageLeadTime");
84  fastFilesProcessedJ_.setName("FilesProcessed");
85  fastLockWaitJ_.setName("LockWaitUs");
86  fastLockCountJ_.setName("LockCount");
87 
89  fastPathProcessedJ_.setName("Processed");
90  }
virtual void setName(std::string name)

Member Function Documentation

void evf::FastMonitoringThread::MonitorData::registerVariables ( jsoncollector::FastMonitor fm,
unsigned int  nStreams,
unsigned int  nThreads 
)
inline

Definition at line 93 of file FastMonitoringThread.h.

References jsoncollector::FastMonitor::commit(), mps_fire::i, AlCaHLTBitMon_ParallelJobs::p, jsoncollector::FastMonitor::registerFastGlobalMonitorable(), jsoncollector::FastMonitor::registerGlobalMonitorable(), jsoncollector::FastMonitor::registerStreamMonitorableUIntVec(), and jsoncollector::FastMonitor::registerStreamMonitorableUIntVecAtomic().

Referenced by evf::FastMonitoringService::preBeginJob().

93  {
94  //tell FM to track these global variables(for fast and slow monitoring)
101 
102  for (unsigned int i=0;i<nStreams;i++) {
104  *p=0;
105  processed_.push_back(p);
106  streamLumi_.push_back(0);
107  }
108 
109  microstateEncoded_.resize(nStreams);
110  ministateEncoded_.resize(nStreams);
112  inputState_.resize(nStreams);
113  for (unsigned int j=0;j<inputState_.size();j++) inputState_[j]=0;
114 
115  //tell FM to track these int vectors
117 
118  if (nThreads<=nStreams)//no overlapping in module execution per stream
120  else
122 
123  fm->registerStreamMonitorableUIntVecAtomic("Processed",&processed_,false,nullptr);
124 
125  //input source state tracking (not stream, but other than first item in vector is set to Ignore state)
127 
128  //global cumulative event counter is used for fast path
130 
131  //provide vector with updated per stream lumis and let it finish initialization
132  fm->commit(&streamLumi_);
133  }
void registerFastGlobalMonitorable(JsonMonitorable *newMonitorable)
Definition: FastMonitor.cc:76
void registerStreamMonitorableUIntVecAtomic(std::string const &name, std::vector< AtomicMonUInt * > *inputs, bool NAifZeroUpdates, unsigned int *nBins=nullptr)
Definition: FastMonitor.cc:96
void registerGlobalMonitorable(JsonMonitorable *newMonitorable, bool NAifZeroUpdates, unsigned int *nBins=nullptr)
Definition: FastMonitor.cc:63
std::vector< unsigned int > threadMicrostateEncoded_
void registerStreamMonitorableUIntVec(std::string const &name, std::vector< unsigned int > *inputs, bool NAifZeroUpdates, unsigned int *nBins=nullptr)
Definition: FastMonitor.cc:84
void commit(std::vector< unsigned int > *streamLumisPtr)
Definition: FastMonitor.cc:110
unsigned int AtomicMonUInt
Definition: DataPoint.h:31
std::vector< unsigned int > microstateEncoded_
std::vector< jsoncollector::AtomicMonUInt * > processed_
std::vector< unsigned int > streamLumi_
std::vector< unsigned int > inputState_
std::vector< unsigned int > ministateEncoded_

Member Data Documentation

jsoncollector::DoubleJ evf::FastMonitoringThread::MonitorData::fastAvgLeadTimeJ_

Definition at line 46 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

jsoncollector::IntJ evf::FastMonitoringThread::MonitorData::fastEventsProcessedJ_

Definition at line 50 of file FastMonitoringThread.h.

jsoncollector::IntJ evf::FastMonitoringThread::MonitorData::fastFilesProcessedJ_

Definition at line 47 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

jsoncollector::IntJ evf::FastMonitoringThread::MonitorData::fastLockCountJ_

Definition at line 49 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

jsoncollector::DoubleJ evf::FastMonitoringThread::MonitorData::fastLockWaitJ_

Definition at line 48 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

jsoncollector::IntJ evf::FastMonitoringThread::MonitorData::fastMacrostateJ_

Definition at line 44 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

jsoncollector::IntJ evf::FastMonitoringThread::MonitorData::fastPathProcessedJ_

Definition at line 58 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::postEvent().

jsoncollector::DoubleJ evf::FastMonitoringThread::MonitorData::fastThroughputJ_

Definition at line 45 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::preGlobalEndLumi().

std::vector<unsigned int> evf::FastMonitoringThread::MonitorData::inputState_

Definition at line 60 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

unsigned int evf::FastMonitoringThread::MonitorData::inputstateBins_

Definition at line 69 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::preBeginJob().

unsigned int evf::FastMonitoringThread::MonitorData::macrostateBins_

Definition at line 66 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::preBeginJob().

unsigned int evf::FastMonitoringThread::MonitorData::microstateBins_
std::vector<unsigned int> evf::FastMonitoringThread::MonitorData::microstateEncoded_

Definition at line 55 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

unsigned int evf::FastMonitoringThread::MonitorData::ministateBins_
std::vector<unsigned int> evf::FastMonitoringThread::MonitorData::ministateEncoded_

Definition at line 56 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot().

std::vector<jsoncollector::AtomicMonUInt*> evf::FastMonitoringThread::MonitorData::processed_
std::vector<unsigned int> evf::FastMonitoringThread::MonitorData::streamLumi_
std::vector<unsigned int> evf::FastMonitoringThread::MonitorData::threadMicrostateEncoded_

Definition at line 59 of file FastMonitoringThread.h.

unsigned int evf::FastMonitoringThread::MonitorData::varIndexThrougput_

Definition at line 52 of file FastMonitoringThread.h.