rtctk::telRepub::PubThreadBase< Q_SIZE > Class Template Reference

DDS publisher thread class that provides queue with aggregated topic to be published by DDS. More...

#include <ddsPubThread.hpp>

Public Member Functions
	PubThreadBase (const char *topic_name, std::uint32_t queue_size)
	PubThreadBase (const std::string &topic_name, std::uint32_t queue_size)
virtual	~PubThreadBase ()
std::string	getTopicName ()
RepubBuf< rtctk::componentFramework::AgnosticTopic > *	GetRepubBuf ()
	Get internal queue/buffer. More...

Protected Attributes
RepubBuf< rtctk::componentFramework::AgnosticTopic > *	m_repub_buf
unsigned long	rcvSamples_m
unsigned long	skipedSamples_m
uint32_t	lastSkipedSample_m
std::string	topic_name_m
boost::mutex	mut
boost::condition_variable	cond
log4cplus::Logger	m_logger

Detailed Description

template<uint16_t Q_SIZE = 300>
class rtctk::telRepub::PubThreadBase< Q_SIZE >

DDS publisher thread class that provides queue with aggregated topic to be published by DDS.

At the moment the size is hardcoded to 3000 i.e. 3000 agnostic topic samples

Constructor & Destructor Documentation

PubThreadBase() [1/2]

template<uint16_t Q_SIZE = 300>

rtctk::telRepub::PubThreadBase< Q_SIZE >::PubThreadBase ( const char *  topic_name, std::uint32_t  queue_size  )

inline

PubThreadBase() [2/2]

template<uint16_t Q_SIZE = 300>

rtctk::telRepub::PubThreadBase< Q_SIZE >::PubThreadBase ( const std::string &  topic_name, std::uint32_t  queue_size  )

inline

~PubThreadBase()

template<uint16_t Q_SIZE = 300>

virtual rtctk::telRepub::PubThreadBase< Q_SIZE >::~PubThreadBase ( )

inlinevirtual

Member Function Documentation

GetRepubBuf()

template<uint16_t Q_SIZE = 300>

RepubBuf<rtctk::componentFramework::AgnosticTopic>* rtctk::telRepub::PubThreadBase< Q_SIZE >::GetRepubBuf ( )

inline

Get internal queue/buffer.

Returns

pointer to the queue / buffer

getTopicName()

template<uint16_t Q_SIZE = 300>

std::string rtctk::telRepub::PubThreadBase< Q_SIZE >::getTopicName ( )

inline

Member Data Documentation

cond

template<uint16_t Q_SIZE = 300>

boost::condition_variable rtctk::telRepub::PubThreadBase< Q_SIZE >::cond

protected

lastSkipedSample_m

template<uint16_t Q_SIZE = 300>

uint32_t rtctk::telRepub::PubThreadBase< Q_SIZE >::lastSkipedSample_m

protected

m_logger

template<uint16_t Q_SIZE = 300>

log4cplus::Logger rtctk::telRepub::PubThreadBase< Q_SIZE >::m_logger

protected

m_repub_buf

template<uint16_t Q_SIZE = 300>

RepubBuf<rtctk::componentFramework::AgnosticTopic>* rtctk::telRepub::PubThreadBase< Q_SIZE >::m_repub_buf

protected

mut

template<uint16_t Q_SIZE = 300>

boost::mutex rtctk::telRepub::PubThreadBase< Q_SIZE >::mut

protected

rcvSamples_m

template<uint16_t Q_SIZE = 300>

unsigned long rtctk::telRepub::PubThreadBase< Q_SIZE >::rcvSamples_m

protected

skipedSamples_m

template<uint16_t Q_SIZE = 300>

unsigned long rtctk::telRepub::PubThreadBase< Q_SIZE >::skipedSamples_m

protected

topic_name_m

template<uint16_t Q_SIZE = 300>

std::string rtctk::telRepub::PubThreadBase< Q_SIZE >::topic_name_m

protected

---

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

• reusableComponents/telRepub/src/ddsPubThread.hpp