EventConsumerSelector.h

Go to the documentation of this file.

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

#ifndef EventFilter_StorageManager_EventConsumerSelector_h
#define EventFilter_StorageManager_EventConsumerSelector_h

#include <boost/shared_ptr.hpp>

#include "EventFilter/StorageManager/interface/EventConsumerRegistrationInfo.h"
#include "EventFilter/StorageManager/interface/I2OChain.h"
#include "EventFilter/StorageManager/interface/TriggerSelector.h"
#include "IOPool/Streamer/interface/InitMessage.h"

namespace stor {

  class EventConsumerSelector
  {

  public:

    EventConsumerSelector( const EventConsRegPtr registrationInfo ):
      initialized_( false ),
      outputModuleId_( 0 ),
      registrationInfo_( registrationInfo ),
      acceptedEvents_( 0 )
    {}

    ~EventConsumerSelector() {}

    void initialize( const InitMsgView& );

    bool acceptEvent( const I2OChain& );

    QueueID const queueId() const { return registrationInfo_->queueId(); }

    bool isInitialized() const { return initialized_; }

    bool operator<(const EventConsumerSelector& other) const;

  private:

    bool initialized_;
    unsigned int outputModuleId_;
    const EventConsRegPtr registrationInfo_;
    TriggerSelectorPtr eventSelector_;
    unsigned long acceptedEvents_;

  };

} // namespace stor

#endif // EventFilter_StorageManager_EventConsumerSelector_h