|
AcsBulkdata::BulkDataNTReaderListener − |
|
#include <bulkDataNTReaderListener.h> Inherits BulkDataNTDDSLoggable. |
|
Public Member Functions |
|
BulkDataNTReaderListener (const char *name, BulkDataNTCallback *cb) |
|
virtual ~BulkDataNTReaderListener (void) |
|
void enableCallingCB () |
|
Enables calling user’s CB (cbStart, cbReceiver, cbStop). |
|
void disableCallingCB () |
|
Disables calling user’s CB (cbStart, cbReceiver, cbStop). |
|
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, IgnoreDataState } |
|
Private Member Functions |
|
void increasConseqErrorCount () |
|
Private Attributes |
|
ReaderListenerStates currentState_m |
|
std::string topicName_m |
|
strings name of states |
|
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 |
|
BulkDataNTCallback * callback_mp |
|
pointer to DDS reader |
|
bool enableCB_m |
|
pointer to user defined callback |
|
ACE_Time_Value cbReceiveStartTime_m |
|
should be called user’s callback or not ? |
|
ACE_Time_Value cbReceiveElapsedTime_m |
|
time just be4 cbReceive is going to be executed |
|
double cbReceiveElapsedTimeSec_m |
|
elapsed time of cbReceive |
|
double cbReceiveTimeoutSec_m |
|
elapsed time in sec |
|
double cbReceiveTotalSec_m |
|
cbReceiver process timeout read from CDB (or default value) |
|
unsigned int cbReceiveNumCalls_m |
|
total time all cbReceive calls between cbStart and cbStop |
|
double cbReceiveAvgSec_m |
|
how many times cbReceive was called between cbStart and cbStop |
|
double cbReceiveAvgTimeoutSec_m |
|
average process time for all cbReceive calls between cbStart and cbStop |
|
DDS::ReturnCode_t retCode |
|
cbReceiver avergae process timeout read from CDB (or default value) |
|
DDS::SampleInfo si |
|
ACSBulkData::BulkDataNTFrame message |
|
unsigned char tmpArray [ACSBulkData::FRAME_MAX_LEN] |
|
Static Private Attributes |
|
static const char * state2String [] |
|
current state of ReaderListener |
|
enum AcsBulkdata::BulkDataNTReaderListener::ReaderListenerStates [private] ReaderListener’s state: IgnoreDataState - we go in this state when we get WrongDataError for Data ... and we stay there until next start/stop. In this way we prevent overfloating with error msg. |
|
Enumerator: |
|
StartState |
|
DataRcvState |
|
StopState |
|
IgnoreDataState |
|
AcsBulkdata::BulkDataNTReaderListener::BulkDataNTReaderListener (const char * name, BulkDataNTCallback * cb) |
|
virtual AcsBulkdata::BulkDataNTReaderListener::~BulkDataNTReaderListener (void) [virtual] |
|
void AcsBulkdata::BulkDataNTReaderListener::disableCallingCB () |
|
Disables calling user’s CB (cbStart, cbReceiver, cbStop). |
|
void AcsBulkdata::BulkDataNTReaderListener::enableCallingCB () |
|
Enables calling user’s CB (cbStart, cbReceiver, cbStop). |
|
void AcsBulkdata::BulkDataNTReaderListener::increasConseqErrorCount () [private] |
|
virtual void AcsBulkdata::BulkDataNTReaderListener::on_data_available (DDS::DataReader * reader) [virtual] |
|
virtual void AcsBulkdata::BulkDataNTReaderListener::on_liveliness_changed (DDS::DataReader * reader, const DDS::LivelinessChangedStatus & status) [virtual] |
|
virtual void AcsBulkdata::BulkDataNTReaderListener::on_requested_deadline_missed (DDS::DataReader * reader, const DDS::RequestedDeadlineMissedStatus & status) [virtual] |
|
virtual void AcsBulkdata::BulkDataNTReaderListener::on_requested_incompatible_qos (DDS::DataReader * reader, const DDS::RequestedIncompatibleQosStatus & status) [virtual] |
|
virtual void AcsBulkdata::BulkDataNTReaderListener::on_sample_lost (DDS::DataReader * reader, const DDS::SampleLostStatus & status) [virtual] |
|
virtual void AcsBulkdata::BulkDataNTReaderListener::on_sample_rejected (DDS::DataReader * reader, const DDS::SampleRejectedStatus & status) [virtual] |
|
virtual void AcsBulkdata::BulkDataNTReaderListener::on_subscription_matched (DDS::DataReader * reader, const DDS::SubscriptionMatchedStatus & status) [virtual] |
|
BulkDataNTCallback* AcsBulkdata::BulkDataNTReaderListener::callback_mp [private] |
|
pointer to DDS reader |
|
double AcsBulkdata::BulkDataNTReaderListener::cbReceiveAvgSec_m [private] |
|
how many times cbReceive was called between cbStart and cbStop |
|
double AcsBulkdata::BulkDataNTReaderListener::cbReceiveAvgTimeoutSec_m [private] |
|
average process time for all cbReceive calls between cbStart and cbStop |
|
ACE_Time_Value AcsBulkdata::BulkDataNTReaderListener::cbReceiveElapsedTime_m [private] |
|
time just be4 cbReceive is going to be executed |
|
double AcsBulkdata::BulkDataNTReaderListener::cbReceiveElapsedTimeSec_m [private] |
|
elapsed time of cbReceive |
|
unsigned int AcsBulkdata::BulkDataNTReaderListener::cbReceiveNumCalls_m [private] |
|
total time all cbReceive calls between cbStart and cbStop |
|
ACE_Time_Value AcsBulkdata::BulkDataNTReaderListener::cbReceiveStartTime_m [private] |
|
should be called user’s callback or not ? |
|
double AcsBulkdata::BulkDataNTReaderListener::cbReceiveTimeoutSec_m [private] |
|
elapsed time in sec |
|
double AcsBulkdata::BulkDataNTReaderListener::cbReceiveTotalSec_m [private] |
|
cbReceiver process timeout read from CDB (or default value) |
|
unsigned int AcsBulkdata::BulkDataNTReaderListener::conseqErrorCount_m [private] |
|
name of DDS topic |
|
ReaderListenerStates AcsBulkdata::BulkDataNTReaderListener::currentState_m [private] |
|
unsigned long AcsBulkdata::BulkDataNTReaderListener::dataLength_m [private] |
|
for performance test |
|
bool AcsBulkdata::BulkDataNTReaderListener::enableCB_m [private] |
|
pointer to user defined callback |
|
unsigned long AcsBulkdata::BulkDataNTReaderListener::frameCounter_m [private] |
|
length of data arrived so far after startSend/paramter |
|
ACSBulkData::BulkDataNTFrameDataReader* AcsBulkdata::BulkDataNTReaderListener::frameDataReader_mp [private] |
|
the count of next frame that should be received |
|
unsigned int AcsBulkdata::BulkDataNTReaderListener::maxConseqErrorCount_m [private] |
|
ACSBulkData::BulkDataNTFrame AcsBulkdata::BulkDataNTReaderListener::message [private] |
|
unsigned long AcsBulkdata::BulkDataNTReaderListener::nextFrame_m [private] |
|
total number of frames that we should get for current sendData |
|
DDS::ReturnCode_t AcsBulkdata::BulkDataNTReaderListener::retCode [private] |
|
cbReceiver avergae process timeout read from CDB (or default value) |
|
DDS::SampleInfo AcsBulkdata::BulkDataNTReaderListener::si [private] |
|
ACE_Time_Value AcsBulkdata::BulkDataNTReaderListener::start_time [private] |
|
const char* AcsBulkdata::BulkDataNTReaderListener::state2String[] [static, private] |
|
current state of ReaderListener |
|
unsigned char AcsBulkdata::BulkDataNTReaderListener::tmpArray[ACSBulkData::FRAME_MAX_LEN] [private] |
|
std::string AcsBulkdata::BulkDataNTReaderListener::topicName_m [private] |
|
strings name of states |
|
unsigned long AcsBulkdata::BulkDataNTReaderListener::totalFrames_m [private] |
|
number of *data* frame arrived so far for sendData |
|
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |