EventStreamHandler.h

Go to the documentation of this file.

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

#ifndef EventFilter_StorageManager_EventStreamHandler_h
#define EventFilter_StorageManager_EventStreamHandler_h

#include <string>

#include "IOPool/Streamer/interface/InitMessage.h"

#include "EventFilter/StorageManager/interface/InitMsgCollection.h"
#include "EventFilter/StorageManager/interface/StreamHandler.h"


namespace stor {

  class Configuration;
  class EventStreamConfigurationInfo;


  class EventStreamHandler : public StreamHandler
  {
  public:
    
    EventStreamHandler
    (
      const EventStreamConfigurationInfo&,
      const SharedResourcesPtr,
      const DbFileHandlerPtr
    );


  private:

    virtual std::string streamLabel() const
    { return streamConfig_.streamLabel(); }

    virtual double fractionToDisk() const
    { return streamConfig_.fractionToDisk(); }

    virtual FileHandlerPtr newFileHandler(const I2OChain& event);

    virtual int getStreamMaxFileSize() const
    { return streamConfig_.maxFileSizeMB(); }


    EventStreamConfigurationInfo streamConfig_;
    InitMsgCollectionPtr initMsgCollection_;
    InitMsgSharedPtr initMsgView_;

  };
  
} // namespace stor

#endif // EventFilter_StorageManager_EventStreamHandler_h