#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] |
1.7.0