BulkDataNTReaderListener Class Reference

#include <bulkDataNTReaderListener.h>

Inheritance diagram for BulkDataNTReaderListener:

Collaboration diagram for BulkDataNTReaderListener:

List of all members.

Public Member Functions
	BulkDataNTReaderListener (const char *name, AcsBulkdata::BulkDataNTCallback *cb)
virtual	~BulkDataNTReaderListener (void)
virtual void	on_requested_deadline_missed (DDS::DataReader *reader, const DDS::RequestedDeadlineMissedStatus &status)
virtual void	on_requested_incompatible_qos (DDS::DataReader *reader, const DDS::RequestedIncompatibleQosStatus &status)
virtual void	on_liveliness_changed (DDS::DataReader *reader, const DDS::LivelinessChangedStatus &status)
virtual void	on_subscription_matched (DDS::DataReader *reader, const DDS::SubscriptionMatchedStatus &status)
virtual void	on_sample_rejected (DDS::DataReader *reader, const DDS::SampleRejectedStatus &status)
virtual void	on_data_available (DDS::DataReader *reader)
virtual void	on_sample_lost (DDS::DataReader *reader, const DDS::SampleLostStatus &status)
Private Types
enum	ReaderListenerStates { StartState, DataRcvState, StopState }
Private Member Functions
void	increasConseqErrorCount ()
Private Attributes
ReaderListenerStates	currentState_m
std::string	topicName_m
	current state of ReaderListener
unsigned int	conseqErrorCount_m
	name of DDS topic
unsigned int	maxConseqErrorCount_m
ACE_Time_Value	start_time
unsigned long	dataLength_m
	for performance test
unsigned long	frameCounter_m
	length of data arrived so far after startSend/paramter
unsigned long	totalFrames_m
	number of *data* frame arrived so far for sendData
unsigned long	nextFrame_m
	total number of frames that we should get for current sendData
ACSBulkData::BulkDataNTFrameDataReader *	frameDataReader_mp
	the count of next frame that should be received
AcsBulkdata::BulkDataNTCallback *	callback_mp
	pointer to DDS reader

---

Member Enumeration Documentation

enum BulkDataNTReaderListener::ReaderListenerStates [private]

Enumerator:

StartState
DataRcvState
StopState

---

Constructor & Destructor Documentation

BulkDataNTReaderListener::BulkDataNTReaderListener	(	const char *	name,
		AcsBulkdata::BulkDataNTCallback *	cb
	)

virtual BulkDataNTReaderListener::~BulkDataNTReaderListener

(

void

)

[virtual]

---

Member Function Documentation

void BulkDataNTReaderListener::increasConseqErrorCount

(

)

[private]

virtual void BulkDataNTReaderListener::on_data_available

(

DDS::DataReader *

reader

)

[virtual]

virtual void BulkDataNTReaderListener::on_liveliness_changed	(	DDS::DataReader *	reader,
		const DDS::LivelinessChangedStatus &	status
	)			[virtual]

virtual void BulkDataNTReaderListener::on_requested_deadline_missed	(	DDS::DataReader *	reader,
		const DDS::RequestedDeadlineMissedStatus &	status
	)			[virtual]

virtual void BulkDataNTReaderListener::on_requested_incompatible_qos	(	DDS::DataReader *	reader,
		const DDS::RequestedIncompatibleQosStatus &	status
	)			[virtual]

virtual void BulkDataNTReaderListener::on_sample_lost	(	DDS::DataReader *	reader,
		const DDS::SampleLostStatus &	status
	)			[virtual]

virtual void BulkDataNTReaderListener::on_sample_rejected	(	DDS::DataReader *	reader,
		const DDS::SampleRejectedStatus &	status
	)			[virtual]

virtual void BulkDataNTReaderListener::on_subscription_matched	(	DDS::DataReader *	reader,
		const DDS::SubscriptionMatchedStatus &	status
	)			[virtual]

---

Member Data Documentation

AcsBulkdata::BulkDataNTCallback* BulkDataNTReaderListener::callback_mp [private]

pointer to DDS reader

unsigned int BulkDataNTReaderListener::conseqErrorCount_m [private]

name of DDS topic

ReaderListenerStates BulkDataNTReaderListener::currentState_m [private]

unsigned long BulkDataNTReaderListener::dataLength_m [private]

for performance test

unsigned long BulkDataNTReaderListener::frameCounter_m [private]

length of data arrived so far after startSend/paramter

ACSBulkData::BulkDataNTFrameDataReader* BulkDataNTReaderListener::frameDataReader_mp [private]

the count of next frame that should be received

unsigned int BulkDataNTReaderListener::maxConseqErrorCount_m [private]

unsigned long BulkDataNTReaderListener::nextFrame_m [private]

total number of frames that we should get for current sendData

ACE_Time_Value BulkDataNTReaderListener::start_time [private]

std::string BulkDataNTReaderListener::topicName_m [private]

current state of ReaderListener

unsigned long BulkDataNTReaderListener::totalFrames_m [private]

number of *data* frame arrived so far for sendData

---

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

• bulkDataNTReaderListener.h