#include <bulkDataNTSenderImpl.h>
Inheritance diagram for BulkDataNTSenderImpl:
Collaboration diagram for BulkDataNTSenderImpl:
Public Member Functions | |
| BulkDataNTSenderImpl (const ACE_CString &name, maci::ContainerServices *containerServices) | |
| virtual | ~BulkDataNTSenderImpl () |
| virtual void | initialize () |
| virtual void | cleanUp () |
| virtual void | connect (bulkdata::BulkDataReceiver_ptr receiverObj_p) |
| virtual void | disconnect () |
| virtual AcsBulkdata::BulkDataNTSenderStream * | getSenderStream (const char *name) |
| virtual AcsBulkdata::BulkDataNTSenderStream * | getSenderStream () |
| virtual void | startSend ()=0 |
| virtual void | paceData ()=0 |
| virtual void | stopSend ()=0 |
Protected Member Functions | |
| virtual bool | usesOldConfigurationMechanism () |
Private Types | |
| typedef std::map< std::string, AcsBulkdata::BulkDataNTSenderStream * > | StreamMap |
Private Member Functions | |
| virtual void | openSenders () |
| AcsBulkdata::BulkDataNTSenderStream * | createSenderStream (const char *stream_name) |
| AcsBulkdata::BulkDataNTSenderStream * | createDefaultSenderStream () |
| void | closeStream (StreamMap::iterator &it) |
Private Attributes | |
| AcsBulkdata::BulkDataConfigurationParser * | parser_m |
| int | defaultFlowsCount_m |
| StreamMap | senderStreams_m |
Member Typedef Documentation
typedef std::map<std::string, AcsBulkdata::BulkDataNTSenderStream *> BulkDataNTSenderImpl::StreamMap [private] |
Constructor & Destructor Documentation
| BulkDataNTSenderImpl::BulkDataNTSenderImpl | ( | const ACE_CString & | name, | |
| maci::ContainerServices * | containerServices | |||
| ) |
Constructor
- Parameters:
-
poa poa which will activate this and also all other components name component name
| virtual BulkDataNTSenderImpl::~BulkDataNTSenderImpl | ( | ) | [virtual] |
Destructor
Member Function Documentation
| virtual void BulkDataNTSenderImpl::cleanUp | ( | ) | [virtual] |
| void BulkDataNTSenderImpl::closeStream | ( | StreamMap::iterator & | it | ) | [private] |
| virtual void BulkDataNTSenderImpl::connect | ( | bulkdata::BulkDataReceiver_ptr | receiverObj_p | ) | [virtual] |
Negotiate and initialize connection with the Sender object.
- Parameters:
-
receiver reference of the Receiver Component (currently unused).
- Exceptions:
-
ACSBulkDataError::AVConnectErrorEx
- Returns:
- void
| AcsBulkdata::BulkDataNTSenderStream* BulkDataNTSenderImpl::createDefaultSenderStream | ( | ) | [private] |
| AcsBulkdata::BulkDataNTSenderStream* BulkDataNTSenderImpl::createSenderStream | ( | const char * | stream_name | ) | [private] |
| virtual void BulkDataNTSenderImpl::disconnect | ( | ) | [virtual] |
- Exceptions:
-
ACSBulkDataError::AVDisconnectErrorEx
| virtual AcsBulkdata::BulkDataNTSenderStream* BulkDataNTSenderImpl::getSenderStream | ( | const char * | name | ) | [virtual] |
- Parameters:
-
name The stream name
- Returns:
- The sender stream object for the given name
- Exceptions:
-
StreamNotExistExImpl
| virtual AcsBulkdata::BulkDataNTSenderStream* BulkDataNTSenderImpl::getSenderStream | ( | ) | [virtual] |
Gets the first sender stream stored in the internal stream map.
- Returns:
- The first sender stream saved in the internal map
- Deprecated:
- You should use getSenderStream(const char *name) instead
| virtual void BulkDataNTSenderImpl::initialize | ( | ) | [virtual] |
| virtual void BulkDataNTSenderImpl::openSenders | ( | ) | [private, virtual] |
Opens all senders as specified on the CDB (old or new configuration mechanism). This method might be added in the future to the IDL interface
| virtual void BulkDataNTSenderImpl::paceData | ( | ) | [pure virtual] |
Sends data to the Receiver calling the receive_frame() method on the Receiver side. This method must be overriden by the user to send his own data.
- Parameters:
-
size buffer size of the sent data.
- Exceptions:
-
ACSBulkDataError::AVPaceDataErrorEx
- Returns:
- void
Implemented in bdNTSenderImplTest.
| virtual void BulkDataNTSenderImpl::startSend | ( | ) | [pure virtual] |
Calls the Receiver handle_start() method once the connection is established.
- Exceptions:
-
ACSBulkDataError::AVStartSendErrorEx
- Returns:
- void
Implemented in bdNTSenderImplTest.
| virtual void BulkDataNTSenderImpl::stopSend | ( | ) | [pure virtual] |
Calls the Receiver handle_stop() method.
- Exceptions:
-
ACSBulkDataError::AVStopSendErrorEx
- Returns:
- void
Implemented in bdNTSenderImplTest.
| virtual bool BulkDataNTSenderImpl::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
Member Data Documentation
int BulkDataNTSenderImpl::defaultFlowsCount_m [private] |
The documentation for this class was generated from the following file:
