BulkDataReceiverImpl

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.
name component name.

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
ACSBulkDataError::AVFlowEndpointErrorEx

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
ACSBulkDataError::AVFlowEndpointErrorEx

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.6 C++ API from the source code.