BulkDataNTReceiverImpl

BulkDataNTReceiverImpl −

#include <bulkDataNTReceiverImpl.h>

Inherits baci::CharacteristicComponentImpl.

Public Member Functions

BulkDataNTReceiverImpl (const ACE_CString &name, maci::ContainerServices *containerServices)

virtual ~BulkDataNTReceiverImpl ()

virtual void initialize ()

virtual void cleanUp ()

AcsBulkdata::BulkDataNTReceiverStream< TCallback > * getReceiverStream (const char *streamName)

virtual void openReceiver ()

virtual 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)

Protected Member Functions

virtual bool usesOldConfigurationMechanism ()

Private Types

typedef std::map< std::string, AcsBulkdata::BulkDataNTReceiverStream< TCallback > * > StreamMap

Private Member Functions

AcsBulkdata::BulkDataNTReceiverStream< TCallback > * createReceiverStream (const char *stream_name, const char *stream_cfg)

AcsBulkdata::BulkDataNTReceiverStream< TCallback > * createDefaultReceiverStream (const char *stream_cfg)

Private Attributes

StreamMap receiverStreams_m

ACE_Recursive_Thread_Mutex rcvStreamMapMutex_m

AcsBulkdata::BulkDataConfigurationParser * parser_m

int defaultFlowsCount_m

bool fwdData2UserCBenabled_m

template<class TCallback> class BulkDataNTReceiverImpl< TCallback >

template<class TCallback> typedef std::map<std::string, AcsBulkdata::BulkDataNTReceiverStream<TCallback> *> BulkDataNTReceiverImpl< TCallback >::StreamMap [private]

template<class TCallback> BulkDataNTReceiverImpl< TCallback >::BulkDataNTReceiverImpl (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 BulkDataNTReceiverImpl< TCallback >::~BulkDataNTReceiverImpl () [virtual] Destructor

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::cleanUp () [virtual]

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::closeReceiver () [virtual] Exceptions:

ACSBulkDataError::AVCloseReceiverErrorEx

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::closeReceiverStream (const char * stream_name) [virtual]

template<class TCallback> AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::createDefaultReceiverStream (const char * stream_cfg) [private]

template<class TCallback> AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::createReceiverStream (const char * stream_name, const char * stream_cfg) [private]

template<class TCallback> void BulkDataNTReceiverImpl< 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* BulkDataNTReceiverImpl< TCallback >::getCbStatus (CORBA::ULong flowNumber) [inline, virtual] Exceptions:

ACSBulkDataError::AVInvalidFlowNumberEx
ACSBulkDataError::AVFlowEndpointErrorEx

template<class TCallback> bulkdata::BulkDataReceiverConfig* BulkDataNTReceiverImpl< TCallback >::getReceiverConfig () Exceptions:

ACSBulkDataError::AVReceiverConfigErrorEx

template<class TCallback> AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::getReceiverStream (const char * streamName)

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::initialize () [virtual]

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback> virtual void BulkDataNTReceiverImpl< 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

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback> void BulkDataNTReceiverImpl< TCallback >::openReceiverFlow (const char * stream_name, const char * flow_name) Parameters:

stream_name
flow_name

Todo

to be implemented

template<class TCallback> void BulkDataNTReceiverImpl< TCallback >::openReceiverFlowCfg (const char * stream_name, const char * flow_name, const char * flow_cfg) Parameters:

stream_name
flow_name
flow_cfg

Todo

to be implemented

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::openReceiverStream (const char * stream_name) [virtual] Parameters:

stream_name

template<class TCallback> void BulkDataNTReceiverImpl< TCallback >::openReceiverStreamCfg (const char * stream_name, const char * stream_cfg) Parameters:

stream_name
stream_cfg

Todo

to be implemented

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::setRecvName (const char * recvName) [virtual] Exceptions:

ACSBulkDataError::AVSetReceiverNameErrorEx

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::setTimeout (CORBA::ULong flowNumber, CORBA::ULong timeout) [inline, virtual] Exceptions:

ACSBulkDataError::AVInvalidFlowNumberEx
ACSBulkDataError::AVFlowEndpointErrorEx

template<class TCallback> virtual void BulkDataNTReceiverImpl< TCallback >::subscribeNotification (ACS::CBvoid_ptr notifCb) [inline, virtual] Exceptions:

ACSBulkDataError::AVNotificationMechanismErrorEx

template<class TCallback> virtual bool BulkDataNTReceiverImpl< TCallback >::usesOldConfigurationMechanism () [protected, virtual] Indicates if this component’s alma/ branch exposes the new or the old configuration mechanism

Returns:

Whether this component is configured using the new or the old configuration mechanism

template<class TCallback> int BulkDataNTReceiverImpl< TCallback >::defaultFlowsCount_m [private]

template<class TCallback> bool BulkDataNTReceiverImpl< TCallback >::fwdData2UserCBenabled_m [private]

template<class TCallback> AcsBulkdata::BulkDataConfigurationParser* BulkDataNTReceiverImpl< TCallback >::parser_m [private]

template<class TCallback> ACE_Recursive_Thread_Mutex BulkDataNTReceiverImpl< TCallback >::rcvStreamMapMutex_m [private]

template<class TCallback> StreamMap BulkDataNTReceiverImpl< TCallback >::receiverStreams_m [private]

Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code.