ots::DataProducerBase Class Reference
#include <otsdaq/DataManager/DataProducerBase.h>
Inheritance diagram for ots::DataProducerBase:
Collaboration diagram for ots::DataProducerBase:
Public Member Functions | |
| 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 |
| Public Member Functions inherited from ots::DataProcessor | |
| DataProcessor (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID) | |
| virtual void | configure (void)=0 |
| virtual void | startProcessingData (std::string runNumber)=0 |
| virtual void | stopProcessingData (void)=0 |
| virtual void | pauseProcessingData (void) |
| virtual void | resumeProcessingData (void) |
| const std::string & | getProcessorID (void) const |
| Getters. | |
| void | setCircularBuffer (CircularBufferBase *circularBuffer) |
| uint64_t | getStatPackets (void) const |
| uint64_t | getStatBytes (void) const |
| uint64_t | getStatErrors (void) const |
| uint64_t | getStatBusyNanos (void) const |
| virtual std::map< std::string, std::string > | getExtraStatus (void) const |
| Plugin-specific status items (e.g. socket backlog) as name/value strings. | |
Additional Inherited Members | |
| Protected Member Functions inherited from ots::DataProcessor | |
| void | countPacket (uint64_t bytes) |
| void | countError (void) |
| void | countBusyNanos (uint64_t nanos) |
| Protected Attributes inherited from ots::DataProcessor | |
| const std::string | supervisorApplicationUID_ |
| const std::string | bufferUID_ |
| const std::string | processorUID_ |
| CircularBufferBase * | theCircularBuffer_ |
Detailed Description
DataProducerBase 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 15 of file DataProducerBase.h.
The documentation for this class was generated from the following files:
- otsdaq/otsdaq/DataManager/DataProducerBase.h
- otsdaq/otsdaq/DataManager/DataProducerBase.cc
