BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback > Class Template Reference

#include <bulkDataSendRecvImpl.h>

Inheritance diagram for BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >:

Collaboration diagram for BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >:

List of all members.

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)
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 >

---

Constructor & Destructor Documentation

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

template<class TReceiverCallback , class TSenderCallback = BulkDataSenderDefaultCallback>

virtual BulkDataSendRecvImpl< TReceiverCallback, TSenderCallback >::~BulkDataSendRecvImpl

(

)

[virtual]

Destructor

---

Member Function Documentation

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 >::openReceiverStream

(

const char *

stream_name

)

[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

---

Member Data Documentation

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]

---

The documentation for this class was generated from the following file:

• bulkDataSendRecvImpl.h