TestConsumer.h

Go to the documentation of this file.

#ifndef IOPool_Streamer_TestConsumer_h
#define IOPool_Streamer_TestConsumer_h

#include "IOPool/Streamer/interface/EventBuffer.h"
#include "FWCore/ParameterSet/interface/ParameterSet.h"

#include "boost/shared_ptr.hpp"

namespace edmtest
{
  class Worker;

  class TestConsumer
  {
  public:
    TestConsumer(edm::ParameterSet const& ps, 
         edm::EventBuffer* buf);

    ~TestConsumer();

    void bufferReady();
    void stop();
    void sendRegistry(void* buf, int len);

  private:
    boost::shared_ptr<Worker> worker_;
    edm::EventBuffer* bufs_; //does not own the buffer
  };
}

#endif