BulkDataNTSenderImpl

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
name component name

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-2016.2 C++ API from the source code.