DataConsumer.h

#ifndef _ots_DataConsumer_h_
#define _ots_DataConsumer_h_
 
#include <map>
#include <string>
#include "otsdaq/DataManager/DataProcessor.h"
 
namespace ots
{
class DataConsumer : public DataProcessor, public virtual WorkLoop
{
  public:
    enum ConsumerPriority
    {
        LowConsumerPriority,  
        HighConsumerPriority  
    };
    DataConsumer(std::string      supervisorApplicationUID,
                 std::string      bufferUID,
                 std::string      processorUID,
                 ConsumerPriority priority);
    virtual ~DataConsumer(void);
 
    virtual void registerToBuffer(void);
    // virtual void         unregisterFromBuffer    (void);
 
    virtual void configure(void) { ; }
    virtual void startProcessingData(std::string runNumber);
    virtual void stopProcessingData(void);
 
    template<class D, class H>
    int read(D& buffer, H& header)
    {
        return static_cast<CircularBuffer<D, H>*>(theCircularBuffer_)
            ->read(buffer, header, processorUID_);
    }
 
    template<class D, class H>
    int read(D*& buffer, H*& header)
    {
        return static_cast<CircularBuffer<D, H>*>(theCircularBuffer_)
            ->read(buffer, header, processorUID_);
    }
 
    template<class D, class H>
    int setReadSubBuffer(void)
    {
        return static_cast<CircularBuffer<D, H>*>(theCircularBuffer_)
            ->getLastReadBuffer(DataProcessor::processorUID_)
            .setReadSubBuffer(DataProcessor::processorUID_);
    }
 
    template<class D, class H>
    int read(D& buffer)
    {
        return static_cast<CircularBuffer<D, H>*>(theCircularBuffer_)
            ->read(buffer, processorUID_);
    }
 
    ConsumerPriority getPriority(void);
 
  private:
    ConsumerPriority priority_;
};
 
}  // namespace ots
 
#endif