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