tdaq-develop-2025-02-12
CircularBufferBase.cc
1 #include "otsdaq/DataManager/CircularBufferBase.h"
2 #include "otsdaq/DataManager/DataConsumer.h"
3 #include "otsdaq/DataManager/DataProducer.h"
4 
5 using namespace ots;
6 
7 //==============================================================================
8 CircularBufferBase::CircularBufferBase(const std::string& bufferID)
9  : dataBufferId_(bufferID), mfSubject_("CircularBuffer:" + dataBufferId_)
10 {
11 }
12 
13 //==============================================================================
14 CircularBufferBase::~CircularBufferBase(void) {}
15 
16 //==============================================================================
17 void CircularBufferBase::registerProducer(DataProcessor* producer,
18  unsigned int numberOfSubBuffers)
19 {
20  registerProducer(producer->getProcessorID(), numberOfSubBuffers);
21  producer->setCircularBuffer(this);
22 }
23 
24 //==============================================================================
25 void CircularBufferBase::registerConsumer(DataProcessor* consumer)
26 {
27  registerConsumer(consumer->getProcessorID(), HighConsumerPriority);
28  consumer->setCircularBuffer(this);
29 }
33 //{
34 // unregisterProducer(producer->getProcessorID());
35 // producer->setCircularBuffer(0);
36 //}
37 //
40 //{
41 // unregisterConsumer(consumer->getProcessorID());
42 // consumer->setCircularBuffer(0);
43 //}
const std::string & getProcessorID(void) const
Getters.
Definition: DataProcessor.h:31