|
| UDPDataListenerProducer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, const ConfigurationTree &theXDAQContextConfigTree, const std::string &configurationPath) |
|
| DataProducer (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID, unsigned int bufferSize=100) |
|
virtual void | startProcessingData (std::string runNumber) |
|
virtual void | stopProcessingData (void) |
|
| DataProducerBase (const std::string &supervisorApplicationUID, const std::string &bufferUID, const std::string &processorUID, unsigned int bufferSize=100) |
|
virtual void | registerToBuffer (void) |
|
template<class D , class H > |
int | attachToEmptySubBuffer (D *&data, H *&header) |
|
template<class D , class H > |
int | setWrittenSubBuffer (void) |
|
template<class D , class H > |
int | write (const D &buffer) |
|
template<class D , class H > |
int | write (const D &buffer, const H &header) |
|
unsigned int | getBufferSize (void) const |
|
| DataProcessor (std::string supervisorApplicationUID, std::string bufferUID, std::string processorUID) |
|
virtual void | pauseProcessingData (void) |
|
virtual void | resumeProcessingData (void) |
|
const std::string & | getProcessorID (void) const |
|
void | setCircularBuffer (CircularBufferBase *circularBuffer) |
|
| WorkLoop (const std::string &name) |
|
void | startWorkLoop (void) |
|
bool | stopWorkLoop (void) |
|
bool | isActive (void) const |
|
| 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 |
|
| ReceiverSocket (std::string IPAddress, unsigned int port=0) |
|
int | receive (std::string &buffer, unsigned int timeoutSeconds=1, unsigned int timeoutUSeconds=0, bool verbose=false) |
|
int | receive (std::vector< uint32_t > &buffer, unsigned int timeoutSeconds=1, unsigned int timeoutUSeconds=0, bool verbose=false) |
|
int | receive (std::string &buffer, unsigned long &fromIPAddress, unsigned short &fromPort, unsigned int timeoutSeconds=1, unsigned int timeoutUSeconds=0, bool verbose=false) |
|
int | receive (std::vector< uint32_t > &buffer, unsigned long &fromIPAddress, unsigned short &fromPort, unsigned int timeoutSeconds=1, unsigned int timeoutUSeconds=0, bool verbose=false) |
|
| Socket (const std::string &IPAddress, unsigned int port=0) |
|
virtual void | initialize (unsigned int socketReceiveBufferSize=defaultSocketReceiveSize_) |
|
struct sockaddr_in & | getSocketAddress (void) |
|
const std::string & | getIPAddress () |
|
uint16_t | getPort () |
|
Definition at line 14 of file UDPDataListenerProducer.h.