1 #include "otsdaq/DataManager/CircularBufferBase.h"
2 #include "otsdaq/DataManager/DataConsumer.h"
3 #include "otsdaq/DataManager/DataProducer.h"
8 CircularBufferBase::CircularBufferBase(
const std::string& bufferID)
9 : dataBufferId_(bufferID), mfSubject_(
"CircularBuffer:" + dataBufferId_)
14 CircularBufferBase::~CircularBufferBase(
void) {}
17 void CircularBufferBase::registerProducer(
DataProcessor* producer,
18 unsigned int numberOfSubBuffers)
21 producer->setCircularBuffer(
this);
25 void CircularBufferBase::registerConsumer(
DataProcessor* consumer)
28 consumer->setCircularBuffer(
this);
const std::string & getProcessorID(void) const
Getters.