/data/refman/pasoursint/CMSSW_6_1_1/src/EventFilter/StorageManager/interface/DQMEventProcessor.h

Go to the documentation of this file.

// $Id: DQMEventProcessor.h,v 1.9 2012/04/20 10:48:18 mommsen Exp $

#ifndef EventFilter_StorageManager_DQMEventProcessor_h
#define EventFilter_StorageManager_DQMEventProcessor_h

#include "toolbox/lang/Class.h"
#include "toolbox/task/WaitingWorkLoop.h"
#include "xdaq/Application.h"

#include <boost/shared_ptr.hpp>

#include "EventFilter/StorageManager/interface/AlarmHandler.h"
#include "EventFilter/StorageManager/interface/DQMEventStore.h"
#include "EventFilter/StorageManager/interface/I2OChain.h"
#include "EventFilter/StorageManager/interface/SharedResources.h"


namespace stor {

  class QueueID;
  class StatisticsReporter;


  class DQMEventProcessor : public toolbox::lang::Class
  {
  public:
    
    DQMEventProcessor(xdaq::Application*, SharedResourcesPtr sr);
    
    ~DQMEventProcessor();

    bool processDQMEvents(toolbox::task::WorkLoop*);

    void startWorkLoop(std::string workloopName);


  private:

    //Prevent copying of the DQMEventProcessor
    DQMEventProcessor(DQMEventProcessor const&);
    DQMEventProcessor& operator=(DQMEventProcessor const&);

    void processNextDQMEvent();

    void endOfRun();
 

    xdaq::Application* app_;
    SharedResourcesPtr sharedResources_;

    boost::posix_time::time_duration timeout_;
    bool actionIsActive_;
    uint32_t latestLumiSection_;
    unsigned int discardDQMUpdatesForOlderLS_;

    toolbox::task::WorkLoop* processWL_;      

    DQMEventStore<I2OChain,DataSenderMonitorCollection,AlarmHandler> dqmEventStore_;

  };
  
} // namespace stor

#endif // EventFilter_StorageManager_DQMEventProcessor_h