ots::RawDataSaverConsumerBase Class Reference
Inheritance diagram for ots::RawDataSaverConsumerBase:
Collaboration diagram for ots::RawDataSaverConsumerBase:
Public Member Functions | |
| RawDataSaverConsumerBase (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath) | |
| Public Member Functions inherited from ots::DataConsumer | |
| DataConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, ConsumerPriority priority) | |
| virtual void | registerToBuffer (void) |
| mirror DataProducerBase::registerToBuffer | |
| virtual void | configure (void) |
| template<class D , class H > | |
| int | read (D &buffer, H &header) |
| Copies the buffer into the passed parameters. | |
| template<class D , class H > | |
| int | read (D *&buffer, H *&header) |
| Fast version where you point to the buffer without copying. | |
| template<class D , class H > | |
| int | setReadSubBuffer (void) |
| template<class D , class H > | |
| int | read (D &buffer) |
| ConsumerPriority | getPriority (void) |
| Public Member Functions inherited from ots::DataProcessor | |
| 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) |
| Public Member Functions inherited from ots::WorkLoop | |
| WorkLoop (const std::string &name) | |
| void | startWorkLoop (void) |
| bool | stopWorkLoop (void) |
| bool | isActive (void) const |
| Public Member Functions inherited from ots::Configurable | |
| Configurable (const ConfigurationTree &theXDAQContextConfigTree, const std::string &theConfigurationPath) | |
| ConfigurationTree | getSelfNode () const |
| const ConfigurationManager * | getConfigurationManager () const |
| const std::string & | getContextUID () const |
| const std::string & | getApplicationUID () const |
| unsigned int | getApplicationLID () const |
| std::string | getContextAddress () const |
| unsigned int | getContextPort () const |
Protected Member Functions | |
| virtual void | openFile (std::string runNumber) |
| virtual void | closeFile (void) |
| virtual void | save (const std::string &data) |
| virtual void | writeHeader (void) |
| virtual void | writeFooter (void) |
| virtual void | writePacketHeader (const std::string &) |
| virtual void | writePacketFooter (const std::string &) |
| virtual void | startProcessingData (std::string runNumber) override |
| virtual void | stopProcessingData (void) override |
| virtual bool | workLoopThread (toolbox::task::WorkLoop *workLoop) override |
| virtual void | fastRead (void) |
| virtual void | slowRead (void) |
| Protected Member Functions inherited from ots::WorkLoop | |
| const std::string & | getWorkLoopName (void) const |
| Getters. | |
Protected Attributes | |
| std::ofstream | outFile_ |
| std::string * | dataP_ |
| For fast read. | |
| std::map< std::string, std::string > * | headerP_ |
| std::string | data_ |
| For slow read. | |
| std::map< std::string, std::string > | header_ |
| std::string | filePath_ |
| std::string | fileRadix_ |
| long | maxFileSize_ |
| std::string | currentRunNumber_ |
| unsigned int | currentSubRunNumber_ |
| Protected Attributes inherited from ots::DataProcessor | |
| const std::string | supervisorApplicationUID_ |
| const std::string | bufferUID_ |
| const std::string | processorUID_ |
| CircularBufferBase * | theCircularBuffer_ |
| Protected Attributes inherited from ots::WorkLoop | |
| volatile bool | continueWorkLoop_ |
| Protected Attributes inherited from ots::Configurable | |
| const ConfigurationTree | theXDAQContextConfigTree_ |
| const std::string | theConfigurationPath_ |
| const std::string | theConfigurationRecordName_ |
Additional Inherited Members | |
| Public Types inherited from ots::DataConsumer | |
| enum | ConsumerPriority { LowConsumerPriority , HighConsumerPriority } |
Detailed Description
Definition at line 12 of file RawDataSaverConsumerBase.h.
Member Function Documentation
◆ startProcessingData()
|
overrideprotectedvirtual |
mirror DataProducerBase::unregisterFromBuffer void DataConsumer::unregisterFromBuffer(void)
Reimplemented from ots::DataConsumer.
Definition at line 46 of file RawDataSaverConsumerBase.cc.
The documentation for this class was generated from the following files:
- otsdaq/otsdaq/DataManager/RawDataSaverConsumerBase.h
- otsdaq/otsdaq/DataManager/RawDataSaverConsumerBase.cc
