#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

◆ InputState

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
     };

◆ Macrostate

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

◆ FastMonitoringThread()

evf::FastMonitoringThread::FastMonitoringThread ( )

inline

Definition at line 198 of file FastMonitoringThread.h.

198 : m_stoprequest(false) {}

Member Function Documentation

◆ resetFastMonitor()

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

inline

Definition at line 200 of file FastMonitoringThread.h.

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

References jsonMonitor_, and AlCaHLTBitMon_QueryRunRegistry::string.

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

◆ start()

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

inline

Definition at line 207 of file FastMonitoringThread.h.

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

References cms::cuda::assert(), CommonMethods::cp(), personalPlayback::fp, and m_thread.

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

◆ stop()

void evf::FastMonitoringThread::stop ( )

inline

Definition at line 211 of file FastMonitoringThread.h.

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

References cms::cuda::assert(), m_stoprequest, and m_thread.

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

Friends And Related Function Documentation

◆ FastMonitoringService

friend class FastMonitoringService

friend

Definition at line 225 of file FastMonitoringThread.h.

Member Data Documentation

◆ jsonMonitor_

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

private

Definition at line 223 of file FastMonitoringThread.h.

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

◆ m_data

MonitorData evf::FastMonitoringThread::m_data

private

Definition at line 220 of file FastMonitoringThread.h.

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

◆ m_stoprequest

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

private

Definition at line 218 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::dowork(), and stop().

◆ m_thread

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

private

Definition at line 219 of file FastMonitoringThread.h.

Referenced by start(), and stop().

◆ monlock_

std::mutex evf::FastMonitoringThread::monlock_

private

Definition at line 221 of file FastMonitoringThread.h.

Classes

Public Types

Public Member Functions

Private Attributes

Friends

Detailed Description

Member Enumeration Documentation

◆ InputState

◆ Macrostate

Constructor & Destructor Documentation

◆ FastMonitoringThread()

Member Function Documentation

◆ resetFastMonitor()

◆ start()

◆ stop()

Friends And Related Function Documentation

◆ FastMonitoringService

Member Data Documentation

◆ jsonMonitor_

◆ m_data

◆ m_stoprequest

◆ m_thread

◆ monlock_