ots::DataProcessor Class Reference

#include <otsdaq/DataManager/DataProcessor.h>

Inheritance diagram for ots::DataProcessor:

Collaboration diagram for ots::DataProcessor:

Public Member Functions
	DataProcessor (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID)
virtual void	registerToBuffer (void)=0
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.

Protected Member Functions
void	countPacket (uint64_t bytes)
void	countError (void)
void	countBusyNanos (uint64_t nanos)

Protected Attributes
const std::string	supervisorApplicationUID_
const std::string	bufferUID_
const std::string	processorUID_
CircularBufferBase *	theCircularBuffer_

Detailed Description

DataProcessor This class provides common functionality for Data Producers and Consumers.

Definition at line 16 of file DataProcessor.h.

Member Function Documentation

getStatPackets()

uint64_t ots::DataProcessor::getStatPackets ( void  ) const

inline

Throughput counters, monotonically increasing since construction. Plugins bump these in their work loops; monitoring code computes rates from deltas. Cheap enough to leave on permanently.

Definition at line 41 of file DataProcessor.h.

---

The documentation for this class was generated from the following files:

• otsdaq/otsdaq/DataManager/DataProcessor.h
• otsdaq/otsdaq/DataManager/DataProcessor.cc