#include <bulkDataSenderImpl.h>
Public Member Functions | |
BulkDataSenderImpl (const ACE_CString &name, maci::ContainerServices *containerServices) | |
virtual | ~BulkDataSenderImpl () |
void | cleanUp () |
virtual void | connect (bulkdata::BulkDataReceiver_ptr receiverObj_p) |
virtual void | disconnect () |
virtual AcsBulkdata::BulkDataSender < TSenderCallback > * | getSender () |
virtual void | startSend ()=0 |
virtual void | paceData ()=0 |
virtual void | stopSend ()=0 |
Private Attributes | |
maci::ContainerServices * | containerServices_p |
AcsBulkdata::BulkDataSender < TSenderCallback > | sender |
bulkdata::BulkDataReceiver_ptr | receiverObj_m |
BulkDataSenderImpl< TSenderCallback >::BulkDataSenderImpl | ( | const ACE_CString & | name, | |
maci::ContainerServices * | containerServices | |||
) |
Constructor
poa | poa which will activate this and also all other components | |
name | component name |
virtual BulkDataSenderImpl< TSenderCallback >::~BulkDataSenderImpl | ( | ) | [virtual] |
Destructor
void BulkDataSenderImpl< TSenderCallback >::cleanUp | ( | ) |
Reimplemented in BulkDataSenderDistrImpl< TSenderCallback >.
virtual void BulkDataSenderImpl< TSenderCallback >::connect | ( | bulkdata::BulkDataReceiver_ptr | receiverObj_p | ) | [virtual] |
Negotiate and initialize connection with the Sender object.
receiver | reference of the Receiver Component. |
ACSBulkDataError::AVConnectErrorEx |
virtual void BulkDataSenderImpl< TSenderCallback >::disconnect | ( | ) | [virtual] |
ACSBulkDataError::AVDisconnectErrorEx |
virtual AcsBulkdata::BulkDataSender<TSenderCallback>* BulkDataSenderImpl< TSenderCallback >::getSender | ( | ) | [inline, virtual] |
References BulkDataSenderImpl< TSenderCallback >::sender.
virtual void BulkDataSenderImpl< TSenderCallback >::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.
size | buffer size of the sent data. |
ACSBulkDataError::AVPaceDataErrorEx |
Implemented in BulkDataSenderDistrImpl< TSenderCallback >, BulkDataSenderEx1Impl, BulkDataSenderEx2Impl, BulkDataSenderEx3Impl, BulkDataSenderNotifImpl, BulkDataSenderPerfImpl, and BulkDataSenderThreadImpl.
virtual void BulkDataSenderImpl< TSenderCallback >::startSend | ( | ) | [pure virtual] |
Calls the Receiver handle_start() method once the connection is established.
ACSBulkDataError::AVStartSendErrorEx |
Implemented in BulkDataSenderDistrImpl< TSenderCallback >, BulkDataSenderEx1Impl, BulkDataSenderEx2Impl, BulkDataSenderEx3Impl, BulkDataSenderNotifImpl, BulkDataSenderPerfImpl, and BulkDataSenderThreadImpl.
virtual void BulkDataSenderImpl< TSenderCallback >::stopSend | ( | ) | [pure virtual] |
Calls the Receiver handle_stop() method.
ACSBulkDataError::AVStopSendErrorEx |
Implemented in BulkDataSenderDistrImpl< TSenderCallback >, BulkDataSenderEx1Impl, BulkDataSenderEx2Impl, BulkDataSenderEx3Impl, BulkDataSenderNotifImpl, BulkDataSenderPerfImpl, and BulkDataSenderThreadImpl.
maci::ContainerServices* BulkDataSenderImpl< TSenderCallback >::containerServices_p [private] |
Pointer to the dataProtocol on which the send_frame(...) method is called in order to actually send data.
bulkdata::BulkDataReceiver_ptr BulkDataSenderImpl< TSenderCallback >::receiverObj_m [private] |
AcsBulkdata::BulkDataSender<TSenderCallback> BulkDataSenderImpl< TSenderCallback >::sender [private] |
Referenced by BulkDataSenderImpl< TSenderCallback >::getSender().