otsdaq  3.11.00
Public Member Functions | Protected Member Functions | Protected Attributes | List of all members
ots::UDPDataStreamerConsumer Class Reference
+ Inheritance diagram for ots::UDPDataStreamerConsumer:
+ Collaboration diagram for ots::UDPDataStreamerConsumer:

Public Member Functions

 UDPDataStreamerConsumer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath)
 
- Public Member Functions inherited from ots::UDPDataStreamerBase
 UDPDataStreamerBase (std::string IPAddress, unsigned int port, std::string toIPAddress, unsigned int toPort)
 
int send (const std::string &buffer)
 
int send (const std::vector< uint32_t > &buffer)
 
- Public Member Functions inherited from ots::TransmitterSocket
 TransmitterSocket (const std::string &IPAddress, unsigned int port=0)
 
int send (Socket &toSocket, const std::string &buffer, bool verbose=false)
 
int send (Socket &toSocket, const std::vector< uint32_t > &buffer, bool verbose=false)
 
int send (Socket &toSocket, const std::vector< uint16_t > &buffer, bool verbose=false)
 
- Public Member Functions inherited from ots::Socket
 Socket (const std::string &IPAddress, unsigned int port=0)
 
virtual void initialize (unsigned int socketReceiveBufferSize=defaultSocketReceiveSize_)
 
const struct sockaddr_in & getSocketAddress (void)
 
const std::string & getIPAddress ()
 
uint16_t getPort ()
 
bool isInitialized ()
 
- 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)
 
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.
 
- 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::Socket
 Socket (void)
 protected constructor
 
- Protected Member Functions inherited from ots::DataProcessor
void countPacket (uint64_t bytes)
 
void countError (void)
 
void countBusyNanos (uint64_t nanos)
 
- 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::UDPDataStreamerBase
ReceiverSocket streamToSocket_
 
- Protected Attributes inherited from ots::Socket
struct sockaddr_in socketAddress_
 
int socketNumber_
 
std::string IPAddress_
 
unsigned int requestedPort_
 
bool isInitialized_ = false
 
- 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 }
 
- Protected Types inherited from ots::Socket
enum  { maxSocketSize_ = 65536 , defaultSocketReceiveSize_ = 0x10000 }
 
enum  { FirstSocketPort = 10000 , LastSocketPort = 15000 }
 

Detailed Description

Definition at line 14 of file UDPDataStreamerConsumer.h.

Constructor & Destructor Documentation

◆ UDPDataStreamerConsumer()

UDPDataStreamerConsumer::UDPDataStreamerConsumer ( 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 UDPDataStreamerConsumer_processor.cc.

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