CircularBufferBase.cc

#include "otsdaq/DataManager/CircularBufferBase.h"
#include "otsdaq/DataManager/DataConsumer.h"
#include "otsdaq/DataManager/DataProducer.h"
 
using namespace ots;
 
//==============================================================================
CircularBufferBase::CircularBufferBase(const std::string& bufferID)
    : dataBufferId_(bufferID), mfSubject_("CircularBuffer:" + dataBufferId_)
{
}
 
//==============================================================================
CircularBufferBase::~CircularBufferBase(void) {}
 
//==============================================================================
void CircularBufferBase::registerProducer(DataProcessor* producer,
                                          unsigned int   numberOfSubBuffers)
{
    registerProducer(producer->getProcessorID(), numberOfSubBuffers);
    producer->setCircularBuffer(this);
}
 
//==============================================================================
void CircularBufferBase::registerConsumer(DataProcessor* consumer)
{
    registerConsumer(consumer->getProcessorID(), HighConsumerPriority);
    consumer->setCircularBuffer(this);
}
//{
//  unregisterProducer(producer->getProcessorID());
//  producer->setCircularBuffer(0);
//}
//
//{
//  unregisterConsumer(consumer->getProcessorID());
//  consumer->setCircularBuffer(0);
//}