|
BulkDataSendRecvImpl − |
|
#include <bulkDataSendRecvImpl.h> Inherits baci::CharacteristicComponentImpl. |
|
Public Member Functions |
|
BulkDataSendRecvImpl (const ACE_CString &name, maci::ContainerServices *containerServices) |
|
virtual ~BulkDataSendRecvImpl () |
|
void cleanUp () |
|
virtual void connect (bulkdata::BulkDataReceiver_ptr receiverObj_p) |
|
void openReceiverStream (const char *stream_name) |
|
void openReceiverStreamCfg (const char *stream_name, const char *stream_cfg) |
|
void openReceiverFlow (const char *stream_name, const char *flow_name) |
|
void openReceiverFlowCfg (const char *stream_name, const char *flow_name, const char *flow_cfg) |
|
virtual void disconnect () |
|
void closeReceiverStream (const char *stream_name) |
|
virtual void startSend () |
|
virtual void paceData () |
|
virtual void stopSend () |
|
virtual void openReceiver () |
|
bulkdata::BulkDataReceiverConfig * getReceiverConfig () |
|
virtual void closeReceiver () |
|
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 Attributes |
|
AcsBulkdata::BulkDataSender< TSenderCallback > sender |
|
AcsBulkdata::BulkDataReceiver< TReceiverCallback > receiver |
|
maci::ContainerServices * containerServices_p |
|
CDB::DAL_ptr dal_p |
|
CDB::DAO_ptr dao_p |
|
template<class TReceiverCallback, class TSenderCallback = BulkDataSenderDefaultCallback> class BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback > |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::BulkDataSendRecvImpl (const ACE_CString & name, maci::ContainerServices * containerServices) Constructor |
|
Parameters: |
|
poa poa which will activate this and also all
other components |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::~BulkDataSendRecvImpl () [virtual] Destructor |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::cleanUp () |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::closeReceiver () [virtual] Exceptions: |
|
ACSBulkDataError::AVCloseReceiverErrorEx |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::closeReceiverStream (const char * stream_name) [inline] Calls the Receiver handle_start() method once the connection is established. |
|
Exceptions: |
|
ACSBulkDataError::AVStartSendErrorEx |
|
Returns: |
|
void |
|
References ACS_SHORT_LOG. |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::connect (bulkdata::BulkDataReceiver_ptr receiverObj_p) [virtual] Negotiate and initialize connection with the SendRecv object. |
|
Parameters: |
|
receiver reference of the Receiver Component. |
|
Exceptions: |
|
ACSBulkDataError::AVConnectErrorEx |
|
Returns: |
|
void |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::disconnect () [virtual] Exceptions: |
|
ACSBulkDataError::AVDisconnectErrorEx |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::fwdData2UserCB (CORBA::Boolean enable) [inline] NOT implemented for distributor |
|
References ACS_SHORT_LOG. |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual ACSErr::Completion* BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::getCbStatus (CORBA::ULong flowNumber) [inline, virtual] Exceptions: |
|
ACSBulkDataError::AVInvalidFlowNumberEx |
|
References ACS_TRACE. |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> bulkdata::BulkDataReceiverConfig* BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::getReceiverConfig () Exceptions: |
|
ACSBulkDataError::AVReceiverConfigErrorEx |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::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. |
|
Exceptions: |
|
ACSBulkDataError::AVOpenReceiverErrorEx |
|
Returns: |
|
void |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::openReceiverFlow (const char * stream_name, const char * flow_name) [inline] |
|
References ACS_SHORT_LOG. |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::openReceiverFlowCfg (const char * stream_name, const char * flow_name, const char * flow_cfg) [inline] |
|
References ACS_SHORT_LOG. |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::openReceiverStream (const char * stream_name) [inline] |
|
References ACS_SHORT_LOG. |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::openReceiverStreamCfg (const char * stream_name, const char * stream_cfg) [inline] |
|
References ACS_SHORT_LOG. |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::paceData () [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 |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::setRecvName (const char * recvName) [inline, virtual] Exceptions: |
|
ACSBulkDataError::AVSetReceiverNameErrorEx |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::setTimeout (CORBA::ULong flowNumber, CORBA::ULong timeout) [inline, virtual] Exceptions: |
|
ACSBulkDataError::AVInvalidFlowNumberEx |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::startSend () [virtual] |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::stopSend () [virtual] Calls the Receiver handle_stop() method. |
|
Exceptions: |
|
ACSBulkDataError::AVStopSendErrorEx |
|
Returns: |
|
void |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> virtual void BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::subscribeNotification (ACS::CBvoid_ptr notifCb) [inline, virtual] Exceptions: |
|
ACSBulkDataError::AVNotificationMechanismErrorEx |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> maci::ContainerServices* BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::containerServices_p [private] |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> CDB::DAL_ptr BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::dal_p [private] |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> CDB::DAO_ptr BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::dao_p [private] |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> AcsBulkdata::BulkDataReceiver<TReceiverCallback> BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::receiver [private] |
|
template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback> AcsBulkdata::BulkDataSender<TSenderCallback> BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::sender [private] |
|
Generated automatically by Doxygen for ACS-2015.2 C++ API from the source code. |