ConsumerUtils.h

Go to the documentation of this file.

// $Id: ConsumerUtils.h,v 1.10 2011/08/22 14:20:16 mommsen Exp $

#ifndef EventFilter_StorageManager_ConsumerUtils_h
#define EventFilter_StorageManager_ConsumerUtils_h

#include "EventFilter/StorageManager/interface/AlarmHandler.h"
#include "EventFilter/StorageManager/interface/DQMEventConsumerRegistrationInfo.h"
#include "EventFilter/StorageManager/interface/EnquingPolicyTag.h"
#include "EventFilter/StorageManager/interface/EventConsumerRegistrationInfo.h"
#include "EventFilter/StorageManager/interface/InitMsgCollection.h"
#include "EventFilter/StorageManager/interface/RegistrationCollection.h"
#include "EventFilter/StorageManager/interface/StatisticsReporter.h"
#include "EventFilter/StorageManager/interface/Utils.h"

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

#include <boost/shared_ptr.hpp>

namespace xgi
{
  class Input;
  class Output;
}

namespace smproxy
{
  class EventMsg;
}

namespace stor
{
  class ConsumerID;


  template<typename Configuration_t, typename EventQueueCollection_t>
  class ConsumerUtils
  {
    
  public:

    ConsumerUtils
    (
      boost::shared_ptr<Configuration_t>,
      RegistrationCollectionPtr,
      RegistrationQueuePtr,
      InitMsgCollectionPtr,
      boost::shared_ptr<EventQueueCollection_t>,
      DQMEventQueueCollectionPtr,
      AlarmHandlerPtr
    );

    void processConsumerRegistrationRequest(xgi::Input*, xgi::Output*) const;

    void processConsumerHeaderRequest(xgi::Input*, xgi::Output*) const;

    void processConsumerEventRequest(xgi::Input*, xgi::Output*) const;

    void processDQMConsumerRegistrationRequest(xgi::Input*, xgi::Output*) const;

    void processDQMConsumerEventRequest(xgi::Input*, xgi::Output*) const;


  private:

    EventConsRegPtr createEventConsumerRegistrationInfo(xgi::Input*, xgi::Output*) const;

    EventConsRegPtr parseEventConsumerRegistration(xgi::Input*) const;

    bool createEventConsumerQueue(EventConsRegPtr) const;

    DQMEventConsRegPtr createDQMEventConsumerRegistrationInfo(xgi::Input*, xgi::Output*) const;

    DQMEventConsRegPtr parseDQMEventConsumerRegistration(xgi::Input*) const;

    bool createDQMEventConsumerQueue(DQMEventConsRegPtr) const;

    bool addRegistrationInfo(const RegPtr) const;

    void writeConsumerRegistration(xgi::Output*, const ConsumerID) const;

    void writeNotReady(xgi::Output*) const;

    void writeEmptyBuffer(xgi::Output*) const;

    void writeDone(xgi::Output*) const;

    void writeErrorString(xgi::Output*, const std::string) const;

    void writeHTTPHeaders(xgi::Output*) const;

    ConsumerID getConsumerId(xgi::Input*) const;

    void writeConsumerHeader(xgi::Output*, const InitMsgSharedPtr) const;

    void writeConsumerEvent(xgi::Output*, const stor::I2OChain&) const;
    void writeConsumerEvent(xgi::Output*, const smproxy::EventMsg&) const;

    void writeDQMConsumerEvent(xgi::Output*, const DQMEventMsgView&) const;


    boost::shared_ptr<Configuration_t> configuration_;
    RegistrationCollectionPtr registrationCollection_;
    RegistrationQueuePtr registrationQueue_;
    InitMsgCollectionPtr initMsgCollection_;
    boost::shared_ptr<EventQueueCollection_t> eventQueueCollection_;
    DQMEventQueueCollectionPtr dqmEventQueueCollection_;
    AlarmHandlerPtr alarmHandler_;
  };

} // namespace stor

#endif // EventFilter_StorageManager_ConsumerUtils_h