#include <FastMonitoringService.h>

Inheritance diagram for evf::FastMonitoringService:

Classes
struct	Encoding

Public Member Functions
void	accummulateFileSize (unsigned long fileSize)

	FastMonitoringService (const edm::ParameterSet &, edm::ActivityRegistry &)

unsigned int	getEventsProcessedForLumi (unsigned int lumi)

std::string	getOutputDefPath () const

std::string	getRunDirName () const

void	jobFailure ()

std::string	makeModuleLegenda ()

std::string	makePathLegenda ()

void	postBeginJob ()

void	postBeginRun (edm::Run const &, edm::EventSetup const &)

void	postEndJob ()

void	postEventProcessing (const edm::Event &, const edm::EventSetup &)

void	postModule (const edm::ModuleDescription &)

void	postSourceEvent (edm::StreamID)

void	preBeginLumi (edm::LuminosityBlockID const &iID, edm::Timestamp const &iTime)

void	preEndLumi (edm::LuminosityBlockID const &iID, edm::Timestamp const &iTime)

void	preEventProcessing (const edm::EventID &, const edm::Timestamp &)

void	preModule (const edm::ModuleDescription &)

void	preModuleBeginJob (const edm::ModuleDescription &desc)

void	prePathBeginRun (const std::string &pathName)

void	preProcessPath (const std::string &pathName)

void	preSourceEvent (edm::StreamID)

void	setMicroState (Microstate)

void	startedLookingForFile ()

void	stoppedLookingForFile ()

	~FastMonitoringService ()

Public Member Functions inherited from evf::MicroStateService
virtual std::string	getMicroState1 ()

virtual std::string const &	getMicroState2 ()

	MicroStateService (const edm::ParameterSet &, edm::ActivityRegistry &)

virtual	~MicroStateService ()

Static Public Attributes
static const std::string	macroStateNames [FastMonitoringThread::MCOUNT]

static const std::string	nopath_ = "NoPath"

Static Public Attributes inherited from evf::MicroStateService
static const edm::ModuleDescription	reservedMicroStateNames [mCOUNT]

Private Member Functions
void	dowork ()

Private Attributes
Encoding	encModule_

Encoding	encPath_

string	fastName_

string	fastPath_

timeval	fileLookStart_

timeval	fileLookStop_

FastMonitoringThread	fmt_

std::vector< double >	leadTimes_

timeval	lumiStartTime_

timeval	lumiStopTime_

string	microstateDefPath_

string	outputDefPath_

std::unordered_map< unsigned int, int >	processedEventsPerLumi_

boost::filesystem::path	runDirectory_

int	sleepTime_

string	slowName_

boost::filesystem::path	workingDirectory_

Additional Inherited Members
Public Types inherited from evf::MicroStateService
enum	Microstate { mInvalid = 0, mFwkOvh, mIdle, mInput, mInputDone, mDqm, mCOUNT }

Protected Attributes inherited from evf::MicroStateService
boost::mutex	lock_

Static Protected Attributes inherited from evf::MicroStateService
static const std::string	default_return_ ="NotImplemented"

Detailed Description

Definition at line 49 of file FastMonitoringService.h.

Constructor & Destructor Documentation

evf::FastMonitoringService::FastMonitoringService	(	const edm::ParameterSet &	iPS,
		edm::ActivityRegistry &	reg
	)

Definition at line 19 of file FastMonitoringService.cc.

                                                  : 
     MicroStateService(iPS,reg)
     ,encModule_(33)
     ,encPath_(0)
     ,sleepTime_(iPS.getUntrackedParameter<int>("sleepTime", 1))
     //,rootDirectory_(iPS.getUntrackedParameter<string>("rootDirectory", "/data"))
     ,microstateDefPath_(iPS.getUntrackedParameter<string>("microstateDefPath", "/tmp/def.jsd"))
     ,outputDefPath_(iPS.getUntrackedParameter<string>("outputDefPath", "/tmp/def.jsd"))
     ,fastName_(iPS.getUntrackedParameter<string>("fastName", "states"))
     ,slowName_(iPS.getUntrackedParameter<string>("slowName", "lumi"))
   {
     fmt_.m_data.macrostate_=FastMonitoringThread::sInit;
     fmt_.m_data.ministate_=&nopath_;
     fmt_.m_data.microstate_=&reservedMicroStateNames[mInvalid];
     fmt_.m_data.lumisection_ = 0;
     fmt_.m_data.accuSize_ = 0;
     fmt_.m_data.filesProcessedDuringLumi_ = 0;
     reg.watchPreModuleBeginJob(this,&FastMonitoringService::preModuleBeginJob);  
     reg.watchPreBeginLumi(this,&FastMonitoringService::preBeginLumi);
     reg.watchPreEndLumi(this,&FastMonitoringService::preEndLumi);
     reg.watchPrePathBeginRun(this,&FastMonitoringService::prePathBeginRun);
     reg.watchPostBeginJob(this,&FastMonitoringService::postBeginJob);
     reg.watchPostBeginRun(this,&FastMonitoringService::postBeginRun);
     reg.watchPostEndJob(this,&FastMonitoringService::postEndJob);
     reg.watchPreProcessPath(this,&FastMonitoringService::preProcessPath);
     reg.watchPreProcessEvent(this,&FastMonitoringService::preEventProcessing);
     reg.watchPostProcessEvent(this,&FastMonitoringService::postEventProcessing);
     reg.watchPreSourceEvent(this,&FastMonitoringService::preSourceEvent);
     reg.watchPostSourceEvent(this,&FastMonitoringService::postSourceEvent);
   
     reg.watchPreModule(this,&FastMonitoringService::preModule);
     reg.watchPostModule(this,&FastMonitoringService::postModule);
     reg.watchJobFailure(this,&FastMonitoringService::jobFailure);
     for(unsigned int i = 0; i < (mCOUNT); i++)
       encModule_.updateReserved((void*)(reservedMicroStateNames+i));
     encPath_.update((void*)&nopath_);
     encModule_.completeReservedWithDummies();
 
     fmt_.m_data.macrostateJ_.setName("Macrostate");
     fmt_.m_data.ministateJ_.setName("Ministate");
     fmt_.m_data.microstateJ_.setName("Microstate");
     fmt_.m_data.processedJ_.setName("Processed");
     fmt_.m_data.throughputJ_.setName("Throughput");
     fmt_.m_data.avgLeadTimeJ_.setName("AverageLeadTime");
     fmt_.m_data.filesProcessedDuringLumi_.setName("FilesProcessed");
     vector<JsonMonitorable*> monParams;
     monParams.push_back(&fmt_.m_data.macrostateJ_);
     monParams.push_back(&fmt_.m_data.ministateJ_);
     monParams.push_back(&fmt_.m_data.microstateJ_);
     monParams.push_back(&fmt_.m_data.processedJ_);
     monParams.push_back(&fmt_.m_data.throughputJ_);
     monParams.push_back(&fmt_.m_data.avgLeadTimeJ_);
     monParams.push_back(&fmt_.m_data.filesProcessedDuringLumi_);
 
     // The run dir should be set via the configuration
     // For now, just grab the latest run directory available
 
     // FIND RUN DIRECTORY
     boost::filesystem::path runDirectory(edm::Service<evf::EvFDaqDirector>()->findHighestRunDir());
     workingDirectory_ = runDirectory_ = runDirectory;
     workingDirectory_ /= "mon";
 
     bool foundMonDir = false;
     if ( boost::filesystem::is_directory(workingDirectory_))
         foundMonDir=true;
     if (!foundMonDir) {
         std::cout << "<MON> DIR NOT FOUND!" << std::endl;
         boost::filesystem::create_directories(workingDirectory_);
     }
 
     std::ostringstream fastFileName;
 
     fastFileName << fastName_ << "_pid" << std::setfill('0') << std::setw(5) << getpid() << ".fast";
     boost::filesystem::path fast = workingDirectory_;
     fast /= fastFileName.str();
     fastPath_ = fast.string();
 
     /*
      * initialize the fast monitor with:
      * vector of pointers to monitorable parameters
      * path to definition
      *
      */
     std::cout
             << "FastMonitoringService: initializing FastMonitor with microstate def path: "
             << microstateDefPath_ << " " << FastMonitoringThread::MCOUNT << " "
             << encPath_.current_ + 1 << " " << encModule_.current_ + 1
             << std::endl;
 
     fmt_.m_data.jsonMonitor_.reset(
             new FastMonitor(monParams, microstateDefPath_));
 
     fmt_.start(&FastMonitoringService::dowork,this);
   }

evf::FastMonitoringService::~FastMonitoringService ( )

Definition at line 116 of file FastMonitoringService.cc.

117 {

118 }

Member Function Documentation

void evf::FastMonitoringService::accummulateFileSize ( unsigned long fileSize )

Definition at line 284 of file FastMonitoringService.cc.

References evf::FastMonitoringThread::MonitorData::accuSize_, evf::FastMonitoringThread::MonitorData::filesProcessedDuringLumi_, fmt_, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::monlock_, and jsoncollector::IntJ::value().

Referenced by evf::EvFDaqDirector::bumpFile().

                                                                         {
     fmt_.monlock_.lock();
     //std::cout << "--> ACCUMMULATING size: " << fileSize << std::endl;
     fmt_.m_data.accuSize_ += fileSize;
     fmt_.m_data.filesProcessedDuringLumi_.value()++;
     fmt_.monlock_.unlock();
   }

void evf::FastMonitoringService::dowork ( )

inlineprivate

Definition at line 138 of file FastMonitoringService.h.

Referenced by FastMonitoringService().

                     { // the function to be called in the thread. Thread completes when function returns.
         while (!fmt_.m_stoprequest) {
             std::cout << "Current states: Ms=" << fmt_.m_data.macrostate_
                     << " ms=" << encPath_.encode(fmt_.m_data.ministate_)
                     << " us=" << encModule_.encode(fmt_.m_data.microstate_)
                     << std::endl;
 
             // lock the monitor
             fmt_.monlock_.lock();
             fmt_.m_data.macrostateJ_ = fmt_.m_data.macrostate_;
             fmt_.m_data.ministateJ_ = encPath_.encode(fmt_.m_data.ministate_);
             fmt_.m_data.microstateJ_ = encModule_.encode(
                     fmt_.m_data.microstate_);
 
             fmt_.m_data.jsonMonitor_->snap(true, fastPath_);
             fmt_.monlock_.unlock();
 
             //::sleep(1);
             ::sleep(sleepTime_);
         }
       }

unsigned int evf::FastMonitoringService::getEventsProcessedForLumi ( unsigned int lumi )

Definition at line 320 of file FastMonitoringService.cc.

References fjr2json::lumi.

                                                                                  {
     return processedEventsPerLumi_[lumi];
 }

std::string evf::FastMonitoringService::getOutputDefPath ( ) const

inline

Definition at line 134 of file FastMonitoringService.h.

References outputDefPath_.

Referenced by evf::RecoEventOutputModuleForFU< Consumer >::RecoEventOutputModuleForFU().

134 { return outputDefPath_; }

evf::FastMonitoringService::outputDefPath_

string outputDefPath_

Definition: FastMonitoringService.h:166

std::string evf::FastMonitoringService::getRunDirName ( ) const

inline

Definition at line 135 of file FastMonitoringService.h.

References runDirectory_.

135 { return runDirectory_.stem().string(); }

evf::FastMonitoringService::runDirectory_

boost::filesystem::path runDirectory_

Definition: FastMonitoringService.h:172

void evf::FastMonitoringService::jobFailure ( )

Definition at line 273 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::MonitorData::macrostate_, and evf::FastMonitoringThread::sError.

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.macrostate_ = FastMonitoringThread::sError;
   }

std::string evf::FastMonitoringService::makeModuleLegenda ( )

Definition at line 162 of file FastMonitoringService.cc.

References evf::FastMonitoringService::Encoding::current_, evf::FastMonitoringService::Encoding::decode(), encModule_, and i.

Referenced by postBeginJob().

                                                     {
     
     std::ostringstream ost;
     for(int i = 0;
     i < encModule_.current_;
     i++)
       {
     //  std::cout << "for i = " << i << std::endl;
     ost<<i<<"="<<((const edm::ModuleDescription *)(encModule_.decode(i)))->moduleLabel()<<" ";
       }
     return ost.str();
   }

std::string evf::FastMonitoringService::makePathLegenda ( )

Definition at line 152 of file FastMonitoringService.cc.

References evf::FastMonitoringService::Encoding::current_, evf::FastMonitoringService::Encoding::decode(), encPath_, i, and AlCaHLTBitMon_QueryRunRegistry::string.

Referenced by postBeginJob(), and postBeginRun().

                                                   {
     
     std::ostringstream ost;
     for(int i = 0;
     i < encPath_.current_;
     i++)
       ost<<i<<"="<<*((std::string *)(encPath_.decode(i)))<<" ";
     return ost.str();
   }

void evf::FastMonitoringService::postBeginJob ( )

Definition at line 175 of file FastMonitoringService.cc.

References gather_cfg::cout, fmt_, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::MonitorData::macrostate_, makeModuleLegenda(), makePathLegenda(), and evf::FastMonitoringThread::sJobReady.

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     std::cout << "path legenda*****************" << std::endl;
     std::cout << makePathLegenda()   << std::endl;
     std::cout << "module legenda***************" << std::endl;
     std::cout << makeModuleLegenda() << std::endl;
     fmt_.m_data.macrostate_ = FastMonitoringThread::sJobReady;
   }

void evf::FastMonitoringService::postBeginRun	(	edm::Run const &	,
		edm::EventSetup const &
	)

Definition at line 139 of file FastMonitoringService.cc.

References gather_cfg::cout, fmt_, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::MonitorData::macrostate_, makePathLegenda(), and evf::FastMonitoringThread::sRunning.

Referenced by FastMonitoringService().

   {
     std::cout << "path legenda*****************" << std::endl;
     std::cout << makePathLegenda()   << std::endl;
     fmt_.m_data.macrostate_ = FastMonitoringThread::sRunning;
   }

void evf::FastMonitoringService::postEndJob ( )

Definition at line 185 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::MonitorData::macrostate_, evf::FastMonitoringThread::sJobEnded, and evf::FastMonitoringThread::stop().

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.macrostate_ = FastMonitoringThread::sJobEnded;
     fmt_.stop();
   }

void evf::FastMonitoringService::postEventProcessing	(	const edm::Event &	e,
		const edm::EventSetup &
	)

Definition at line 241 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, evf::MicroStateService::mFwkOvh, evf::FastMonitoringThread::MonitorData::microstate_, evf::FastMonitoringThread::monlock_, evf::FastMonitoringThread::MonitorData::processedJ_, evf::MicroStateService::reservedMicroStateNames, and jsoncollector::IntJ::value().

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.microstate_ = &reservedMicroStateNames[mFwkOvh];
     fmt_.monlock_.lock();
     fmt_.m_data.processedJ_.value()++;
     fmt_.monlock_.unlock();
   }

void evf::FastMonitoringService::postModule ( const edm::ModuleDescription & desc )

Definition at line 268 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, and evf::FastMonitoringThread::MonitorData::microstate_.

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.microstate_ = &desc;
   }

void evf::FastMonitoringService::postSourceEvent ( edm::StreamID )

Definition at line 256 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, evf::MicroStateService::mFwkOvh, evf::FastMonitoringThread::MonitorData::microstate_, and evf::MicroStateService::reservedMicroStateNames.

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.microstate_ = &reservedMicroStateNames[mFwkOvh];
   }

void evf::FastMonitoringService::preBeginLumi	(	edm::LuminosityBlockID const &	iID,
		edm::Timestamp const &	iTime
	)

Definition at line 192 of file FastMonitoringService.cc.

References gather_cfg::cout, fmt_, edm::LuminosityBlockID::luminosityBlock(), evf::FastMonitoringThread::MonitorData::lumisection_, lumiStartTime_, evf::FastMonitoringThread::m_data, and evf::FastMonitoringThread::monlock_.

Referenced by FastMonitoringService().

   {
       std::cout << "FastMonitoringService: Pre-begin LUMI: " << iID.luminosityBlock() << std::endl;
       fmt_.monlock_.lock();
       fmt_.m_data.lumisection_ = (unsigned int) iID.luminosityBlock();
       gettimeofday(&lumiStartTime_, 0);
       fmt_.monlock_.unlock();
   }

void evf::FastMonitoringService::preEndLumi	(	edm::LuminosityBlockID const &	iID,
		edm::Timestamp const &	iTime
	)

Definition at line 201 of file FastMonitoringService.cc.

Referenced by FastMonitoringService().

   {
       std::cout << "FastMonitoringService: LUMI: " << iID.luminosityBlock() << " ended! Writing JSON information..." << std::endl;
       fmt_.monlock_.lock();
       gettimeofday(&lumiStopTime_, 0);
 
       // Compute throughput
       unsigned int secondsForLumi = lumiStopTime_.tv_sec - lumiStartTime_.tv_sec;
       fmt_.m_data.throughputJ_.value() = double(fmt_.m_data.accuSize_) / double(secondsForLumi) / double(1024*1024);
 
       std::cout
             << ">>> >>> FastMonitoringService: processed event count for this lumi = "
             << fmt_.m_data.processedJ_.value() << " time = " << secondsForLumi
             << " size = " << fmt_.m_data.accuSize_ << " thr = " << fmt_.m_data.throughputJ_.value() << std::endl;
       fmt_.m_data.jsonMonitor_->snap(true, fastPath_);
       // create file name for slow monitoring file
       std::stringstream slowFileName;
       slowFileName << slowName_ << "_ls" << std::setfill('0') << std::setw(4)
             << fmt_.m_data.lumisection_ << "_pid" << std::setfill('0')
             << std::setw(5) << getpid() << ".jsn";
       boost::filesystem::path slow = workingDirectory_;
       slow /= slowFileName.str();
       fmt_.m_data.jsonMonitor_->outputFullHistoDataPoint(slow.string());
       processedEventsPerLumi_[fmt_.m_data.lumisection_] = fmt_.m_data.processedJ_.value();
 
       fmt_.m_data.processedJ_ = 0;
       fmt_.m_data.accuSize_ = 0;
       fmt_.m_data.throughputJ_ = 0;
       fmt_.m_data.avgLeadTimeJ_ = 0;
       fmt_.m_data.filesProcessedDuringLumi_ = 0;
       leadTimes_.clear();
       fmt_.monlock_.unlock();
   }

void evf::FastMonitoringService::preEventProcessing	(	const edm::EventID &	iID,
		const edm::Timestamp &	iTime
	)

Definition at line 235 of file FastMonitoringService.cc.

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
   }

void evf::FastMonitoringService::preModule ( const edm::ModuleDescription & desc )

Definition at line 262 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, and evf::FastMonitoringThread::MonitorData::microstate_.

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.microstate_ = &desc;
   }

void evf::FastMonitoringService::preModuleBeginJob ( const edm::ModuleDescription & desc )

Definition at line 120 of file FastMonitoringService.cc.

References encModule_, edm::ModuleDescription::moduleName(), evf::FastMonitoringService::Encoding::update(), and evf::FastMonitoringService::Encoding::updateReserved().

Referenced by FastMonitoringService().

   {
     //build a map of modules keyed by their module description address
     //here we need to treat output modules in a special way so they can be easily singled out
     if(desc.moduleName() == "ShmStreamConsumer" || desc.moduleName() == "EventStreamFileWriter" || 
        desc.moduleName() == "PoolOutputModule")
       encModule_.updateReserved((void*)&desc);
     else
       encModule_.update((void*)&desc);
   }

void evf::FastMonitoringService::prePathBeginRun ( const std::string & pathName )

Definition at line 131 of file FastMonitoringService.cc.

References gather_cfg::cout, encPath_, and evf::FastMonitoringService::Encoding::update().

Referenced by FastMonitoringService().

   {
     //bonus track, now monitoring path execution too...
     // here we are forced to use string keys...
     std::cout << ">>>>>>>>>>>>>>>>>>>>>>>>>>update path map with " << pathName << std::endl;
     encPath_.update((void*)&pathName);
   }

void evf::FastMonitoringService::preProcessPath ( const std::string & pathName )

Definition at line 146 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::MonitorData::ministate_, and EgammaValidation_cff::pathName.

Referenced by FastMonitoringService().

   {
     //bonus track, now monitoring path execution too...
     fmt_.m_data.ministate_ = &pathName;
   }

void evf::FastMonitoringService::preSourceEvent ( edm::StreamID )

Definition at line 250 of file FastMonitoringService.cc.

References fmt_, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::MonitorData::microstate_, evf::MicroStateService::mIdle, and evf::MicroStateService::reservedMicroStateNames.

Referenced by FastMonitoringService().

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.microstate_ = &reservedMicroStateNames[mIdle];
   }

void evf::FastMonitoringService::setMicroState ( Microstate m )

virtual

Implements evf::MicroStateService.

Definition at line 278 of file FastMonitoringService.cc.

References fmt_, m, evf::FastMonitoringThread::m_data, evf::FastMonitoringThread::MonitorData::microstate_, and evf::MicroStateService::reservedMicroStateNames.

   {
     //    boost::mutex::scoped_lock sl(lock_);
     fmt_.m_data.microstate_ = &reservedMicroStateNames[m];
   }

void evf::FastMonitoringService::startedLookingForFile ( )

Definition at line 292 of file FastMonitoringService.cc.

References fileLookStart_.

Referenced by FedRawDataInputSource::searchForNextFile().

                                                     {
       gettimeofday(&fileLookStart_, 0);
       /*
      std::cout << "Started looking for .raw file at: s=" << fileLookStart_.tv_sec << ": ms = "
      << fileLookStart_.tv_usec / 1000.0 << std::endl;
      */
   }

void evf::FastMonitoringService::stoppedLookingForFile ( )

Definition at line 300 of file FastMonitoringService.cc.

References evf::FastMonitoringThread::MonitorData::avgLeadTimeJ_, fileLookStart_, fileLookStop_, fmt_, i, leadTimes_, and evf::FastMonitoringThread::m_data.

Referenced by FedRawDataInputSource::searchForNextFile().

                                                     {
       gettimeofday(&fileLookStop_, 0);
       /*
      std::cout << "Stopped looking for .raw file at: s=" << fileLookStop_.tv_sec << ": ms = "
      << fileLookStop_.tv_usec / 1000.0 << std::endl;
      */
       double elapsedTime = (fileLookStop_.tv_sec - fileLookStart_.tv_sec) * 1000.0; // sec to ms
       elapsedTime += (fileLookStop_.tv_usec - fileLookStart_.tv_usec) / 1000.0; // us to ms
       // add this to lead times for this lumi
       leadTimes_.push_back(elapsedTime);
 
       // recompute average lead time for this lumi
       if (leadTimes_.size() == 1) fmt_.m_data.avgLeadTimeJ_ = leadTimes_[0];
       else {
           double totTime = 0;
           for (unsigned int i = 0; i < leadTimes_.size(); i++) totTime += leadTimes_[i];
           fmt_.m_data.avgLeadTimeJ_ = totTime / leadTimes_.size();
       }
   }

Member Data Documentation

Encoding evf::FastMonitoringService::encModule_

private

Definition at line 162 of file FastMonitoringService.h.

Referenced by dowork(), FastMonitoringService(), makeModuleLegenda(), and preModuleBeginJob().

Encoding evf::FastMonitoringService::encPath_

private

Definition at line 163 of file FastMonitoringService.h.

Referenced by dowork(), FastMonitoringService(), makePathLegenda(), and prePathBeginRun().

string evf::FastMonitoringService::fastName_

private

Definition at line 167 of file FastMonitoringService.h.

Referenced by FastMonitoringService().

string evf::FastMonitoringService::fastPath_

private

Definition at line 167 of file FastMonitoringService.h.

Referenced by dowork(), FastMonitoringService(), and preEndLumi().

timeval evf::FastMonitoringService::fileLookStart_

private

Definition at line 169 of file FastMonitoringService.h.

Referenced by startedLookingForFile(), and stoppedLookingForFile().

timeval evf::FastMonitoringService::fileLookStop_

private

Definition at line 169 of file FastMonitoringService.h.

Referenced by stoppedLookingForFile().

FastMonitoringThread evf::FastMonitoringService::fmt_

private

Definition at line 161 of file FastMonitoringService.h.

Referenced by accummulateFileSize(), dowork(), FastMonitoringService(), jobFailure(), postBeginJob(), postBeginRun(), postEndJob(), postEventProcessing(), postModule(), postSourceEvent(), preBeginLumi(), preEndLumi(), preModule(), preProcessPath(), preSourceEvent(), setMicroState(), and stoppedLookingForFile().

std::vector<double> evf::FastMonitoringService::leadTimes_

private

Definition at line 170 of file FastMonitoringService.h.

Referenced by preEndLumi(), and stoppedLookingForFile().

timeval evf::FastMonitoringService::lumiStartTime_

private

Definition at line 168 of file FastMonitoringService.h.

Referenced by preBeginLumi(), and preEndLumi().

timeval evf::FastMonitoringService::lumiStopTime_

private

Definition at line 168 of file FastMonitoringService.h.

Referenced by preEndLumi().

const std::string evf::FastMonitoringService::macroStateNames

static

Initial value:

= 
    {"Init","JobReady","RunGiven","Running",
     "Stopping","Done","JobEnded","Error","ErrorEnded","End",
     "Invalid"}

Definition at line 98 of file FastMonitoringService.h.

string evf::FastMonitoringService::microstateDefPath_

private

Definition at line 166 of file FastMonitoringService.h.

Referenced by FastMonitoringService().

const std::string evf::FastMonitoringService::nopath_ = "NoPath"

static

Definition at line 101 of file FastMonitoringService.h.

Referenced by FastMonitoringService().

string evf::FastMonitoringService::outputDefPath_

private

Definition at line 166 of file FastMonitoringService.h.

Referenced by getOutputDefPath().

std::unordered_map<unsigned int, int> evf::FastMonitoringService::processedEventsPerLumi_

private

Definition at line 171 of file FastMonitoringService.h.

Referenced by preEndLumi().

boost::filesystem::path evf::FastMonitoringService::runDirectory_

private

Definition at line 172 of file FastMonitoringService.h.

Referenced by FastMonitoringService(), and getRunDirName().

int evf::FastMonitoringService::sleepTime_

private

Definition at line 165 of file FastMonitoringService.h.

Referenced by dowork().

string evf::FastMonitoringService::slowName_

private

Definition at line 167 of file FastMonitoringService.h.

Referenced by preEndLumi().

boost::filesystem::path evf::FastMonitoringService::workingDirectory_

private

Definition at line 172 of file FastMonitoringService.h.

Referenced by FastMonitoringService(), and preEndLumi().

Classes

Public Member Functions

Static Public Attributes

Private Member Functions

Private Attributes

Additional Inherited Members

Detailed Description

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation