BulkDataNTReceiverImpl< TCallback > Class Template Reference

#include <bulkDataNTReceiverImpl.h>

Inheritance diagram for BulkDataNTReceiverImpl< TCallback >:

Collaboration diagram for BulkDataNTReceiverImpl< TCallback >:

List of all members.

Public Member Functions
	BulkDataNTReceiverImpl (const ACE_CString &name, maci::ContainerServices *containerServices)
virtual	~BulkDataNTReceiverImpl ()
virtual void	initialize ()
virtual void	cleanUp ()
AcsBulkdata::BulkDataNTReceiverStream < TCallback > *	getReceiverStream (const char *streamName)
virtual void	openReceiver ()
virtual 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)
bulkdata::BulkDataReceiverConfig *	getReceiverConfig ()
virtual void	closeReceiver ()
virtual void	closeReceiverStream (const char *stream_name)
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)
Protected Member Functions
virtual bool	usesOldConfigurationMechanism ()
Private Types
typedef std::map< std::string, AcsBulkdata::BulkDataNTReceiverStream < TCallback > * >	StreamMap
Private Member Functions
AcsBulkdata::BulkDataNTReceiverStream < TCallback > *	createReceiverStream (const char *stream_name, const char *stream_cfg)
AcsBulkdata::BulkDataNTReceiverStream < TCallback > *	createDefaultReceiverStream (const char *stream_cfg)
Private Attributes
StreamMap	receiverStreams_m
ACE_Recursive_Thread_Mutex	rcvStreamMapMutex_m
AcsBulkdata::BulkDataConfigurationParser *	parser_m
int	defaultFlowsCount_m
bool	fwdData2UserCBenabled_m

template<class TCallback>
class BulkDataNTReceiverImpl< TCallback >

---

Member Typedef Documentation

template<class TCallback>

typedef std::map<std::string, AcsBulkdata::BulkDataNTReceiverStream<TCallback> *> BulkDataNTReceiverImpl< TCallback >::StreamMap [private]

---

Constructor & Destructor Documentation

template<class TCallback>

BulkDataNTReceiverImpl< TCallback >::BulkDataNTReceiverImpl	(	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 TCallback>

virtual BulkDataNTReceiverImpl< TCallback >::~BulkDataNTReceiverImpl

(

)

[virtual]

Destructor

---

Member Function Documentation

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::cleanUp

(

)

[virtual]

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::closeReceiver

(

)

[virtual]

Exceptions:

ACSBulkDataError::AVCloseReceiverErrorEx

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::closeReceiverStream

(

const char *

stream_name

)

[virtual]

template<class TCallback>

AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::createDefaultReceiverStream

(

const char *

stream_cfg

)

[private]

template<class TCallback>

AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::createReceiverStream	(	const char *	stream_name,
		const char *	stream_cfg
	)			[private]

template<class TCallback>

void BulkDataNTReceiverImpl< TCallback >::fwdData2UserCB

(

CORBA::Boolean

enable

)

Enable or disable that data are sent to the user's CB. By default this is enable. This operation has to be use with caution!!!

Parameters:

enable

true -> data will be sent to the user's CB, false -> data will *not* be sent to the user's CB,

Returns:

void

template<class TCallback>

virtual ACSErr::Completion* BulkDataNTReceiverImpl< TCallback >::getCbStatus

(

CORBA::ULong

flowNumber

)

[inline, virtual]

Exceptions:

	ACSBulkDataError::AVInvalidFlowNumberEx
	ACSBulkDataError::AVFlowEndpointErrorEx

template<class TCallback>

bulkdata::BulkDataReceiverConfig* BulkDataNTReceiverImpl< TCallback >::getReceiverConfig

(

)

Exceptions:

ACSBulkDataError::AVReceiverConfigErrorEx

template<class TCallback>

AcsBulkdata::BulkDataNTReceiverStream<TCallback>* BulkDataNTReceiverImpl< TCallback >::getReceiverStream

(

const char *

streamName

)

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::initialize

(

)

[virtual]

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::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

---

Reimplemented in BulkDataNTMasterImpl.

template<class TCallback>

void BulkDataNTReceiverImpl< TCallback >::openReceiverFlow	(	const char *	stream_name,
		const char *	flow_name
	)

Parameters:

	stream_name
	flow_name

Todo:

to be implemented

template<class TCallback>

void BulkDataNTReceiverImpl< TCallback >::openReceiverFlowCfg	(	const char *	stream_name,
		const char *	flow_name,
		const char *	flow_cfg
	)

Parameters:

	stream_name
	flow_name
	flow_cfg

Todo:

to be implemented

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::openReceiverStream

(

const char *

stream_name

)

[virtual]

Parameters:

stream_name

template<class TCallback>

void BulkDataNTReceiverImpl< TCallback >::openReceiverStreamCfg	(	const char *	stream_name,
		const char *	stream_cfg
	)

Parameters:

	stream_name
	stream_cfg

Todo:

to be implemented

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::setRecvName

(

const char *

recvName

)

[virtual]

Exceptions:

ACSBulkDataError::AVSetReceiverNameErrorEx

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::setTimeout	(	CORBA::ULong	flowNumber,
		CORBA::ULong	timeout
	)			[inline, virtual]

Exceptions:

	ACSBulkDataError::AVInvalidFlowNumberEx
	ACSBulkDataError::AVFlowEndpointErrorEx

template<class TCallback>

virtual void BulkDataNTReceiverImpl< TCallback >::subscribeNotification

(

ACS::CBvoid_ptr

notifCb

)

[inline, virtual]

Exceptions:

ACSBulkDataError::AVNotificationMechanismErrorEx

template<class TCallback>

virtual bool BulkDataNTReceiverImpl< TCallback >::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

---

Member Data Documentation

template<class TCallback>

int BulkDataNTReceiverImpl< TCallback >::defaultFlowsCount_m [private]

template<class TCallback>

bool BulkDataNTReceiverImpl< TCallback >::fwdData2UserCBenabled_m [private]

template<class TCallback>

AcsBulkdata::BulkDataConfigurationParser* BulkDataNTReceiverImpl< TCallback >::parser_m [private]

template<class TCallback>

ACE_Recursive_Thread_Mutex BulkDataNTReceiverImpl< TCallback >::rcvStreamMapMutex_m [private]

template<class TCallback>

StreamMap BulkDataNTReceiverImpl< TCallback >::receiverStreams_m [private]

---

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

• bulkDataNTReceiverImpl.h