DtConnectionFaultProcessor Class Reference

The DtConnectionFaultProcessor class is a message processor responsible for responding to lost connections by initiating and participating in the RTI Exec's fault resolution algorithm. More...

Collaboration diagram for DtConnectionFaultProcessor:

List of all members.

Public Types
typedef bool(DtConnectionFaultProcessor::*	HandshakeMsgHandlerMemberCb )(MAKRti::DtInetAddr src, const DtConnectionFaultMsg &msg)
Public Member Functions
	DtConnectionFaultProcessor (DtForwarderNode *parent)
	Default Ctor.
virtual	~DtConnectionFaultProcessor ()
	Default Dtor.
virtual bool	gotForwarderStatusRequest (const MAKRti::DtInetAddr &src, const DtForwarderStatusRequestMsg msg)
	Got Forwarder Status Request Message.
virtual bool	gotRemoteRtiExecConnect (const MAKRti::DtInetAddr &src, const DtRtiExecConnectMsg &msg)
	Got Remote rtiexec Connect Message from IN Port.
virtual bool	gotLocalRtiExecConnect (const MAKRti::DtInetAddr &src, const DtRtiExecConnectMsg &msg)
	Got Local rtiexec Connect Message from LAN Port.
virtual bool	gotRtiExecDisconnect (const MAKRti::DtInetAddr &src, const DtDisconnectMsg &msg)
	Got Local rtiexec Disconnect Message (local or remote)
virtual bool	processResignForwarderMsgDestinations (const MAKRti::DtInetAddr &src, DtForwarderPort::DtAddressPortList &destinations)
	Set forwarding destination list based on source (eg.
Protected Attributes
DtForwarderNode *	myParent

---

Detailed Description

The DtConnectionFaultProcessor class is a message processor responsible for responding to lost connections by initiating and participating in the RTI Exec's fault resolution algorithm.

When rtiexec receives ConnectionLostMsg( myForwarderID, droppedForwarderID ) rtiexec sends PingForwarderMsg( droppedForwarderID ) Forwarders aggregate all downstream PingForwarderResps and return upstream (=> return NoConnection( droppedForwarderID ) by default If rtiexec receives PingForwarderResp = NoConnection Then Forwarder has been lost no additional action required Else Both myForwarderID and droppedForwarderID are connected rtiexec sends ForwarderStatusRequestMsg( myConnectionID ) rtiexec sends ForwarderStatusRequestMsg( droppedConnectionID ) rtiexec waits for ForwarderStatusMsg (contains downstream federate count) Compare ForwarderStatusMsg( myConnectionID ).numFederates to ForwarderStatusMsg( droppedConnectionID ).numFederates rtiexec Sends ResignForwarder( ID ) where ID = either forwarder with fewer attached federates or (if equal) forwarder with lower ID (arbitrary) Required Processors (basically implement the algorithms required for fault recovery): 1) CountDownstreamFederates Processor

• Receives CountDownstreamFederatesMsg from Port A ( IN or LAN port )
• Forward CountDownstreamFederatesMsg to all downstream nodes
• myFederateCount = num local federates
• Wait for all downstream responses (if no connections, no waiting)
• myFederateCount += CountDownstreamFederatesResp.numFederates (from downstream)
• Send CountDownstreamFederatesResp( myFederateCount ) to Port A

2) PingResponse Processor

• Receives PingForwarderMsg( ID ) from Port A ( IN or LAN port )
• Forward PingForwarderMsg( ID ) to all downstream nodes
• myPingResp = false
• If ID == myID Then
  • myPingResponse = true
• If No downstream connections, Then
  • myPingResponse |= false
• Wait for PingResponseMsg from all downstream forwarders
• myPingResponse |= downstream PingResponseMsg (ie - accept any TRUE )
• Send PingResponseMsg( ID, myPingResponse ) to Port A

3) ConnectionLossDetection Processor

• If !myOutPort.droppedConnections.empty()
• For each dropped connection ID
  • Send ForwarderConnectionLost( myID, droppedID ) to OUT port

4) ResignForwarder Processor

• Receives ResignForwarderMsg( ID )
• If ID == myID Then
  • Exit
• Else
  • Forward message downstream and/or to foreign and local groups

---

Member Typedef Documentation

typedef bool(DtConnectionFaultProcessor::* DtConnectionFaultProcessor::HandshakeMsgHandlerMemberCb)(MAKRti::DtInetAddr src, const DtConnectionFaultMsg &msg)

---

Constructor & Destructor Documentation

DtConnectionFaultProcessor::DtConnectionFaultProcessor

(

DtForwarderNode *

parent

)

Default Ctor.

virtual DtConnectionFaultProcessor::~DtConnectionFaultProcessor

(

)

[virtual]

Default Dtor.

---

Member Function Documentation

virtual bool DtConnectionFaultProcessor::gotForwarderStatusRequest	(	const MAKRti::DtInetAddr &	src,
		const DtForwarderStatusRequestMsg	msg
	)		[virtual]

Got Forwarder Status Request Message.

virtual bool DtConnectionFaultProcessor::gotLocalRtiExecConnect	(	const MAKRti::DtInetAddr &	src,
		const DtRtiExecConnectMsg &	msg
	)		[virtual]

Got Local rtiexec Connect Message from LAN Port.

virtual bool DtConnectionFaultProcessor::gotRemoteRtiExecConnect	(	const MAKRti::DtInetAddr &	src,
		const DtRtiExecConnectMsg &	msg
	)		[virtual]

Got Remote rtiexec Connect Message from IN Port.

virtual bool DtConnectionFaultProcessor::gotRtiExecDisconnect	(	const MAKRti::DtInetAddr &	src,
		const DtDisconnectMsg &	msg
	)		[virtual]

Got Local rtiexec Disconnect Message (local or remote)

virtual bool DtConnectionFaultProcessor::processResignForwarderMsgDestinations	(	const MAKRti::DtInetAddr &	src,
		DtForwarderPort::DtAddressPortList &	destinations
	)		[virtual]

Set forwarding destination list based on source (eg.

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

---

Member Data Documentation

DtForwarderNode* DtConnectionFaultProcessor::myParent [protected]

---

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

• connectionFaultProcessor.h