DQMHttpSource.h

Go to the documentation of this file.

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

#ifndef StorageManager_DQMHttpSource_h
#define StorageManager_DQMHttpSource_h

#include "DQMServices/Core/interface/DQMStore.h"
#include "EventFilter/StorageManager/interface/DQMEventConsumerRegistrationInfo.h"
#include "EventFilter/StorageManager/interface/EventServerProxy.h"
#include "FWCore/Framework/interface/InputSourceDescription.h"
#include "FWCore/Framework/interface/EventPrincipal.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"
#include "FWCore/Sources/interface/RawInputSource.h"
#include "IOPool/Streamer/interface/DQMEventMessage.h"

#include <boost/thread/mutex.hpp>

#include <memory>


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

    static void addEventToDQMBackend
    (
      DQMStore*,
      const DQMEventMsgView&,
      const bool overwrite
    );


  private:
    EventAuxiliary const& eventAuxiliary() const {
      return *eventAuxiliary_;
    }
    void setEventAuxiliary(std::unique_ptr<EventAuxiliary> aux) {
      eventAuxiliary_ = std::move(aux);
    }
    virtual EventPrincipal* read(EventPrincipal& eventPrincipal);
    virtual bool checkNextEvent();
    void initializeDQMStore();

    std::unique_ptr<EventAuxiliary> eventAuxiliary_;
    stor::EventServerProxy<stor::DQMEventConsumerRegistrationInfo> dqmEventServerProxy_;
    DQMStore* dqmStore_;

    static boost::mutex mutex_;
  };

} // namespace edm

#endif // StorageManager_DQMHttpSource_h