madara::transport::NDDSReadThread Class Reference

Thread for reading knowledge updates via a NDDS waitset (deprecated and unused). More...

#include <NddsTransportReadThread.h>

Inheritance diagram for madara::transport::NDDSReadThread:

Collaboration diagram for madara::transport::NDDSReadThread:

Public Member Functions
	NDDSReadThread (const std::string &id, knowledge::ThreadSafeContext &context, NDDSKnowledgeUpdateDataReader *reader)
	~NDDSReadThread ()
int	close (void)
int	enter_barrier (void)
	service exit point for thread More...
int	svc (void)
void	wait_for_ready (void)

Private Member Functions
void	handle_assignment (NDDSKnowledgeUpdate &data)
void	handle_multiassignment (NDDSKnowledgeUpdate &data)

Private Attributes
::std::vector< ::std::string >	assignment_symbols_
ACE_Barrier	barrier_
	typdef for a threadsafe counter More...
knowledge::ThreadSafeContext &	context_
NDDSKnowledgeUpdateDataReader *	data_reader_
bool	enable_mutexing_
const std::string	id_
transport::Condition	is_not_ready_
bool	is_ready_
ACE_Thread_Mutex	mutex_
ACE_Atomic_Op< ACE_Mutex, bool >	terminated_

Detailed Description

Thread for reading knowledge updates via a NDDS waitset (deprecated and unused).

Definition at line 30 of file NddsTransportReadThread.h.

Constructor & Destructor Documentation

madara::transport::NDDSReadThread::NDDSReadThread	(	const std::string &	id,
		knowledge::ThreadSafeContext &	context,
		NDDSKnowledgeUpdateDataReader *	reader
	)

Definition at line 11 of file NddsTransportReadThread.cpp.

madara::transport::NDDSReadThread::~NDDSReadThread

(

)

Definition at line 30 of file NddsTransportReadThread.cpp.

Member Function Documentation

int madara::transport::NDDSReadThread::close

(

void

)

Definition at line 36 of file NddsTransportReadThread.cpp.

int madara::transport::NDDSReadThread::enter_barrier

(

void

)

service exit point for thread

Definition at line 51 of file NddsTransportReadThread.cpp.

void madara::transport::NDDSReadThread::handle_assignment ( NDDSKnowledgeUpdate &  data )

private

Definition at line 61 of file NddsTransportReadThread.cpp.

void madara::transport::NDDSReadThread::handle_multiassignment ( NDDSKnowledgeUpdate &  data )

private

Definition at line 132 of file NddsTransportReadThread.cpp.

int madara::transport::NDDSReadThread::svc

(

void

)

Definition at line 211 of file NddsTransportReadThread.cpp.

void madara::transport::NDDSReadThread::wait_for_ready

(

void

)

Definition at line 45 of file NddsTransportReadThread.cpp.

Member Data Documentation

::std::vector< ::std::string> madara::transport::NDDSReadThread::assignment_symbols_

private

Definition at line 48 of file NddsTransportReadThread.h.

ACE_Barrier madara::transport::NDDSReadThread::barrier_

private

typdef for a threadsafe counter

Definition at line 53 of file NddsTransportReadThread.h.

knowledge::ThreadSafeContext& madara::transport::NDDSReadThread::context_

private

Definition at line 51 of file NddsTransportReadThread.h.

NDDSKnowledgeUpdateDataReader* madara::transport::NDDSReadThread::data_reader_

private

Definition at line 62 of file NddsTransportReadThread.h.

bool madara::transport::NDDSReadThread::enable_mutexing_

private

Definition at line 59 of file NddsTransportReadThread.h.

const std::string madara::transport::NDDSReadThread::id_

private

Definition at line 50 of file NddsTransportReadThread.h.

transport::Condition madara::transport::NDDSReadThread::is_not_ready_

private

Definition at line 57 of file NddsTransportReadThread.h.

bool madara::transport::NDDSReadThread::is_ready_

private

Definition at line 58 of file NddsTransportReadThread.h.

ACE_Thread_Mutex madara::transport::NDDSReadThread::mutex_

private

Definition at line 56 of file NddsTransportReadThread.h.

ACE_Atomic_Op<ACE_Mutex,bool> madara::transport::NDDSReadThread::terminated_

private

Definition at line 54 of file NddsTransportReadThread.h.

---

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

• include/madara/transport/ndds/NddsTransportReadThread.h
• include/madara/transport/ndds/NddsTransportReadThread.cpp