DtForwarderFaultProcessor Class Reference

The DtForwarderFaultProcessor class provides connection fault processing to the Forwarder Node. More...

Collaboration diagram for DtForwarderFaultProcessor:

Public Member Functions
	DtForwarderFaultProcessor (DtForwarderNode *parent)
	Constructor. More...
virtual	~DtForwarderFaultProcessor ()
	Destructor. More...
virtual bool	processExecConnectDestinations (const DtInetAddrAndPort &src, DtForwarderPort::DtAddressPortList &destinations)
	Set forwarding destination list based on source (eg. More...
virtual bool	isLocalGroupMember (const DtInetAddrAndPort &addr)
	Aids to determine inbound and outbound connections to rtiexec. More...
virtual DtInetAddrAndPort	locateGroupPortal (const DtInetAddrAndPort &addr)
virtual DtInetAddrAndPort	localNodeAddress ()
	Return parent node address. More...
virtual DtInetAddrAndPort	rootForwarder ()
	Return address of rtiexec's Root Forwarder. More...
virtual DtInetAddrAndPort	nextHopTowardRootForwarder ()
	Return address of next upstream outbound hop toward rtiexec's Root Forwarder. More...

Static Public Member Functions
static int	lostConnection (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr, void *usr)
	Connection loss callback. More...
static int	newConnection (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr, void *usr)
	Connection added callback ( used to provide rtiexec location to late joiners ) More...

Protected Member Functions
virtual int	lostConnection (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr)
	Connection loss callback. More...
virtual int	newConnection (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr)
	Connection added callback ( used to provide rtiexec location to late joiners ) More...
virtual void	processLostUpstreamConnection ()
	Handle broken connection in the upstream path to the rtiexec. More...

Protected Attributes
DtForwarderNode *	myParent
DtRtiExecConnectionFilter < DtForwarderFaultProcessor >	myRtiExecMonitor

Private Member Functions
	DtForwarderFaultProcessor ()
	Default constructor unimplemented. More...

Detailed Description

The DtForwarderFaultProcessor class provides connection fault processing to the Forwarder Node.

By default, the DtForwarderFaultProcessor responds to lost connections by issuing a forwarderConnectionLost msg. The upstream connection between every forwarder and the rtiexec may consist of two separate pathways. Messages sent by the rtiexec will pass through the "root" forwarder (the forwarder directly connected to the rtiexec) to a single portal forwarder in other forwarder groups. Messages from forwarders in foreign forwarder groups (where "foreign" here means they are not in the same group as the "root" forwarder) will be sent through the portal they are connected to in the root Forwarder Group. In many cases, such as when there is only one forwarder in each Forwarder Group (the degenerate case) the pathways overlap completely. However it is also possible that the two pathways diverge. If either pathway of the upstream connection to the RTI Exec is lost then, by default, the DtForwarderFaultProcessor responds by exiting the Forwarder Node (this will result in a chain reaction for downstream Nodes)

Constructor & Destructor Documentation

DtForwarderFaultProcessor::DtForwarderFaultProcessor ( )

private

Default constructor unimplemented.

DtForwarderFaultProcessor::DtForwarderFaultProcessor

(

DtForwarderNode *

parent

)

Constructor.

virtual DtForwarderFaultProcessor::~DtForwarderFaultProcessor ( )

virtual

Destructor.

Member Function Documentation

virtual bool DtForwarderFaultProcessor::isLocalGroupMember ( const DtInetAddrAndPort &  addr )

virtual

Aids to determine inbound and outbound connections to rtiexec.

virtual DtInetAddrAndPort DtForwarderFaultProcessor::localNodeAddress ( )

virtual

Return parent node address.

virtual DtInetAddrAndPort DtForwarderFaultProcessor::locateGroupPortal ( const DtInetAddrAndPort &  addr )

virtual

static int DtForwarderFaultProcessor::lostConnection ( const MAKRti::DtString &  connName, const MAKRti::DtString &  hostName, unsigned int  connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &  connAddr, void *  usr  )

static

Connection loss callback.

virtual int DtForwarderFaultProcessor::lostConnection ( const MAKRti::DtString &  connName, const MAKRti::DtString &  hostName, unsigned int  connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &  connAddr  )

protectedvirtual

Connection loss callback.

static int DtForwarderFaultProcessor::newConnection ( const MAKRti::DtString &  connName, const MAKRti::DtString &  hostName, unsigned int  connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &  connAddr, void *  usr  )

static

Connection added callback ( used to provide rtiexec location to late joiners )

virtual int DtForwarderFaultProcessor::newConnection ( const MAKRti::DtString &  connName, const MAKRti::DtString &  hostName, unsigned int  connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &  connAddr  )

protectedvirtual

Connection added callback ( used to provide rtiexec location to late joiners )

virtual DtInetAddrAndPort DtForwarderFaultProcessor::nextHopTowardRootForwarder ( )

virtual

Return address of next upstream outbound hop toward rtiexec's Root Forwarder.

virtual bool DtForwarderFaultProcessor::processExecConnectDestinations ( const DtInetAddrAndPort &  src, DtForwarderPort::DtAddressPortList &  destinations  )

virtual

Set forwarding destination list based on source (eg.

which inlet the message was received on) and forwarder network configuration

virtual void DtForwarderFaultProcessor::processLostUpstreamConnection ( )

protectedvirtual

Handle broken connection in the upstream path to the rtiexec.

virtual DtInetAddrAndPort DtForwarderFaultProcessor::rootForwarder ( )

virtual

Return address of rtiexec's Root Forwarder.

Member Data Documentation

DtForwarderNode* DtForwarderFaultProcessor::myParent

protected

DtRtiExecConnectionFilter<DtForwarderFaultProcessor> DtForwarderFaultProcessor::myRtiExecMonitor

protected

---

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

• forwarderFaultProcessor.h