FastMonitoringThread.h

Go to the documentation of this file.

#ifndef EVF_FASTMONITORINGTHREAD
#define EVF_FASTMONITORINGTHREAD

#include "boost/thread/thread.hpp"

#include <iostream>
#include <vector>

#include "EventFilter/Utilities/interface/JsonMonitorable.h"
#include "EventFilter/Utilities/interface/FastMonitor.h"
#include "EventFilter/Utilities/interface/JSONSerializer.h"

using namespace jsoncollector;
using std::vector;

namespace evf{

  class FastMonitoringService;

  class FastMonitoringThread{
  public:
    enum Macrostate { sInit = 0, sJobReady, sRunGiven, sRunning, sStopping,
              sShuttingDown, sDone, sJobEnded, sError, sErrorEnded, sEnd, sInvalid,MCOUNT}; 
    struct MonitorData
    {
      Macrostate macrostate_;
      const void *ministate_;
      const void *microstate_;
      unsigned int eventnumber_;
      unsigned int processed_;
      // accummulated size of processed files over a lumi (in Bytes)
      unsigned long accuSize_;
      unsigned int lumisection_; //only updated on beginLumi signal
      unsigned int prescaleindex_; // ditto

      // Micro, mini, macrostate numbers
      IntJ macrostateJ_;
      IntJ ministateJ_;
      IntJ microstateJ_;
      // Processed events count
      IntJ processedJ_;
      // Throughput, MB/s
      DoubleJ throughputJ_;
      // Average time to obtain a file to read (ms)
      DoubleJ avgLeadTimeJ_;
      // Number of files processed during lumi section
      IntJ filesProcessedDuringLumi_;
      boost::shared_ptr<FastMonitor> jsonMonitor_;

    };
    // a copy of the Framework/EventProcessor states 


    FastMonitoringThread() : m_stoprequest(false){}
      
    void start(void (FastMonitoringService::*fp)(),FastMonitoringService *cp){
      assert(!m_thread);
      m_thread = boost::shared_ptr<boost::thread>(new boost::thread(boost::bind(fp,cp)));
    }
    void stop(){
      assert(m_thread);
      m_stoprequest=true;
      m_thread->join();
    }

  private:

    volatile bool m_stoprequest;
    boost::shared_ptr<boost::thread> m_thread;
    MonitorData m_data;
    boost::mutex lock_;
    boost::mutex monlock_;

    friend class FastMonitoringService;
  };
} //end namespace evf
#endif