EventDistributor.h

Go to the documentation of this file.

// $Id: EventDistributor.h,v 1.8 2011/03/07 15:31:31 mommsen Exp $

#ifndef EventFilter_StorageManager_EventDistributor_h
#define EventFilter_StorageManager_EventDistributor_h

#include "EventFilter/StorageManager/interface/DQMEventConsumerRegistrationInfo.h"
#include "EventFilter/StorageManager/interface/EventConsumerRegistrationInfo.h"
#include "EventFilter/StorageManager/interface/ErrorStreamConfigurationInfo.h"
#include "EventFilter/StorageManager/interface/EventQueueCollection.h"
#include "EventFilter/StorageManager/interface/EventStreamConfigurationInfo.h"
#include "EventFilter/StorageManager/interface/SharedResources.h"

#include "boost/shared_ptr.hpp"


namespace stor {

  class DataSenderMonitorCollection;
  class DQMEventSelector;
  class ErrorStreamConfigurationInfo;
  class ErrorStreamSelector;
  class EventConsumerSelector;
  class EventStreamConfigurationInfo;
  class EventStreamSelector;
  class I2OChain;
  class QueueID;
  class StatisticsReporter;


  class EventDistributor
  {
  public:

    EventDistributor(SharedResourcesPtr sr);

    ~EventDistributor();

    void addEventToRelevantQueues( I2OChain& );

    const bool full() const;

    void registerEventConsumer( const EventConsRegPtr );

    void registerDQMEventConsumer( const DQMEventConsRegPtr );

    void registerEventStreams( const EvtStrConfigListPtr );

    void registerErrorStreams( const ErrStrConfigListPtr );

    void clearStreams();

    unsigned int configuredStreamCount() const;

    unsigned int initializedStreamCount() const;

    void clearConsumers();

    unsigned int configuredConsumerCount() const;

    unsigned int initializedConsumerCount() const;

    void checkForStaleConsumers();

  private:

    void tagCompleteEventForQueues( I2OChain& );

    SharedResourcesPtr sharedResources_;

    typedef boost::shared_ptr<EventStreamSelector> EvtSelPtr;
    typedef std::set<EvtSelPtr, utils::ptrComp<EventStreamSelector> > EvtSelList;
    EvtSelList eventStreamSelectors_;

    typedef boost::shared_ptr<DQMEventSelector> DQMEvtSelPtr;
    typedef std::set<DQMEvtSelPtr, utils::ptrComp<DQMEventSelector> > DQMEvtSelList;
    DQMEvtSelList dqmEventSelectors_;

    typedef boost::shared_ptr<ErrorStreamSelector> ErrSelPtr;
    typedef std::set<ErrSelPtr, utils::ptrComp<ErrorStreamSelector> > ErrSelList;
    ErrSelList errorStreamSelectors_;

    typedef boost::shared_ptr<EventConsumerSelector> ConsSelPtr;
    typedef std::set<ConsSelPtr, utils::ptrComp<EventConsumerSelector> > ConsSelList;
    ConsSelList eventConsumerSelectors_;

  };
  
} // namespace stor

#endif // EventFilter_StorageManager_EventDistributor_h