DQMEventProcessorResources.h

Go to the documentation of this file.

// $Id: DQMEventProcessorResources.h,v 1.4.4.1 2011/03/07 11:33:04 mommsen Exp $


#ifndef EventFilter_StorageManager_DQMEventProcessorResources_h
#define EventFilter_StorageManager_DQMEventProcessorResources_h

#include "EventFilter/StorageManager/interface/Configuration.h"

#include "boost/thread/condition.hpp"
#include "boost/thread/mutex.hpp"

namespace stor
{

  class DQMEventProcessorResources
  {
  public:

    struct Requests
    {
      bool configuration;
      bool endOfRun;
      bool storeDestruction;

      void reset();
    };

    DQMEventProcessorResources();

    virtual ~DQMEventProcessorResources() {}

    void requestConfiguration(DQMProcessingParams const&,  boost::posix_time::time_duration const&);

    void requestEndOfRun();

    void requestStoreDestruction();

    bool getRequests(Requests&, DQMProcessingParams&, boost::posix_time::time_duration& timeoutValue);

    virtual void waitForCompletion();

    virtual bool requestsOngoing();

    void requestsDone();


  private:

    bool requestsPending_;
    bool requestsInProgress_;
    Requests pendingRequests_;

    DQMProcessingParams requestedDQMProcessingParams_;
    boost::posix_time::time_duration requestedTimeout_;

    boost::condition requestsCondition_;

    mutable boost::mutex requestsMutex_;
  };

  typedef boost::shared_ptr<DQMEventProcessorResources> DQMEventProcessorResourcesPtr;

} // namespace stor

#endif // EventFilter_StorageManager_DQMEventProcessorResources_h