#include <bulkDataNTReceiverImpl.h>
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) |
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 Types | |
typedef std::map< std::string, AcsBulkdata::BulkDataNTReceiverStream < TCallback > * > | StreamMap |
Private Member Functions | |
AcsBulkdata::BulkDataNTReceiverStream < TCallback > * | createReceiverStream (const char *stream_name, std::map< std::string, BulkDataConfigurationParser::ReceiverCfg >::iterator &it) |
void | closeStream (typename StreamMap::iterator &it) |
Private Attributes | |
StreamMap | receiverStreams_m |
std::map< std::string, BulkDataConfigurationParser::ReceiverCfg > | recvConfigMap_m |
maci::ContainerServices * | containerServices_p |
typedef std::map<std::string, AcsBulkdata::BulkDataNTReceiverStream<TCallback> *> BulkDataNTReceiverImpl< TCallback >::StreamMap [private] |
BulkDataNTReceiverImpl< TCallback >::BulkDataNTReceiverImpl | ( | const ACE_CString & | name, | |
maci::ContainerServices * | containerServices | |||
) |
Constructor
poa | Poa which will activate this and also all other Components. | |
name | component name. |
virtual BulkDataNTReceiverImpl< TCallback >::~BulkDataNTReceiverImpl | ( | ) | [virtual] |
Destructor
virtual void BulkDataNTReceiverImpl< TCallback >::cleanUp | ( | ) | [virtual] |
virtual void BulkDataNTReceiverImpl< TCallback >::closeReceiver | ( | ) | [virtual] |
ACSBulkDataError::AVCloseReceiverErrorEx |
virtual void BulkDataNTReceiverImpl< TCallback >::closeReceiverStream | ( | const char * | stream_name | ) | [virtual] |
void BulkDataNTReceiverImpl< TCallback >::closeStream | ( | typename StreamMap::iterator & | it | ) | [private] |
AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::createReceiverStream | ( | const char * | stream_name, | |
std::map< std::string, BulkDataConfigurationParser::ReceiverCfg >::iterator & | it | |||
) | [private] |
void BulkDataNTReceiverImpl< TCallback >::fwdData2UserCB | ( | CORBA::Boolean | enable | ) | [inline] |
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!!!
enable | true -> data will be sent to the user's CB, false -> data will *not* be sent to the user's CB, |
virtual ACSErr::Completion* BulkDataNTReceiverImpl< TCallback >::getCbStatus | ( | CORBA::ULong | flowNumber | ) | [inline, virtual] |
ACSBulkDataError::AVInvalidFlowNumberEx | ||
ACSBulkDataError::AVFlowEndpointErrorEx |
bulkdata::BulkDataReceiverConfig* BulkDataNTReceiverImpl< TCallback >::getReceiverConfig | ( | ) |
ACSBulkDataError::AVReceiverConfigErrorEx |
AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::getReceiverStream | ( | const char * | streamName | ) |
virtual void BulkDataNTReceiverImpl< TCallback >::initialize | ( | ) | [virtual] |
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.
ACSBulkDataError::AVOpenReceiverErrorEx |
virtual void BulkDataNTReceiverImpl< TCallback >::openReceiverStream | ( | const char * | stream_name | ) | [virtual] |
virtual void BulkDataNTReceiverImpl< TCallback >::setRecvName | ( | const char * | recvName | ) | [virtual] |
ACSBulkDataError::AVSetReceiverNameErrorEx |
virtual void BulkDataNTReceiverImpl< TCallback >::setTimeout | ( | CORBA::ULong | flowNumber, | |
CORBA::ULong | timeout | |||
) | [inline, virtual] |
ACSBulkDataError::AVInvalidFlowNumberEx | ||
ACSBulkDataError::AVFlowEndpointErrorEx |
virtual void BulkDataNTReceiverImpl< TCallback >::subscribeNotification | ( | ACS::CBvoid_ptr | notifCb | ) | [inline, virtual] |
ACSBulkDataError::AVNotificationMechanismErrorEx |
maci::ContainerServices* BulkDataNTReceiverImpl< TCallback >::containerServices_p [private] |
StreamMap BulkDataNTReceiverImpl< TCallback >::receiverStreams_m [private] |
std::map<std::string, BulkDataConfigurationParser::ReceiverCfg> BulkDataNTReceiverImpl< TCallback >::recvConfigMap_m [private] |