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:

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

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

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