#include <bulkDataNTReceiverFlow.h>


Public Member Functions | |
| BulkDataNTReceiverFlow (BulkDataNTReceiverStreamBase *receiverStream, const char *flowName, const ReceiverFlowConfiguration &rcvCfg, BulkDataNTCallback *cb, bool releaseCB) | |
| virtual | ~BulkDataNTReceiverFlow () |
| void | setReceiverName (char *recvName) |
| BulkDataNTCallback * | getCallbackObject () |
| template<class T > | |
| T * | getCallback () |
| void | enableCallingCB () |
| Enables calling user's CB (cbStart, cbReceiver, cbStop). | |
| void | disableCallingCB () |
| Disables calling user's CB (cbStart, cbReceiver, cbStop). | |
| void | dumpStatistics () |
Protected Member Functions | |
| BulkDataNTReceiverFlow () | |
| local copy of rcv configuration | |
| void | operator= (const BulkDataNTReceiverFlow &) |
| ALMA C++ coding standards state assignment operators should be disabled. | |
| BulkDataNTReceiverFlow (const BulkDataNTReceiverFlow &) | |
| ALMA C++ coding standards state copy constructors should be disabled. | |
Protected Attributes | |
| AcsBulkdata::BulkDataNTReceiverStreamBase * | receiverStream_m |
| AcsBulkdata::BulkDataNTDDSSubscriber * | ddsSubscriber_m |
| ACSBulkData::BulkDataNTFrameDataReader * | ddsDataReader_m |
| DDS::Topic * | ddsTopic_m |
| BulkDataNTReaderListener * | dataReaderListener_m |
| DDS topic. | |
| BulkDataNTCallback * | callback_m |
| DDS reader. | |
| bool | releaseCB_m |
| callback | |
| ReceiverFlowConfiguration | rcvCfg_m |
| should the CB be destroyed when the flow is destroyed | |
| AcsBulkdata::BulkDataNTReceiverFlow::BulkDataNTReceiverFlow | ( | BulkDataNTReceiverStreamBase * | receiverStream, | |
| const char * | flowName, | |||
| const ReceiverFlowConfiguration & | rcvCfg, | |||
| BulkDataNTCallback * | cb, | |||
| bool | releaseCB | |||
| ) |
Receiver flow constructor. It is used by REceiverStream class.
| receiverStream | pointer to the stream where the flow should be created | |
| flowName | the name of the flow that we want to create | |
| rcvCfg | receiver flow configuration | |
| cb | pointer to the receiver flow callback | |
| releaseCB | should the callback be relased when the flow is destroyed |
| virtual AcsBulkdata::BulkDataNTReceiverFlow::~BulkDataNTReceiverFlow | ( | ) | [virtual] |
Receiver flow destructor
| AcsBulkdata::BulkDataNTReceiverFlow::BulkDataNTReceiverFlow | ( | ) | [protected] |
local copy of rcv configuration
disable default - empty constructor
| AcsBulkdata::BulkDataNTReceiverFlow::BulkDataNTReceiverFlow | ( | const BulkDataNTReceiverFlow & | ) | [protected] |
ALMA C++ coding standards state copy constructors should be disabled.
| void AcsBulkdata::BulkDataNTReceiverFlow::disableCallingCB | ( | ) |
Disables calling user's CB (cbStart, cbReceiver, cbStop).
| void AcsBulkdata::BulkDataNTReceiverFlow::dumpStatistics | ( | ) |
| void AcsBulkdata::BulkDataNTReceiverFlow::enableCallingCB | ( | ) |
Enables calling user's CB (cbStart, cbReceiver, cbStop).
| T* AcsBulkdata::BulkDataNTReceiverFlow::getCallback | ( | ) | [inline] |
template/casted version of getCallbackObject
References callback_m.
| BulkDataNTCallback* AcsBulkdata::BulkDataNTReceiverFlow::getCallbackObject | ( | ) | [inline] |
If we need to get callback object, for example if CB is created using template parameter.
References callback_m.
| void AcsBulkdata::BulkDataNTReceiverFlow::operator= | ( | const BulkDataNTReceiverFlow & | ) | [protected] |
ALMA C++ coding standards state assignment operators should be disabled.
| void AcsBulkdata::BulkDataNTReceiverFlow::setReceiverName | ( | char * | recvName | ) |
Sets the name of receiver, so that we can distinguish between different receivers in the system.
| recvName | name of receiver. |
DDS reader.
Referenced by getCallback(), and getCallbackObject().
DDS topic.
ACSBulkData::BulkDataNTFrameDataReader* AcsBulkdata::BulkDataNTReceiverFlow::ddsDataReader_m [protected] |
AcsBulkdata::BulkDataNTDDSSubscriber* AcsBulkdata::BulkDataNTReceiverFlow::ddsSubscriber_m [protected] |
DDS::Topic* AcsBulkdata::BulkDataNTReceiverFlow::ddsTopic_m [protected] |
should the CB be destroyed when the flow is destroyed
AcsBulkdata::BulkDataNTReceiverStreamBase* AcsBulkdata::BulkDataNTReceiverFlow::receiverStream_m [protected] |
bool AcsBulkdata::BulkDataNTReceiverFlow::releaseCB_m [protected] |
callback
1.7.0