DiskWriterResources.h

Go to the documentation of this file.

// $Id: DiskWriterResources.h,v 1.9 2011/03/07 15:31:31 mommsen Exp $


#ifndef EventFilter_StorageManager_DiskWriterResources_h
#define EventFilter_StorageManager_DiskWriterResources_h

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

#include "boost/date_time/posix_time/posix_time_types.hpp"
#include "boost/thread/condition.hpp"
#include "boost/thread/mutex.hpp"

#include <deque>
#include <stdint.h>


namespace stor
{

  class DiskWriterResources
  {
  public:

    DiskWriterResources();

    virtual ~DiskWriterResources() {}

    void requestStreamConfiguration
    (
      EvtStrConfigListPtr const,
      ErrStrConfigListPtr const,
      DiskWritingParams const&,
      unsigned int const& runNumber,
      boost::posix_time::time_duration const& timeoutValue
    );

    void requestStreamDestruction();

    bool streamChangeRequested
    (
      bool& doConfig,
      EvtStrConfigListPtr&,
      ErrStrConfigListPtr&,
      DiskWritingParams& dwParams,
      unsigned int& runNumber,
      boost::posix_time::time_duration& timeoutValue
    );

    virtual void waitForStreamChange();

    virtual bool streamChangeOngoing();

    void streamChangeDone();

    void setBusy(bool isBusyFlag);

    bool isBusy();

  private:

    bool configurationIsNeeded_;
    bool streamChangeIsNeeded_;
    bool fileClosingTestIsNeeded_;
    bool diskWriterIsBusy_;

    EvtStrConfigListPtr requestedEventStreamConfig_;
    ErrStrConfigListPtr requestedErrorStreamConfig_;
    DiskWritingParams requestedDiskWritingParams_;
    unsigned int requestedRunNumber_;
    boost::posix_time::time_duration requestedTimeout_;

    bool streamChangeInProgress_;
    boost::condition streamChangeCondition_;
    
    mutable boost::mutex streamChangeMutex_;
  };
  
  typedef boost::shared_ptr<DiskWriterResources> DiskWriterResourcesPtr;

} // namespace stor

#endif // EventFilter_StorageManager_DiskWriterResources_h