ADORe
ADORe is a modular open source software library and toolkit for decision making, planning, control and simulation of automated vehicles
ZMQObjectSink< T > Class Template Reference

#include <zmqobjectsink.h>

Collaboration diagram for ZMQObjectSink< T >:
Collaboration graph

Public Member Functions

 ZMQObjectSink (zmq::context_t &context, unsigned int Port)
 
 ZMQObjectSink (unsigned int Port)
 
virtual ~ZMQObjectSink ()
 
bool has_data ()
 
T * pop_data ()
 

Private Member Functions

void push_data (T *value)
 
virtual void initialize (zmq::context_t &context, unsigned int Port)
 

Private Attributes

zmq::socket_t * m_socket
 
pthread_t m_thread
 
pthread_mutex_t m_mutex
 
bool terminate
 
std::list< T * > buffer
 
zmq::context_t * m_context
 

Friends

void * pthread_ZMQObjectSink_worker (void *that)
 

Constructor & Destructor Documentation

◆ ZMQObjectSink() [1/2]

template<typename T >
ZMQObjectSink< T >::ZMQObjectSink ( zmq::context_t &  context,
unsigned int  Port 
)
inline
Here is the call graph for this function:

◆ ZMQObjectSink() [2/2]

template<typename T >
ZMQObjectSink< T >::ZMQObjectSink ( unsigned int  Port)
inline
Here is the call graph for this function:

◆ ~ZMQObjectSink()

template<typename T >
virtual ZMQObjectSink< T >::~ZMQObjectSink ( )
inlinevirtual

Member Function Documentation

◆ has_data()

template<typename T >
bool ZMQObjectSink< T >::has_data ( )
inline

◆ initialize()

template<typename T >
virtual void ZMQObjectSink< T >::initialize ( zmq::context_t &  context,
unsigned int  Port 
)
inlineprivatevirtual
Here is the caller graph for this function:

◆ pop_data()

template<typename T >
T* ZMQObjectSink< T >::pop_data ( )
inline

◆ push_data()

template<typename T >
void ZMQObjectSink< T >::push_data ( T *  value)
inlineprivate

Friends And Related Function Documentation

◆ pthread_ZMQObjectSink_worker

template<typename T >
void* pthread_ZMQObjectSink_worker ( void *  that)
friend

Member Data Documentation

◆ buffer

template<typename T >
std::list<T*> ZMQObjectSink< T >::buffer
private

◆ m_context

template<typename T >
zmq::context_t* ZMQObjectSink< T >::m_context
private

◆ m_mutex

template<typename T >
pthread_mutex_t ZMQObjectSink< T >::m_mutex
private

◆ m_socket

template<typename T >
zmq::socket_t* ZMQObjectSink< T >::m_socket
private

◆ m_thread

template<typename T >
pthread_t ZMQObjectSink< T >::m_thread
private

◆ terminate

template<typename T >
bool ZMQObjectSink< T >::terminate
private

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