evf::FastMonitoringThread Class Reference

#include <FastMonitoringThread.h>

Classes
struct	MonitorData

Public Types
enum	InputState {   inIgnore = 0, inInit, inWaitInput, inNewLumi,   inNewLumiBusyEndingLS, inNewLumiIdleEndingLS, inRunEnd, inProcessingFile,   inWaitChunk, inChunkReceived, inChecksumEvent, inCachedEvent,   inReadEvent, inReadCleanup, inNoRequest, inNoRequestWithIdleThreads,   inNoRequestWithGlobalEoL, inNoRequestWithEoLThreads, inSupFileLimit, inSupWaitFreeChunk,   inSupWaitFreeChunkCopying, inSupWaitFreeThread, inSupWaitFreeThreadCopying, inSupBusy,   inSupLockPolling, inSupLockPollingCopying, inSupNoFile, inSupNewFile,   inSupNewFileWaitThreadCopying, inSupNewFileWaitThread, inSupNewFileWaitChunkCopying, inSupNewFileWaitChunk,   inWaitInput_fileLimit, inWaitInput_waitFreeChunk, inWaitInput_waitFreeChunkCopying, inWaitInput_waitFreeThread,   inWaitInput_waitFreeThreadCopying, inWaitInput_busy, inWaitInput_lockPolling, inWaitInput_lockPollingCopying,   inWaitInput_runEnd, inWaitInput_noFile, inWaitInput_newFile, inWaitInput_newFileWaitThreadCopying,   inWaitInput_newFileWaitThread, inWaitInput_newFileWaitChunkCopying, inWaitInput_newFileWaitChunk, inWaitChunk_fileLimit,   inWaitChunk_waitFreeChunk, inWaitChunk_waitFreeChunkCopying, inWaitChunk_waitFreeThread, inWaitChunk_waitFreeThreadCopying,   inWaitChunk_busy, inWaitChunk_lockPolling, inWaitChunk_lockPollingCopying, inWaitChunk_runEnd,   inWaitChunk_noFile, inWaitChunk_newFile, inWaitChunk_newFileWaitThreadCopying, inWaitChunk_newFileWaitThread,   inWaitChunk_newFileWaitChunkCopying, inWaitChunk_newFileWaitChunk, inCOUNT }
enum	Macrostate {   sInit = 0, sJobReady, sRunGiven, sRunning,   sStopping, sShuttingDown, sDone, sJobEnded,   sError, sErrorEnded, sEnd, sInvalid,   MCOUNT }

Public Member Functions
	FastMonitoringThread ()
void	resetFastMonitor (std::string const &microStateDefPath, std::string const &fastMicroStateDefPath)
void	start (void(FastMonitoringService::*fp)(), FastMonitoringService *cp)
void	stop ()

Private Attributes
std::unique_ptr< jsoncollector::FastMonitor >	jsonMonitor_
MonitorData	m_data
std::atomic< bool >	m_stoprequest
std::shared_ptr< std::thread >	m_thread
std::mutex	monlock_

Friends
class	FastMonitoringService

Detailed Description

Definition at line 15 of file FastMonitoringThread.h.

Member Enumeration Documentation

enum evf::FastMonitoringThread::InputState

Enumerator
inIgnore
inInit
inWaitInput
inNewLumi
inNewLumiBusyEndingLS
inNewLumiIdleEndingLS
inRunEnd
inProcessingFile
inWaitChunk
inChunkReceived
inChecksumEvent
inCachedEvent
inReadEvent
inReadCleanup
inNoRequest
inNoRequestWithIdleThreads
inNoRequestWithGlobalEoL
inNoRequestWithEoLThreads
inSupFileLimit
inSupWaitFreeChunk
inSupWaitFreeChunkCopying
inSupWaitFreeThread
inSupWaitFreeThreadCopying
inSupBusy
inSupLockPolling
inSupLockPollingCopying
inSupNoFile
inSupNewFile
inSupNewFileWaitThreadCopying
inSupNewFileWaitThread
inSupNewFileWaitChunkCopying
inSupNewFileWaitChunk
inWaitInput_fileLimit
inWaitInput_waitFreeChunk
inWaitInput_waitFreeChunkCopying
inWaitInput_waitFreeThread
inWaitInput_waitFreeThreadCopying
inWaitInput_busy
inWaitInput_lockPolling
inWaitInput_lockPollingCopying
inWaitInput_runEnd
inWaitInput_noFile
inWaitInput_newFile
inWaitInput_newFileWaitThreadCopying
inWaitInput_newFileWaitThread
inWaitInput_newFileWaitChunkCopying
inWaitInput_newFileWaitChunk
inWaitChunk_fileLimit
inWaitChunk_waitFreeChunk
inWaitChunk_waitFreeChunkCopying
inWaitChunk_waitFreeThread
inWaitChunk_waitFreeThreadCopying
inWaitChunk_busy
inWaitChunk_lockPolling
inWaitChunk_lockPollingCopying
inWaitChunk_runEnd
inWaitChunk_noFile
inWaitChunk_newFile
inWaitChunk_newFileWaitThreadCopying
inWaitChunk_newFileWaitThread
inWaitChunk_newFileWaitChunkCopying
inWaitChunk_newFileWaitChunk
inCOUNT

Definition at line 34 of file FastMonitoringThread.h.

                    {
      inIgnore = 0,
      inInit,
      inWaitInput,
      inNewLumi,
      inNewLumiBusyEndingLS,
      inNewLumiIdleEndingLS,
      inRunEnd,
      inProcessingFile,
      inWaitChunk,
      inChunkReceived,
      inChecksumEvent,
      inCachedEvent,
      inReadEvent,
      inReadCleanup,
      inNoRequest,
      inNoRequestWithIdleThreads,
      inNoRequestWithGlobalEoL,
      inNoRequestWithEoLThreads,
      //supervisor thread and worker threads state
      inSupFileLimit,
      inSupWaitFreeChunk,
      inSupWaitFreeChunkCopying,
      inSupWaitFreeThread,
      inSupWaitFreeThreadCopying,
      inSupBusy,
      inSupLockPolling,
      inSupLockPollingCopying,
      inSupNoFile,
      inSupNewFile,
      inSupNewFileWaitThreadCopying,
      inSupNewFileWaitThread,
      inSupNewFileWaitChunkCopying,
      inSupNewFileWaitChunk,
      //combined with inWaitInput
      inWaitInput_fileLimit,
      inWaitInput_waitFreeChunk,
      inWaitInput_waitFreeChunkCopying,
      inWaitInput_waitFreeThread,
      inWaitInput_waitFreeThreadCopying,
      inWaitInput_busy,
      inWaitInput_lockPolling,
      inWaitInput_lockPollingCopying,
      inWaitInput_runEnd,
      inWaitInput_noFile,
      inWaitInput_newFile,
      inWaitInput_newFileWaitThreadCopying,
      inWaitInput_newFileWaitThread,
      inWaitInput_newFileWaitChunkCopying,
      inWaitInput_newFileWaitChunk,
      //combined with inWaitChunk
      inWaitChunk_fileLimit,
      inWaitChunk_waitFreeChunk,
      inWaitChunk_waitFreeChunkCopying,
      inWaitChunk_waitFreeThread,
      inWaitChunk_waitFreeThreadCopying,
      inWaitChunk_busy,
      inWaitChunk_lockPolling,
      inWaitChunk_lockPollingCopying,
      inWaitChunk_runEnd,
      inWaitChunk_noFile,
      inWaitChunk_newFile,
      inWaitChunk_newFileWaitThreadCopying,
      inWaitChunk_newFileWaitThread,
      inWaitChunk_newFileWaitChunkCopying,
      inWaitChunk_newFileWaitChunk,
      inCOUNT
    };

enum evf::FastMonitoringThread::Macrostate

Enumerator
sInit
sJobReady
sRunGiven
sRunning
sStopping
sShuttingDown
sDone
sJobEnded
sError
sErrorEnded
sEnd
sInvalid
MCOUNT

Definition at line 18 of file FastMonitoringThread.h.

                    {
      sInit = 0,
      sJobReady,
      sRunGiven,
      sRunning,
      sStopping,
      sShuttingDown,
      sDone,
      sJobEnded,
      sError,
      sErrorEnded,
      sEnd,
      sInvalid,
      MCOUNT
    };

Constructor & Destructor Documentation

evf::FastMonitoringThread::FastMonitoringThread ( )

inline

Definition at line 198 of file FastMonitoringThread.h.

: m_stoprequest(false) {}

Member Function Documentation

void evf::FastMonitoringThread::resetFastMonitor ( std::string const &  microStateDefPath, std::string const &  fastMicroStateDefPath  )

inline

Definition at line 200 of file FastMonitoringThread.h.

References jsonMonitor_, and AlCaHLTBitMon_QueryRunRegistry::string.

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

                                                                                                      {
      std::string defGroup = "data";
      jsonMonitor_.reset(new jsoncollector::FastMonitor(microStateDefPath, defGroup, false));
      if (!fastMicroStateDefPath.empty())
        jsonMonitor_->addFastPathDefinition(fastMicroStateDefPath, defGroup, false);
    }

void evf::FastMonitoringThread::start ( void(FastMonitoringService::*)()  fp, FastMonitoringService *  cp  )

inline

Definition at line 207 of file FastMonitoringThread.h.

References SimDataFormats::CaloAnalysis::cp, personalPlayback::fp, and m_thread.

Referenced by progressbar.ProgressBar::__next__(), Types.LuminosityBlockRange::cppID(), Types.EventRange::cppID(), and evf::FastMonitoringService::preBeginJob().

                                                                             {
      assert(!m_thread);
      m_thread = std::make_shared<std::thread>(fp, cp);
    }

void evf::FastMonitoringThread::stop ( )

inline

Definition at line 211 of file FastMonitoringThread.h.

References m_stoprequest, and m_thread.

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

                {
      assert(m_thread);
      m_stoprequest = true;
      m_thread->join();
    }

Friends And Related Function Documentation

friend class FastMonitoringService

friend

Definition at line 225 of file FastMonitoringThread.h.

Member Data Documentation

std::unique_ptr<jsoncollector::FastMonitor> evf::FastMonitoringThread::jsonMonitor_

private

Definition at line 223 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot(), evf::FastMonitoringService::preBeginJob(), evf::FastMonitoringService::preGlobalEndLumi(), and resetFastMonitor().

MonitorData evf::FastMonitoringThread::m_data

private

Definition at line 220 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::doSnapshot(), evf::FastMonitoringService::postBeginJob(), evf::FastMonitoringService::postEvent(), evf::FastMonitoringService::preBeginJob(), evf::FastMonitoringService::preGlobalEndLumi(), evf::FastMonitoringService::prePathEvent(), and evf::FastMonitoringService::preStreamBeginLumi().

std::atomic<bool> evf::FastMonitoringThread::m_stoprequest

private

Definition at line 218 of file FastMonitoringThread.h.

Referenced by stop().

std::shared_ptr<std::thread> evf::FastMonitoringThread::m_thread

private

Definition at line 219 of file FastMonitoringThread.h.

Referenced by start(), and stop().

std::mutex evf::FastMonitoringThread::monlock_

private

Definition at line 221 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::accumulateFileSize(), evf::FastMonitoringService::getAbortFlagForLumi(), evf::FastMonitoringService::getEventsProcessedForLumi(), evf::FastMonitoringService::postBeginJob(), evf::FastMonitoringService::postGlobalEndLumi(), evf::FastMonitoringService::preGlobalBeginLumi(), evf::FastMonitoringService::preGlobalEarlyTermination(), evf::FastMonitoringService::preGlobalEndLumi(), evf::FastMonitoringService::preModuleBeginJob(), evf::FastMonitoringService::prePathEvent(), evf::FastMonitoringService::preSourceEarlyTermination(), evf::FastMonitoringService::preStreamBeginLumi(), evf::FastMonitoringService::preStreamEarlyTermination(), evf::FastMonitoringService::preStreamEndLumi(), evf::FastMonitoringService::reportLockWait(), and evf::FastMonitoringService::stoppedLookingForFile().