ots::TCPDataStreamerConsumer Class Reference
Inheritance diagram for ots::TCPDataStreamerConsumer:
Public Member Functions | |
| TCPDataStreamerConsumer (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) |
| virtual void | startProcessingData (std::string runNumber) |
| virtual void | stopProcessingData (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 | |
| bool | workLoopThread (toolbox::task::WorkLoop *workLoop) |
| void | fastRead (void) |
| void | slowRead (void) |
| Protected Member Functions inherited from ots::WorkLoop | |
| const std::string & | getWorkLoopName (void) const |
| Getters. | |
Protected Attributes | |
| 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_ |
| 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 14 of file TCPDataStreamerConsumer.h.
Constructor & Destructor Documentation
◆ TCPDataStreamerConsumer()
| TCPDataStreamerConsumer::TCPDataStreamerConsumer | ( | std::string | supervisorApplicationUID, |
| std::string | bufferUID, | ||
| std::string | processorUID, | ||
| const ConfigurationTree & | theXDAQContextConfigTree, | ||
| const std::string & | configurationPath | ||
| ) |
, Socket ("192.168.133.1", 47200) , DataConsumer ("ARTDAQDataManager", 1, "ARTDAQBuffer", "ARTDAQDataStreamer0", HighConsumerPriority) , streamToSocket_("192.168.133.1", 50100)
Definition at line 13 of file TCPDataStreamerConsumer_processor.cc.
The documentation for this class was generated from the following files:
- otsdaq/otsdaq/DataProcessorPlugins/TCPDataStreamerConsumer.h
- otsdaq/otsdaq/DataProcessorPlugins/TCPDataStreamerConsumer_processor.cc
