ots::OtsDataSaverConsumer Class Reference
Inheritance diagram for ots::OtsDataSaverConsumer:
Collaboration diagram for ots::OtsDataSaverConsumer:
Public Member Functions | |
| OtsDataSaverConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath) | |
| virtual void | writePacketHeader (const std::string &data) override |
| add one byte quad-word count before each packet | |
| Public Member Functions inherited from ots::RawDataSaverConsumerBase | |
| 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 | |
| void | writeHeader (void) override |
| Protected Member Functions inherited from ots::RawDataSaverConsumerBase | |
| virtual void | openFile (std::string runNumber) |
| virtual void | closeFile (void) |
| virtual void | save (const std::string &data) |
| virtual void | writeFooter (void) |
| 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 | |
| unsigned char | lastSeqId_ |
| Protected Attributes inherited from ots::RawDataSaverConsumerBase | |
| 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 8 of file OtsDataSaverConsumer.h.
The documentation for this class was generated from the following files:
- otsdaq/otsdaq/DataProcessorPlugins/OtsDataSaverConsumer.h
- otsdaq/otsdaq/DataProcessorPlugins/OtsDataSaverConsumer_processor.cc
