tdaq-develop-2025-02-12
|
#include <otsdaq/DataManager/DataProducer.h>
Public Member Functions | |
DataProducer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, unsigned int bufferSize=100) | |
virtual void | configure (void) |
virtual void | startProcessingData (std::string runNumber) |
virtual void | stopProcessingData (void) |
![]() | |
DataProducerBase (const std::string &supervisorApplicationUID, const std::string &bufferUID, const std::string &processorUID, unsigned int bufferSize=100) | |
virtual void | registerToBuffer (void) |
mirror DataConsumer::registerToBuffer | |
template<class D , class H > | |
int | attachToEmptySubBuffer (D *&data, H *&header) |
template<class D , class H > | |
int | setWrittenSubBuffer (void) |
template<class D , class H > | |
int | write (const D &buffer) |
template<class D , class H > | |
int | write (const D &buffer, const H &header) |
unsigned int | getBufferSize (void) const |
![]() | |
DataProcessor (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID) | |
virtual void | pauseProcessingData (void) |
virtual void | resumeProcessingData (void) |
const std::string & | getProcessorID (void) const |
Getters. | |
void | setCircularBuffer (CircularBufferBase *circularBuffer) |
![]() | |
WorkLoop (const std::string &name) | |
void | startWorkLoop (void) |
bool | stopWorkLoop (void) |
bool | isActive (void) const |
Additional Inherited Members | |
![]() | |
virtual bool | workLoopThread (toolbox::task::WorkLoop *workLoop)=0 |
const std::string & | getWorkLoopName (void) const |
Getters. | |
![]() | |
const std::string | supervisorApplicationUID_ |
const std::string | bufferUID_ |
const std::string | processorUID_ |
CircularBufferBase * | theCircularBuffer_ |
![]() | |
volatile bool | continueWorkLoop_ |
DataProducer This class provides base class functionality for Data Producer plugin classes to receive incoming streaming data and places it in a Buffer.
Definition at line 12 of file DataProducer.h.