EventStreamHttpReader.h

Go to the documentation of this file.

// $Id: EventStreamHttpReader.h,v 1.30 2012/10/31 17:09:27 wmtan Exp $

#ifndef StorageManager_EventStreamHttpReader_h
#define StorageManager_EventStreamHttpReader_h

#include "DQMServices/Core/interface/DQMStore.h"
#include "EventFilter/StorageManager/interface/EventConsumerRegistrationInfo.h"
#include "EventFilter/StorageManager/interface/EventServerProxy.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Framework/interface/InputSourceDescription.h"
#include "IOPool/Streamer/interface/StreamerInputSource.h"


namespace edm
{
  class EventStreamHttpReader : public edm::StreamerInputSource
  {
  public:
    EventStreamHttpReader
    (
      edm::ParameterSet const&,
      edm::InputSourceDescription const&
    );
    virtual ~EventStreamHttpReader() {};

  private:
    virtual bool checkNextEvent();

    void readHeader();
    void initializeDQMStore();
    
    stor::EventServerProxy<stor::EventConsumerRegistrationInfo> eventServerProxy_;
    DQMStore* dqmStore_;
    bool dqmStoreAvailabiltyChecked_;

    const bool dropOldLumisectionEvents_;
    const std::string consumerName_;
    unsigned int totalDroppedEvents_;
    unsigned int lastLS_;

  };

} // namespace edm

#endif // StorageManager_EventStreamHttpReader_h