BulkDataReceiverImpl − |
#include <bulkDataReceiverImpl.h> Inherits baci::CharacteristicComponentImpl. Inherited by BulkDataReceiver1PerfImpl< TCallback > [virtual], BulkDataReceiverDistr1Impl< TCallback > [virtual], BulkDataReceiverEx2Impl< TCallback > [virtual], and BulkDataReceiverEx3Impl< TCallback > [virtual]. |
Public Member Functions |
BulkDataReceiverImpl (const ACE_CString &name, maci::ContainerServices *containerServices) |
virtual ~BulkDataReceiverImpl () |
void cleanUp () |
virtual AcsBulkdata::BulkDataReceiver< TCallback > * getReceiver () |
virtual void openReceiver () |
void openReceiverStream (const char *stream_name) |
void openReceiverStreamCfg (const char *stream_name, const char *stream_cfg) |
void openReceiverFlow (const char *stream_name, const char *flow_name) |
void openReceiverFlowCfg (const char *stream_name, const char *flow_name, const char *flow_cfg) |
bulkdata::BulkDataReceiverConfig * getReceiverConfig () |
virtual void closeReceiver () |
virtual void closeReceiverStream (const char *stream_name) |
virtual ACSErr::Completion * getCbStatus (CORBA::ULong flowNumber) |
virtual void setTimeout (CORBA::ULong flowNumber, CORBA::ULong timeout) |
virtual void setRecvName (const char *recvName) |
virtual void subscribeNotification (ACS::CBvoid_ptr notifCb) |
void fwdData2UserCB (CORBA::Boolean enable) |
Private Attributes |
AcsBulkdata::BulkDataReceiver< TCallback > receiver |
maci::ContainerServices * containerServices_p |
template<class TCallback> class BulkDataReceiverImpl< TCallback > |
template<class TCallback> BulkDataReceiverImpl< TCallback >::BulkDataReceiverImpl (const ACE_CString & name, maci::ContainerServices * containerServices) Constructor |
Parameters: |
poa Poa which will activate this and also all
other Components. |
template<class TCallback> virtual BulkDataReceiverImpl< TCallback >::~BulkDataReceiverImpl () [virtual] Destructor |
template<class TCallback> void BulkDataReceiverImpl< TCallback >::cleanUp () |
Reimplemented in BulkDataReceiver1PerfImpl< TCallback >, BulkDataReceiverDistr1Impl< TCallback >, BulkDataReceiverDistr2Impl, BulkDataReceiverEx2Impl< TCallback >, and BulkDataReceiverEx3Impl< TCallback >. |
template<class TCallback> virtual void BulkDataReceiverImpl< TCallback >::closeReceiver () [virtual] Exceptions: |
ACSBulkDataError::AVCloseReceiverErrorEx |
template<class TCallback> virtual void BulkDataReceiverImpl< TCallback >::closeReceiverStream (const char * stream_name) [virtual] |
template<class TCallback> void BulkDataReceiverImpl< TCallback >::fwdData2UserCB (CORBA::Boolean enable) Enable or disable that data are sent to the user’s CB. By default this is enable. This operation has to be use with caution!!! |
Parameters: |
enable true -> data will be sent to the user’s CB, false -> data will *not* be sent to the user’s CB, |
Returns: |
void |
template<class TCallback> virtual ACSErr::Completion* BulkDataReceiverImpl< TCallback >::getCbStatus (CORBA::ULong flowNumber) [virtual] Exceptions: |
ACSBulkDataError::AVInvalidFlowNumberEx |
template<class TCallback> virtual AcsBulkdata::BulkDataReceiver<TCallback>* BulkDataReceiverImpl< TCallback >::getReceiver () [inline, virtual] |
template<class TCallback> bulkdata::BulkDataReceiverConfig* BulkDataReceiverImpl< TCallback >::getReceiverConfig () Exceptions: |
ACSBulkDataError::AVReceiverConfigErrorEx |
template<class TCallback> virtual void BulkDataReceiverImpl< TCallback >::openReceiver () [virtual] Opens connection creating an out-of-bound channel using TAO A/V services. It creates the Receiver Stream End Point and Flow End Point for the connection with the Sender. The Receiver Stream End Point can be retrieved as an attribute. |
Exceptions: |
ACSBulkDataError::AVOpenReceiverErrorEx |
Returns: |
void |
template<class TCallback> void BulkDataReceiverImpl< TCallback >::openReceiverFlow (const char * stream_name, const char * flow_name) [inline] |
template<class TCallback> void BulkDataReceiverImpl< TCallback >::openReceiverFlowCfg (const char * stream_name, const char * flow_name, const char * flow_cfg) [inline] |
template<class TCallback> void BulkDataReceiverImpl< TCallback >::openReceiverStream (const char * stream_name) [inline] |
template<class TCallback> void BulkDataReceiverImpl< TCallback >::openReceiverStreamCfg (const char * stream_name, const char * stream_cfg) [inline] |
template<class TCallback> virtual void BulkDataReceiverImpl< TCallback >::setRecvName (const char * recvName) [virtual] Exceptions: |
ACSBulkDataError::AVSetReceiverNameErrorEx |
template<class TCallback> virtual void BulkDataReceiverImpl< TCallback >::setTimeout (CORBA::ULong flowNumber, CORBA::ULong timeout) [virtual] Exceptions: |
ACSBulkDataError::AVInvalidFlowNumberEx |
template<class TCallback> virtual void BulkDataReceiverImpl< TCallback >::subscribeNotification (ACS::CBvoid_ptr notifCb) [virtual] Exceptions: |
ACSBulkDataError::AVNotificationMechanismErrorEx |
template<class TCallback> maci::ContainerServices* BulkDataReceiverImpl< TCallback >::containerServices_p [private] |
template<class TCallback> AcsBulkdata::BulkDataReceiver<TCallback> BulkDataReceiverImpl< TCallback >::receiver [private] |
Referenced by BulkDataReceiverImpl< BulkDataReceiverCbDistr2 >::getReceiver(). |
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |