DQMEventStore.h

Go to the documentation of this file.

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

#ifndef EventFilter_StorageManager_DQMEventStore_h
#define EventFilter_StorageManager_DQMEventStore_h

#include <map>
#include <queue>

#include <boost/thread/mutex.hpp>

#include "TThread.h"

#include "xcept/Exception.h"
#include "xdaq/ApplicationDescriptor.h"

#include "EventFilter/StorageManager/interface/AlarmHandler.h"
#include "EventFilter/StorageManager/interface/Configuration.h"
#include "EventFilter/StorageManager/interface/DataSenderMonitorCollection.h"
#include "EventFilter/StorageManager/interface/DQMTopLevelFolder.h"
#include "EventFilter/StorageManager/interface/DQMKey.h"
#include "EventFilter/StorageManager/interface/SharedResources.h"


namespace stor {
  
  class DQMEventMonitorCollection;


  template<class EventType, class ConnectionType, class StateMachineType>  
  class DQMEventStore
  {
  public:
    
    DQMEventStore
    (
      xdaq::ApplicationDescriptor*,
      DQMEventQueueCollectionPtr,
      DQMEventMonitorCollection&,
      ConnectionType*,
      size_t (ConnectionType::*getExpectedUpdatesCount)() const,
      StateMachineType*,
      void (StateMachineType::*moveToFailedState)(xcept::Exception&),
      AlarmHandlerPtr
    );

    ~DQMEventStore();

    void setParameters(DQMProcessingParams const&);

    void addDQMEvent(EventType const&);

    void purge();

    void clear();

    bool empty()
    { return store_.empty(); }

    void moveToFailedState(xcept::Exception& sentinelException)
    { (stateMachineType_->*moveToFailedState_)(sentinelException); }

    bool doProcessCompletedTopLevelFolders()
    { return processCompletedTopLevelFolders_; }
    
    
  private:

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

    void addDQMEventToStore(EventType const&);
    void addDQMEventToReadyToServe(EventType const&);
    DQMTopLevelFolderPtr makeDQMTopLevelFolder(EventType const&);
    DQMEventMsgView getDQMEventView(EventType const&);
    bool getNextReadyTopLevelFolder(DQMTopLevelFolderPtr&);
    static void processCompletedTopLevelFolders(void* arg);
    bool handleNextCompletedTopLevelFolder();
    void stopProcessingCompletedTopLevelFolders();

    xdaq::ApplicationDescriptor* appDescriptor_;
    DQMProcessingParams dqmParams_;
    DQMEventQueueCollectionPtr dqmEventQueueCollection_;
    DQMEventMonitorCollection& dqmEventMonColl_;
    ConnectionType* connectionType_;
    size_t (ConnectionType::*getExpectedUpdatesCount_)() const;
    StateMachineType* stateMachineType_;
    void (StateMachineType::*moveToFailedState_)(xcept::Exception&);
    AlarmHandlerPtr alarmHandler_;

    typedef std::map<DQMKey, DQMTopLevelFolderPtr> DQMTopLevelFolderMap;
    DQMTopLevelFolderMap store_;
    static boost::mutex storeMutex_;

    TThread* completedFolderThread_;
    bool processCompletedTopLevelFolders_;

    std::vector<unsigned char> tempEventArea_;

  };
  
} // namespace stor

#endif // EventFilter_StorageManager_DQMEventStore_h