evf::FastMonitoringThread Class Reference

#include <FastMonitoringThread.h>

Classes
struct	MonitorData

Public Types
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
boost::shared_ptr< std::thread >	m_thread
std::mutex	monlock_

Friends
class	FastMonitoringService

Detailed Description

Definition at line 16 of file FastMonitoringThread.h.

Member Enumeration Documentation

enum evf::FastMonitoringThread::Macrostate

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

Definition at line 19 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 109 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 112 of file FastMonitoringThread.h.

References jsonMonitor_, and AlCaHLTBitMon_QueryRunRegistry::string.

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

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

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

inline

Definition at line 119 of file FastMonitoringThread.h.

References assert(), and m_thread.

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

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

void evf::FastMonitoringThread::stop ( )

inline

Definition at line 123 of file FastMonitoringThread.h.

References assert(), 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 138 of file FastMonitoringThread.h.

Member Data Documentation

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

private

Definition at line 136 of file FastMonitoringThread.h.

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

MonitorData evf::FastMonitoringThread::m_data

private

Definition at line 133 of file FastMonitoringThread.h.

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

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

private

Definition at line 131 of file FastMonitoringThread.h.

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

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

private

Definition at line 132 of file FastMonitoringThread.h.

Referenced by start(), and stop().

std::mutex evf::FastMonitoringThread::monlock_

private

Definition at line 134 of file FastMonitoringThread.h.

Referenced by evf::FastMonitoringService::accumulateFileSize(), evf::FastMonitoringService::dowork(), evf::FastMonitoringService::getAbortFlagForLumi(), evf::FastMonitoringService::getEventsProcessedForLumi(), evf::FastMonitoringService::postBeginJob(), 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::reportEventsThisLumiInSource(), evf::FastMonitoringService::reportLockWait(), and evf::FastMonitoringService::stoppedLookingForFile().