BulkDataNTSenderImpl − |
#include <bulkDataNTSenderImpl.h> Inherits baci::CharacteristicComponentImpl. Inherited by bdNTSenderImplTest. |
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 |
typedef std::map<std::string, AcsBulkdata::BulkDataNTSenderStream *> BulkDataNTSenderImpl::StreamMap [private] |
BulkDataNTSenderImpl::BulkDataNTSenderImpl (const ACE_CString & name, maci::ContainerServices * containerServices) Constructor |
Parameters: |
poa poa which will activate this and also all
other components |
virtual BulkDataNTSenderImpl::~BulkDataNTSenderImpl () [virtual] Destructor |
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 |
int BulkDataNTSenderImpl::defaultFlowsCount_m [private] |
AcsBulkdata::BulkDataConfigurationParser* BulkDataNTSenderImpl::parser_m [private] |
StreamMap BulkDataNTSenderImpl::senderStreams_m [private] |
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |