AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback > Class Template Reference

#include <bulkDataDistributer.h>

Collaboration diagram for AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >:

List of all members.

Public Member Functions
	BulkDataDistributer ()
virtual	~BulkDataDistributer ()
virtual void	multiConnect (bulkdata::BulkDataReceiverConfig *recvConfig_p, const char *fepsConfig, const ACE_CString &receiverName)
virtual void	multiDisconnect (const ACE_CString &receiverName)
virtual BulkDataReceiver < TReceiverCallback > *	getReceiver ()
virtual Sender_Map *	getSenderMap ()
virtual bool	isRecvConnected (const ACE_CString &receiverName)
virtual bool	isSenderConnected (const ACE_CString &receiverName)
virtual bool	isReceiverConnected (const ACE_CString &receiverName)
virtual void	distSendStart (ACE_CString &flowName, CORBA::ULong flowNumber)
virtual int	distSendDataHsk (ACE_CString &flowName, ACE_Message_Block *frame_p, CORBA::ULong flowNumber)
virtual int	distSendData (ACE_CString &flowName, ACE_Message_Block *frame_p, CORBA::ULong flowNumber)
virtual CORBA::Boolean	distSendStopTimeout (ACE_CString &flowName, CORBA::ULong flowNumber)
virtual void	distSendStop (ACE_CString &flowName, CORBA::ULong flowNumber)
void	setTimeout (CORBA::ULong user_timeout)
void	setContSvc (maci::ContainerServices *services_p)
void	subscribeNotification (ACS::CBvoid_ptr notifCb)
void	notifySender (const ACSErr::Completion &comp)
bulkdata::Connection	getSenderConnectionState ()
Private Types
enum	Flow_Status { FLOW_AVAILABLE, FLOW_NOT_AVAILABLE }
typedef ACE_Pair< RecvData, AcsBulkdata::BulkDataSender < TSenderCallback > * >	Sender_Map_Pair
typedef ACE_Hash_Map_Manager < ACE_CString, Sender_Map_Pair, ACE_Null_Mutex >	Sender_Map
typedef ACE_Hash_Map_Entry < ACE_CString, Sender_Map_Pair >	Sender_Map_Entry
typedef ACE_Hash_Map_Iterator < ACE_CString, Sender_Map_Pair,ACE_Null_Mutex >	Sender_Map_Iterator
typedef ACE_Hash_Map_Manager < CORBA::ULong, Flow_Status, ACE_Null_Mutex >	Flows_Status_Map
typedef ACE_Hash_Map_Entry < CORBA::ULong, Flow_Status >	Flows_Status_Map_Entry
typedef ACE_Hash_Map_Iterator < CORBA::ULong, Flow_Status, ACE_Null_Mutex >	Flows_Status_Map_Iterator
typedef ACE_Hash_Map_Manager < ACE_CString, CORBA::ULong, ACE_Null_Mutex >	Recv_Status_Map
typedef ACE_Hash_Map_Entry < ACE_CString, CORBA::ULong >	Recv_Status_Map_Entry
typedef ACE_Hash_Map_Iterator < ACE_CString, CORBA::ULong, ACE_Null_Mutex >	Recv_Status_Map_Iterator
Private Member Functions
CORBA::Boolean	getFlowReceiverStatus (const ACE_CString &receiverName, CORBA::ULong flowNumber)
CORBA::Boolean	isFlowReceiverAvailable (const ACE_CString &receiverName, CORBA::ULong flowNumber)
Private Attributes
BulkDataSender< TSenderCallback > *	sender_p
BulkDataReceiver < TReceiverCallback >	receiver_m
Sender_Map	senderMap_m
Recv_Status_Map	recvStatusMap_m
Flows_Status_Map	flowsStatusMap_m
CORBA::ULong	timeout_m
CORBA::ULong	numberOfFlows
CORBA::ULong	offset
maci::ContainerServices *	contSvc_p
BulkDataDistributerNotifCb < TReceiverCallback, TSenderCallback > *	distributerNotifCb_p
ACS::CBvoid_ptr	locNotifCb_p

template<class TReceiverCallback, class TSenderCallback>
class AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >

---

Member Typedef Documentation

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Manager<CORBA::ULong, Flow_Status, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Flows_Status_Map [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Entry<CORBA::ULong, Flow_Status> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Flows_Status_Map_Entry [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Iterator<CORBA::ULong, Flow_Status, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Flows_Status_Map_Iterator [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Manager<ACE_CString, CORBA::ULong, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Recv_Status_Map [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Entry<ACE_CString, CORBA::ULong> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Recv_Status_Map_Entry [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Iterator<ACE_CString, CORBA::ULong, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Recv_Status_Map_Iterator [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Manager<ACE_CString, Sender_Map_Pair, ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Entry<ACE_CString, Sender_Map_Pair > AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map_Entry [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Hash_Map_Iterator<ACE_CString, Sender_Map_Pair ,ACE_Null_Mutex> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map_Iterator [private]

template<class TReceiverCallback, class TSenderCallback>

typedef ACE_Pair< RecvData , AcsBulkdata::BulkDataSender<TSenderCallback> *> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::Sender_Map_Pair [private]

---

Member Enumeration Documentation

template<class TReceiverCallback, class TSenderCallback>

enum AcsBulkdata::BulkDataDistributer::Flow_Status [private]

Enumerator:

FLOW_AVAILABLE
FLOW_NOT_AVAILABLE

---

Constructor & Destructor Documentation

template<class TReceiverCallback, class TSenderCallback>

AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::BulkDataDistributer

(

)

Constructor

template<class TReceiverCallback, class TSenderCallback>

virtual AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::~BulkDataDistributer

(

)

[virtual]

Destructor

---

Member Function Documentation

template<class TReceiverCallback, class TSenderCallback>

virtual int AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendData	(	ACE_CString &	flowName,
		ACE_Message_Block *	frame_p,
		CORBA::ULong	flowNumber
	)			[virtual]

template<class TReceiverCallback, class TSenderCallback>

virtual int AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendDataHsk	(	ACE_CString &	flowName,
		ACE_Message_Block *	frame_p,
		CORBA::ULong	flowNumber
	)			[virtual]

template<class TReceiverCallback, class TSenderCallback>

virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendStart	(	ACE_CString &	flowName,
		CORBA::ULong	flowNumber
	)			[virtual]

template<class TReceiverCallback, class TSenderCallback>

virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendStop	(	ACE_CString &	flowName,
		CORBA::ULong	flowNumber
	)			[virtual]

template<class TReceiverCallback, class TSenderCallback>

virtual CORBA::Boolean AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distSendStopTimeout	(	ACE_CString &	flowName,
		CORBA::ULong	flowNumber
	)			[virtual]

template<class TReceiverCallback, class TSenderCallback>

CORBA::Boolean AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getFlowReceiverStatus	(	const ACE_CString &	receiverName,
		CORBA::ULong	flowNumber
	)			[private]

template<class TReceiverCallback, class TSenderCallback>

virtual BulkDataReceiver<TReceiverCallback>* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getReceiver

(

)

[inline, virtual]

Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::getSenderConnectionState().

template<class TReceiverCallback, class TSenderCallback>

bulkdata::Connection AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getSenderConnectionState

(

)

[inline]

template<class TReceiverCallback, class TSenderCallback>

virtual Sender_Map* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::getSenderMap

(

)

[inline, virtual]

template<class TReceiverCallback, class TSenderCallback>

CORBA::Boolean AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isFlowReceiverAvailable	(	const ACE_CString &	receiverName,
		CORBA::ULong	flowNumber
	)			[private]

template<class TReceiverCallback, class TSenderCallback>

virtual bool AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isReceiverConnected

(

const ACE_CString &

receiverName

)

[virtual]

template<class TReceiverCallback, class TSenderCallback>

virtual bool AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isRecvConnected

(

const ACE_CString &

receiverName

)

[virtual]

template<class TReceiverCallback, class TSenderCallback>

virtual bool AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::isSenderConnected

(

const ACE_CString &

receiverName

)

[virtual]

template<class TReceiverCallback, class TSenderCallback>

virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::multiConnect	(	bulkdata::BulkDataReceiverConfig *	recvConfig_p,
		const char *	fepsConfig,
		const ACE_CString &	receiverName
	)			[virtual]

Exceptions:

ACSBulkDataError::AVConnectErrorExImpl

template<class TReceiverCallback, class TSenderCallback>

virtual void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::multiDisconnect

(

const ACE_CString &

receiverName

)

[virtual]

Exceptions:

ACSBulkDataError::AVDisconnectErrorExImpl

template<class TReceiverCallback, class TSenderCallback>

void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::notifySender

(

const ACSErr::Completion &

comp

)

Exceptions:

ACSBulkDataError::AVNotificationMechanismErrorExImpl

template<class TReceiverCallback, class TSenderCallback>

void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::setContSvc

(

maci::ContainerServices *

services_p

)

[inline]

template<class TReceiverCallback, class TSenderCallback>

void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::setTimeout

(

CORBA::ULong

user_timeout

)

[inline]

template<class TReceiverCallback, class TSenderCallback>

void AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::subscribeNotification

(

ACS::CBvoid_ptr

notifCb

)

Exceptions:

ACSBulkDataError::AVNotificationMechanismErrorExImpl

---

Member Data Documentation

template<class TReceiverCallback, class TSenderCallback>

maci::ContainerServices* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::contSvc_p [private]

Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::setContSvc().

template<class TReceiverCallback, class TSenderCallback>

BulkDataDistributerNotifCb<TReceiverCallback, TSenderCallback>* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::distributerNotifCb_p [private]

template<class TReceiverCallback, class TSenderCallback>

Flows_Status_Map AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::flowsStatusMap_m [private]

template<class TReceiverCallback, class TSenderCallback>

ACS::CBvoid_ptr AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::locNotifCb_p [private]

template<class TReceiverCallback, class TSenderCallback>

CORBA::ULong AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::numberOfFlows [private]

template<class TReceiverCallback, class TSenderCallback>

CORBA::ULong AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::offset [private]

template<class TReceiverCallback, class TSenderCallback>

BulkDataReceiver<TReceiverCallback> AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::receiver_m [private]

Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::getReceiver().

template<class TReceiverCallback, class TSenderCallback>

Recv_Status_Map AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::recvStatusMap_m [private]

template<class TReceiverCallback, class TSenderCallback>

BulkDataSender<TSenderCallback>* AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::sender_p [private]

template<class TReceiverCallback, class TSenderCallback>

Sender_Map AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::senderMap_m [private]

Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::getSenderMap().

template<class TReceiverCallback, class TSenderCallback>

CORBA::ULong AcsBulkdata::BulkDataDistributer< TReceiverCallback, TSenderCallback >::timeout_m [private]

Referenced by AcsBulkdata::BulkDataDistributer< BulkDataDistributerStreamCb, BulkDataSenderDefaultCallback >::setTimeout().

---

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

• bulkDataDistributer.h