The DtSmartForwardingProcessor class tracks Federate connections and filters the outgoing destination list for incoming messages based on their routing mask. More...

Collaboration diagram for DtSmartForwardingProcessor:

Public Member Functions
	DtSmartForwardingProcessor (DtBoost::shared_ptr< DtForwarderNode > parent)
	Constructor.
virtual	~DtSmartForwardingProcessor ()
	Destructor.
bool	federateJoined (const DtInetAddrAndPort &src, const DtNetJoinConfirmMsg *msg)
	Join Msg received callback.
bool	federateResigned (const DtInetAddrAndPort &src, const DtNetResignMsg *msg)
	Resign Msg received callback.
bool	processJoinResignDestinations (const DtInetAddrAndPort &src, DtForwarderPort::DtAddressPortList &destinations)
	Set the forwarding destinations for Join & Resign messages based on the source (eg.
bool	filterUpdateInterDestinations (const DtInetAddrAndPort &src, caddr_t msg, DtForwarderPort::DtAddressPortList &destinations)
	Got an incoming Update or Interaction, so set destination list based on source (eg.

Static Public Member Functions
static int	lostConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Connection loss callback.

Protected Types
typedef std::map< unsigned long, DtInetAddrAndPort >	DtIdToAddrMap
typedef std::map < DtInetAddrAndPort, DtBitMask >	DtAddrToIdMaskMap

Protected Member Functions
virtual int	lostConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
	Connection loss callback.

Protected Attributes
DtBoost::shared_ptr < DtForwarderNode >	myParent
DtIdToAddrMap	myFedIdToAddressMap
DtAddrToIdMaskMap	myAddressToFedIdsMap
DtFederateJoinResignFilter < DtSmartForwardingProcessor > *	myJoinResignFilter
DtUpdateInterDestinationFilter < DtSmartForwardingProcessor > *	myUpdateInterFilter

Private Member Functions
	DtSmartForwardingProcessor ()
	Default constructor unimplemented.
	DtSmartForwardingProcessor (const DtSmartForwardingProcessor &)
	Copy CTOR unimplemented.
DtSmartForwardingProcessor &	operator= (const DtSmartForwardingProcessor &orig)
	assignment operator – Not Implemented

Detailed Description

The DtSmartForwardingProcessor class tracks Federate connections and filters the outgoing destination list for incoming messages based on their routing mask.

Member Typedef Documentation

typedef std::map< DtInetAddrAndPort, DtBitMask > DtSmartForwardingProcessor::DtAddrToIdMaskMap

protected

typedef std::map< unsigned long, DtInetAddrAndPort > DtSmartForwardingProcessor::DtIdToAddrMap

protected

Constructor & Destructor Documentation

DtSmartForwardingProcessor::DtSmartForwardingProcessor ( )

private

Default constructor unimplemented.

DtSmartForwardingProcessor::DtSmartForwardingProcessor ( const DtSmartForwardingProcessor & )

private

Copy CTOR unimplemented.

DtSmartForwardingProcessor::DtSmartForwardingProcessor ( DtBoost::shared_ptr< DtForwarderNode > parent )

Constructor.

References federateJoined(), federateResigned(), filterUpdateInterDestinations(), lostConnection(), myJoinResignFilter, myParent, myUpdateInterFilter, and processJoinResignDestinations().

DtSmartForwardingProcessor::~DtSmartForwardingProcessor ( )

virtual

Destructor.

References myJoinResignFilter, myParent, and myUpdateInterFilter.

Member Function Documentation

bool DtSmartForwardingProcessor::federateJoined	(	const DtInetAddrAndPort &	src,
		const DtNetJoinConfirmMsg *	msg
	)

Join Msg received callback.

References DtRtiMtdDestinationList::destinationIndex(), DtForwarderIntfcLan, DtForwarderIntfcOut, DtJoinConfirmMsg::errorCode(), DtRtiMsg::federateHandle(), DtRtiMsg::fedExName(), DtNetMsgHeader::fedHandle, DtRtiMtdForwarderGroupId::get(), DtRtiMtdDestinationList::getMaxDestinations(), DtNetJoinConfirmMsg::header, myAddressToFedIdsMap, myFedIdToAddressMap, myParent, DtRtiMtdForwarderGroupId::set(), DtRtiMsg::setFederateHandle(), and DtJoinConfirmMsg::sourceID().

Referenced by DtSmartForwardingProcessor().

bool DtSmartForwardingProcessor::federateResigned	(	const DtInetAddrAndPort &	src,
		const DtNetResignMsg *	msg
	)

Resign Msg received callback.

References DtRtiMtdDestinationList::destinationIndex(), DtNetMsgHeader::fedHandle, DtNetResignMsg::header, myAddressToFedIdsMap, and myFedIdToAddressMap.

Referenced by DtSmartForwardingProcessor().

bool DtSmartForwardingProcessor::filterUpdateInterDestinations	(	const DtInetAddrAndPort &	src,
		caddr_t	msg,
		DtForwarderPort::DtAddressPortList &	destinations
	)

Got an incoming Update or Interaction, so set destination list based on source (eg.

which inlet the message was received on) and forwarder network configuration, then pare down list based on bitmask in message.

References DtRtiMtdDestinationList::get(), DtRtiMtdDestinationList::getMaxDestinations(), DtBitMask::isEmpty(), and myAddressToFedIdsMap.

Referenced by DtSmartForwardingProcessor().

int DtSmartForwardingProcessor::lostConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)