#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	fastFilesProcessedJ_

jsoncollector::IntJ	fastLockCountJ_

jsoncollector::DoubleJ	fastLockWaitJ_

jsoncollector::IntJ	fastMacrostateJ_

jsoncollector::IntJ	fastPathProcessedJ_

jsoncollector::DoubleJ	fastThroughputJ_

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 21 of file FastMonitoringThread.h.

Constructor & Destructor Documentation

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

inline

Definition at line 50 of file FastMonitoringThread.h.

References fastAvgLeadTimeJ_, fastFilesProcessedJ_, fastLockCountJ_, fastLockWaitJ_, fastMacrostateJ_, fastPathProcessedJ_, fastThroughputJ_, jsoncollector::JsonMonitorable::setName(), and evf::FastMonitoringThread::sInit.

                     {
 
     fastMacrostateJ_ = FastMonitoringThread::sInit;
     fastThroughputJ_ = 0;
     fastAvgLeadTimeJ_ = 0;
     fastFilesProcessedJ_ = 0;
         fastLockWaitJ_ = 0;
         fastLockCountJ_ = 0;
         fastMacrostateJ_.setName("Macrostate");
         fastThroughputJ_.setName("Throughput");
         fastAvgLeadTimeJ_.setName("AverageLeadTime");
     fastFilesProcessedJ_.setName("FilesProcessed");
     fastLockWaitJ_.setName("LockWaitUs");
     fastLockCountJ_.setName("LockCount");
 
         fastPathProcessedJ_ = 0;
         fastPathProcessedJ_.setName("Processed");
       }

Member Function Documentation

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

inline

Definition at line 70 of file FastMonitoringThread.h.

References jsoncollector::FastMonitor::commit(), fastAvgLeadTimeJ_, fastFilesProcessedJ_, fastLockCountJ_, fastLockWaitJ_, fastMacrostateJ_, fastPathProcessedJ_, fastThroughputJ_, i, macrostateBins_, microstateBins_, microstateEncoded_, ministateBins_, ministateEncoded_, AlCaHLTBitMon_ParallelJobs::p, processed_, jsoncollector::FastMonitor::registerFastGlobalMonitorable(), jsoncollector::FastMonitor::registerGlobalMonitorable(), jsoncollector::FastMonitor::registerStreamMonitorableUIntVec(), jsoncollector::FastMonitor::registerStreamMonitorableUIntVecAtomic(), streamLumi_, and threadMicrostateEncoded_.

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

                                                                                                          {
     //tell FM to track these global variables(for fast and slow monitoring)
         fm->registerGlobalMonitorable(&fastMacrostateJ_,true,&macrostateBins_);
         fm->registerGlobalMonitorable(&fastThroughputJ_,false);
         fm->registerGlobalMonitorable(&fastAvgLeadTimeJ_,false);
         fm->registerGlobalMonitorable(&fastFilesProcessedJ_,false);
         fm->registerGlobalMonitorable(&fastLockWaitJ_,false);
         fm->registerGlobalMonitorable(&fastLockCountJ_,false);
 
     for (unsigned int i=0;i<nStreams;i++) {
      jsoncollector::AtomicMonUInt * p  = new jsoncollector::AtomicMonUInt;
      *p=0;
       processed_.push_back(p);
           streamLumi_.push_back(0);
     }
     
     microstateEncoded_.resize(nStreams);
     ministateEncoded_.resize(nStreams);
     threadMicrostateEncoded_.resize(nThreads);
 
     //tell FM to track these int vectors
         fm->registerStreamMonitorableUIntVec("Ministate", &ministateEncoded_,true,&ministateBins_);
 
     if (nThreads<=nStreams)//no overlapping in module execution per stream
           fm->registerStreamMonitorableUIntVec("Microstate",&microstateEncoded_,true,&microstateBins_);
     else
       fm->registerStreamMonitorableUIntVec("Microstate",&threadMicrostateEncoded_,true,&microstateBins_);
 
         fm->registerStreamMonitorableUIntVecAtomic("Processed",&processed_,false,0);
 
         //global cumulative event counter is used for fast path
         fm->registerFastGlobalMonitorable(&fastPathProcessedJ_);
 
     //provide vector with updated per stream lumis and let it finish initialization
     fm->commit(&streamLumi_);
       }