The DtForwarderNode class defines a 3-way message distribution architecture for building forwarding networks of arbitrary complexity. More...

Collaboration diagram for DtForwarderNode:

Public Types
typedef DtMessageProcessor < DtInetAddrAndPort, DtForwarderPort::DtForwarderMsg >	DtForwarderMessageProcessor
typedef DtForwarderNode (	DtForwarderNodeCreatorFcn )(const DtRIDParameters , DtForwarderMessageProcessor , DtForwarderMessageProcessor *, int forwarderPort, MAKRti::DtInetAddr forwarderAddrToConnectTo, bool writeToPipeWhenReady)
	DtForwarderNode creator signature.
Public Member Functions
virtual	~DtForwarderNode ()
virtual int	tick (double maxTime=0.0f)
	Forward pending inbound messages.
virtual void	addTickCallback (DtTickCbFn fn, void *usr, MAKRti::DtTime interval)
	Register a callback to be called during tick, but only at the given interval.
virtual void	removeTickCallback (DtTickCbFn fn, void *usr)
virtual bool	ready () const
	Is the forwarder fully connected and actively forwarding?
virtual const DtRIDParameters *	params () const
	Get the RID parameters object.
virtual DtBoost::shared_ptr < DtRouteMap >	routeMap () const
	Get the Route Map.
virtual DtForwarderPort *	inPort () const
	Get a pointer to the IN/OUT/LAN port.
virtual DtForwarderPort *	lanPort () const
virtual DtForwarderPort *	outPort () const
virtual void	selectParams (MAKRti::DtSelectParamWithWrite &selectParams)
	Get the current set of file descriptors to select against for notification.
virtual unsigned long	localNodeId () const
	Get the ID of this Node for Routing purposes.
const DtInetAddrAndPort &	localNodeAddress () const
	Get the address of this Node for Routing purposes Not virtual as used in CTOR.
virtual MAKRti::DtString	localNodeName () const
	Get the forwarder name.
virtual void	processInToLanMsg (DtForwarderPort::DtAddressMsgPair &msg)
	Process and Send Msg from IN to LAN.
virtual void	processInToOutMsg (DtForwarderPort::DtAddressMsgPair &msg)
	Process and Send Msg from IN to OUT.
virtual void	processLanToOutMsg (DtForwarderPort::DtAddressMsgPair &msg)
	Process and Send Msg from LAN to OUT.
virtual void	sendToLanPort (DtForwarderPort::DtAddressMsgPair &msg)
	Send message directly to LAN port.
virtual void	sendToOutPort (DtForwarderPort::DtAddressMsgPair &msg)
	Send message directly to OUT port (all destinations)
virtual void	sendToOutPort (DtForwarderPort::DtAddressMsgPair &msg, const DtRouteMap::DtAddressPortList &destinations)
	Send message directly to the specified OUT port destinations.
virtual void	registerOutPortProcessor (DtForwarderMessageProcessor::Filter *processor)
	Add/Remove a Message Processor for IN or LAN to OUT messages (LAN to OUT messages identifiable since src == local)
virtual void	unregisterOutPortProcessor (DtForwarderMessageProcessor::Filter *processor)
virtual void	registerLanPortProcessor (DtForwarderMessageProcessor::Filter *processor)
	Add/Remove a Message Processor for IN to LAN messages.
virtual void	unregisterLanPortProcessor (DtForwarderMessageProcessor::Filter *processor)
virtual void	packageAndSendReliable (DtRtiMsg &msg, unsigned int sendViaIntfc)
	Wrap a DtRtiMsg in a DtForwarderMsg envelope and send to the indicated interfaces.
virtual void	packageAndSendReliable (DtRtiMsg &msg, unsigned int sendViaIntfc, const DtRouteMap::DtAddressPortList &destinations)
virtual void	setMetadataControl (DtMetadataType type, bool onOff)
	Set/Get metadata control indicators.
virtual bool	isMetadataEnabled (DtMetadataType type)
virtual void	lanPortListenToMulticastGroup (const MAKRti::DtInetAddr &mcastAddr)
	Listen/Drop multicast groups on LAN port's UDP receive socket.
virtual void	lanPortDropMulticastGroup (const MAKRti::DtInetAddr &mcastAddr)
virtual bool	lanPortUpdateFederateConnectionId (unsigned long orig, unsigned long final)
	Set locally connected federate's connectionId to final value specified by federate in its Connect Confirm message.
virtual DtInetAddrAndPort	nextForwarderOnRoute (const DtInetAddrAndPort &target)
	Locate the next forwarder connection on the route to the targeted address.
virtual DtInetAddrAndPort	nextForwarderOnRoute (const MAKRti::DtString &targetGroupName)
virtual DtInetAddrAndPort	rootForwarder ()
	Return the IP address of the rtiexec's root forwarder.
virtual DtInetAddrAndPort	nextHopToExec ()
	Return the next upstream outbound forwarder's IP address on the path toward the rtiexec's root forwarder.
virtual void	abortPendingConnections ()
	Abort setting up embryonic connections.
virtual unsigned int	abortedConnections ()
	Get the count of failed/aborted connection attempts.
virtual bool	connectionInformation (unsigned int &numForwarderToForwarderConns, std::vector< MAKRti::DtString > &forwarderIdentifiers, std::vector< MAKRti::DtString > &forwarderConnectionHostNames, std::vector< DtInetAddrAndPort > &forwarderConnectionAddrs, unsigned int &numForwarderExecConns, unsigned int &numForwarderClientConns, std::vector< MAKRti::DtString > &clientConnectionHostNames, std::vector< MAKRti::DtInetAddr > &clientConnectionAddrs)
	Get connections information from the forwarder.
void	continueWithoutUnconnectedFws ()
	If the forwarder is currently waiting for remote forwarder connections, this method tells it to abandon any unconnected forwarders and continue on without them.
Static Public Member Functions
static DtForwarderNode *	create (const DtRIDParameters params, DtForwarderMessageProcessor toOutProcessor, DtForwarderMessageProcessor *toLanProcessor, int forwarderPort, MAKRti::DtInetAddr forwarderAddrToConnectTo, bool writeToPipeWhenReady)
	Creates an instance of a DtForwarderNode.
static void	setCreatorFunction (DtForwarderNodeCreatorFcn creator)
	Call this function to set an alternate creator function With this function, users can replace this DtForwarderNode with their own derived class.
static int	newInPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callbacks.
static int	newOutPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
static int	lostInPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
static int	lostOutPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
static void	inOutForwarderPortReady (unsigned long forwarderNodeId, void *usr)
Protected Member Functions
	DtForwarderNode (const DtRIDParameters params, DtForwarderMessageProcessor toOutProcessor, DtForwarderMessageProcessor *toLanProcessor, int forwarderPort, const MAKRti::DtInetAddr &forwarderAddrToConnectTo, bool writeToPipeWhenReady)
	Base Constructor.
	DtForwarderNode ()
	Default Ctor, Copy Ctor, and Assignment - unimplemented.
	DtForwarderNode (const DtForwarderNode &orig)
DtForwarderNode &	operator= (const DtForwarderNode &orig)
int	refreshConnections ()
	Ensure that all connections are stable and connected.
void	writeMessageToPipe (const MAKRti::DtString &msg)
	Write message to rtiexec pipe.
int	newInPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
	Callbacks.
int	newOutPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
int	lostInPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
int	lostOutPortConnection (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
void	inOutForwarderPortReady (unsigned long forwarderNodeId)
Protected Attributes
const DtRIDParameters *	myParams
	RID file configuration.
DtForwarderMessageProcessor *	myToOutMsgProcessor
	Outgoing message processors allow user defined operations to be performed on messages before sending to specified port.
DtForwarderMessageProcessor *	myToLanMsgProcessor
DtForwarderFaultProcessor *	myFaultProcessor
	Fault handler.
DtClock	myClock
	A clock used for basic timing.
bool	myIsReady
	Is the Forwarder in a "Good" state and ready to forward?
DtBoost::shared_ptr< DtRouteMap >	myRoutes
	Routing file configuration Keep this variable before myLocalPort in the class declaration!!
DtForwarderPort *	myRemoteInputPort
	IN Port - incoming message path from other DtForwarderNodes.
DtForwarderPort *	myRemoteOutputPort
	OUT Port - outgoing message path to other DtForwarderNodes.
DtForwarderPort *	myLocalPort
	LAN Port - bidirectional message path to/from local message sources/sinks Keep this variable after myRoutes in the class declaration!!
DtInetAddrAndPort	myLocalNodeAddress
	IP address and port of the local node.
bool	myAddTcpDestinationListMetadata
	Metadata control indicators.
bool	myAddUdpDestinationListMetadata
bool	myAddTransportTypeMetadata
bool	myAddMcastMetadata
bool	myWriteToPipeWhenReady
	Whether the forwarder should write to the pipe once it is ready.
std::list< DtTickCallbackInfo >	myTickCallbacks
	List of tick callbacks.
Static Protected Attributes
static const MAKRti::DtInetAddr	theFirstHostInetAddr = DtDefaultInterfaceAddr()
static DtForwarderNodeCreatorFcn	theCreator = 0

Detailed Description

The DtForwarderNode class defines a 3-way message distribution architecture for building forwarding networks of arbitrary complexity.

The DtForwarderNode has 3 interfaces: IN: - incoming message path from other DtForwarderNodes OUT: - outgoing message path to other DtForwarderNodes LAN: - bidirectional message path to/from local message sources/sinks ( generally HLA Federates )

these are the message distribution endpoints

Forwarding Pathways: 1) Messages from LAN will be forwarded out to upstream/downstream forwarders in hierarchical configurations, to the portal forwarders in foreign Forwarder Groups, and to other LAN connections 2) Messages from IN will be forwarded out to LAN 3) Messages from IN can ONLY be forwarded out to OUT under the following conditions: (a) The forwarder is acting as a bridge (aka "link") node between upstream forwarders and downstream forwarders in a hierarchical network. In this case the user must configure the route and specify the endpoints and the bridge forwarder. This will create an entry in the DtRouteMap myRoutesByLinkAddrMap map. Messages can be forwarded FROM upstream sources TO downstream recipients and vice-versa. (b) The forwarder is acting as a portal forwarder in a Forwarder Group. Only certain internal messages will be forwarded, and only FROM foreign Forwarder Groups TO members of the local group, not in the reverse direction. The reverse direction is taken care of by virtue of the fact that all the local group members will have a connection to a portal in the foreign Forwarder Groups so the messages do not need to pass through the local portal. Some messages require the local portal to aggregate responses of the local group members, but the group members individual response messages are not forwarded in those cases.

Note: These pathways do not guarantee that a message will be forwarded as described above. Outlets may be altered by filters and destinations can be added or removed based on the type of message and the network topology. An optional filter may be applied to all messages forwarded to OUT to allow a final message processing step before passing the message.

Member Typedef Documentation

typedef DtMessageProcessor< DtInetAddrAndPort, DtForwarderPort::DtForwarderMsg > DtForwarderNode::DtForwarderMessageProcessor

typedef DtForwarderNode*(* DtForwarderNode::DtForwarderNodeCreatorFcn)(const DtRIDParameters *, DtForwarderMessageProcessor *, DtForwarderMessageProcessor *, int forwarderPort, MAKRti::DtInetAddr forwarderAddrToConnectTo, bool writeToPipeWhenReady)

DtForwarderNode creator signature.

Constructor & Destructor Documentation

DtForwarderNode::DtForwarderNode	(	const DtRIDParameters *	params,
		DtForwarderMessageProcessor *	toOutProcessor,
		DtForwarderMessageProcessor *	toLanProcessor,
		int	forwarderPort,
		const MAKRti::DtInetAddr &	forwarderAddrToConnectTo,
		bool	writeToPipeWhenReady
	)		`[protected]`

Base Constructor.

DtForwarderNodes should be constructed using the standard plugin creator method

References DtForwarderPort::addConnectionEstablishedCb(), DtForwarderPort::addConnectionLostCb(), DtForwarderPort::addForwarderPortReadyCb(), create(), inOutForwarderPortReady(), DtForwarderPort::isOk(), localNodeAddress(), lostInPortConnection(), lostOutPortConnection(), myAddMcastMetadata, myAddTcpDestinationListMetadata, myAddTransportTypeMetadata, myAddUdpDestinationListMetadata, myClock, myFaultProcessor, myLocalNodeAddress, myLocalPort, myParams, myRemoteInputPort, myRemoteOutputPort, myRoutes, DtRIDParameters::networkInterfaceAddr(), newInPortConnection(), newOutPortConnection(), and theFirstHostInetAddr.

DtForwarderNode::~DtForwarderNode ( ) [virtual]

References inOutForwarderPortReady(), lostInPortConnection(), lostOutPortConnection(), myFaultProcessor, myIsReady, myLocalPort, myRemoteInputPort, myRemoteOutputPort, myWriteToPipeWhenReady, newInPortConnection(), newOutPortConnection(), DtForwarderPort::removeConnectionEstablishedCb(), DtForwarderPort::removeConnectionLostCb(), DtForwarderPort::removeForwarderPortReadyCb(), and writeMessageToPipe().

DtForwarderNode::DtForwarderNode ( ) [protected]

Default Ctor, Copy Ctor, and Assignment - unimplemented.

Referenced by create().

DtForwarderNode::DtForwarderNode ( const DtForwarderNode & orig ) [protected]

Member Function Documentation

unsigned int DtForwarderNode::abortedConnections ( ) [inline, virtual]

Get the count of failed/aborted connection attempts.

References lanPort(), and outPort().

void DtForwarderNode::abortPendingConnections ( ) [virtual]

Abort setting up embryonic connections.

References DtForwarderPort::abortPendingConnections(), DtForwarderPort::checkConnectionStatus(), DtForwarderPort::isReady(), myIsReady, myLocalPort, myRemoteInputPort, and myRemoteOutputPort.

void DtForwarderNode::addTickCallback	(	DtTickCbFn	fn,
		void *	usr,
		MAKRti::DtTime	interval
	)		`[virtual]`

Register a callback to be called during tick, but only at the given interval.

References myTickCallbacks.

bool DtForwarderNode::connectionInformation	(	unsigned int &	numForwarderToForwarderConns,
		std::vector< MAKRti::DtString > &	forwarderIdentifiers,
		std::vector< MAKRti::DtString > &	forwarderConnectionHostNames,
		std::vector< DtInetAddrAndPort > &	forwarderConnectionAddrs,
		unsigned int &	numForwarderExecConns,
		unsigned int &	numForwarderClientConns,
		std::vector< MAKRti::DtString > &	clientConnectionHostNames,
		std::vector< MAKRti::DtInetAddr > &	clientConnectionAddrs
	)		`[virtual]`

Get connections information from the forwarder.

References inPort(), lanPort(), DtLanForwarderPort::populateConnectionInformation(), and DtInOutForwarderPort::populateConnectionInformation().

void DtForwarderNode::continueWithoutUnconnectedFws ( )

If the forwarder is currently waiting for remote forwarder connections, this method tells it to abandon any unconnected forwarders and continue on without them.

References DtForwarderPort::abortPendingConnections(), DtForwarderPort::clearNeededConnections(), myIsReady, myRemoteInputPort, and myRemoteOutputPort.

DtForwarderNode * DtForwarderNode::create	(	const DtRIDParameters *	params,
		DtForwarderMessageProcessor *	toOutProcessor,
		DtForwarderMessageProcessor *	toLanProcessor,
		int	forwarderPort,
		MAKRti::DtInetAddr	forwarderAddrToConnectTo,
		bool	writeToPipeWhenReady
	)		`[static]`

Creates an instance of a DtForwarderNode.

References DtForwarderNode(), params(), and theCreator.

Referenced by DtForwarderNode(), and setCreatorFunction().

void DtForwarderNode::inOutForwarderPortReady	(	unsigned long	forwarderNodeId,
		void *	usr
	)		`[static]`

Referenced by DtForwarderNode(), and ~DtForwarderNode().

void DtForwarderNode::inOutForwarderPortReady ( unsigned long forwarderNodeId ) [protected]

References myLocalPort, and DtForwarderPort::setForwarderId().

DtForwarderPort * DtForwarderNode::inPort ( ) const [inline, virtual]

Get a pointer to the IN/OUT/LAN port.

References myRemoteInputPort.

Referenced by connectionInformation(), DtForwarderFaultProcessor::DtForwarderFaultProcessor(), and DtForwarderFaultProcessor::~DtForwarderFaultProcessor().

bool DtForwarderNode::isMetadataEnabled ( DtMetadataType type ) [virtual]

References DtMetadataTypeDestinationList, DtMetadataTypeMcastAddr, DtMetadataTypeTransport, myAddMcastMetadata, and myAddTransportTypeMetadata.

Referenced by DtForwarderFaultProcessor::lostConnection(), DtForwarderFaultProcessor::newConnection(), and packageAndSendReliable().

DtForwarderPort * DtForwarderNode::lanPort ( ) const [inline, virtual]

References myLocalPort.

Referenced by abortedConnections(), connectionInformation(), lanPortDropMulticastGroup(), lanPortListenToMulticastGroup(), and lanPortUpdateFederateConnectionId().

void DtForwarderNode::lanPortDropMulticastGroup ( const MAKRti::DtInetAddr & mcastAddr ) [virtual]

References DtForwarderPort::dropMulticastGroup(), and lanPort().

void DtForwarderNode::lanPortListenToMulticastGroup ( const MAKRti::DtInetAddr & mcastAddr ) [virtual]

Listen/Drop multicast groups on LAN port's UDP receive socket.

References lanPort(), and DtForwarderPort::listenToMulticastGroup().

bool DtForwarderNode::lanPortUpdateFederateConnectionId	(	unsigned long	orig,
		unsigned long	final
	)		`[virtual]`

Set locally connected federate's connectionId to final value specified by federate in its Connect Confirm message.

References lanPort(), and DtForwarderPort::updateFederateConnectionId().

const DtInetAddrAndPort & DtForwarderNode::localNodeAddress ( ) const

Get the address of this Node for Routing purposes Not virtual as used in CTOR.

References myLocalNodeAddress.

Referenced by DtForwarderNode(), DtForwarderFaultProcessor::localNodeAddress(), localNodeName(), DtForwarderFaultProcessor::lostConnection(), DtForwarderFaultProcessor::newConnection(), packageAndSendReliable(), DtForwarderFaultProcessor::processExecConnectDestinations(), processInToOutMsg(), processLanToOutMsg(), and sendToOutPort().

unsigned long DtForwarderNode::localNodeId ( ) const [virtual]

Get the ID of this Node for Routing purposes.

References myRoutes.

Referenced by DtForwarderFaultProcessor::lostConnection().

MAKRti::DtString DtForwarderNode::localNodeName ( ) const [virtual]

Get the forwarder name.

References localNodeAddress(), and myRoutes.

int DtForwarderNode::lostInPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)		`[static]`

Referenced by DtForwarderNode(), and ~DtForwarderNode().

int DtForwarderNode::lostInPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr
	)		`[protected]`

References myRemoteInputPort, and DtForwarderPort::updateRoutes().

int DtForwarderNode::lostOutPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)		`[static]`

Referenced by DtForwarderNode(), and ~DtForwarderNode().

int DtForwarderNode::lostOutPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr
	)		`[protected]`

References myRemoteInputPort, and DtForwarderPort::updateRoutes().

int DtForwarderNode::newInPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)		`[static]`

Callbacks.

Referenced by DtForwarderNode(), and ~DtForwarderNode().

int DtForwarderNode::newInPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr
	)		`[protected]`

Callbacks.

References myRemoteInputPort, myRemoteOutputPort, and DtForwarderPort::updateRoutes().

int DtForwarderNode::newOutPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)		`[static]`

Referenced by DtForwarderNode(), and ~DtForwarderNode().

int DtForwarderNode::newOutPortConnection	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr
	)		`[protected]`

DtInetAddrAndPort DtForwarderNode::nextForwarderOnRoute ( const DtInetAddrAndPort & target ) [virtual]

Locate the next forwarder connection on the route to the targeted address.

Returns the address only if connection is active (ie. the socket is connected).

References DtForwarderPort::checkConnectionStatus(), outPort(), and routeMap().

Referenced by DtForwarderFaultProcessor::locateGroupPortal().

DtInetAddrAndPort DtForwarderNode::nextForwarderOnRoute ( const MAKRti::DtString & targetGroupName ) [virtual]

References DtForwarderPort::checkConnectionStatus(), outPort(), and routeMap().

DtInetAddrAndPort DtForwarderNode::nextHopToExec ( ) [virtual]

Return the next upstream outbound forwarder's IP address on the path toward the rtiexec's root forwarder.

References myFaultProcessor, and DtForwarderFaultProcessor::nextHopTowardRootForwarder().

DtForwarderNode& DtForwarderNode::operator= ( const DtForwarderNode & orig ) [protected]

DtForwarderPort * DtForwarderNode::outPort ( ) const [inline, virtual]

References myRemoteOutputPort.

Referenced by abortedConnections(), DtConnectionLossDetectorFilter::applyFilter(), DtConnectionLossDetectorFilter::doMessageProcessing(), DtForwarderFaultProcessor::DtForwarderFaultProcessor(), DtForwarderFaultProcessor::newConnection(), nextForwarderOnRoute(), and DtForwarderFaultProcessor::~DtForwarderFaultProcessor().

void DtForwarderNode::packageAndSendReliable	(	DtRtiMsg &	msg,
		unsigned int	sendViaIntfc
	)		`[virtual]`

Wrap a DtRtiMsg in a DtForwarderMsg envelope and send to the indicated interfaces.

Always sends via reliable transport.

References DtForwarderIntfcLan, DtForwarderIntfcOut, DtMetadataTypeTransport, isMetadataEnabled(), DtForwarderPort::DtForwarderMsg::length, localNodeAddress(), DtForwarderPort::DtForwarderMsg::msg, sendToLanPort(), sendToOutPort(), DtRtiMtdTransportType::set(), and DtForwarderPort::DtForwarderMsg::transport.

void DtForwarderNode::packageAndSendReliable	(	DtRtiMsg &	msg,
		unsigned int	sendViaIntfc,
		const DtRouteMap::DtAddressPortList &	destinations
	)		`[virtual]`

References DtForwarderIntfcLan, DtForwarderIntfcOut, DtMetadataTypeTransport, isMetadataEnabled(), DtForwarderPort::DtForwarderMsg::length, localNodeAddress(), DtForwarderPort::DtForwarderMsg::msg, sendToLanPort(), sendToOutPort(), DtRtiMtdTransportType::set(), and DtForwarderPort::DtForwarderMsg::transport.

const DtRIDParameters * DtForwarderNode::params ( ) const [inline, virtual]

Get the RID parameters object.

References myParams.

Referenced by create().

void DtForwarderNode::processInToLanMsg ( DtForwarderPort::DtAddressMsgPair & msg ) [virtual]

Process and Send Msg from IN to LAN.

References myToLanMsgProcessor, DtMessageProcessor< Address, Message >::processMessage(), and sendToLanPort().

Referenced by DtForwarderFaultProcessor::lostConnection(), and tick().

void DtForwarderNode::processInToOutMsg ( DtForwarderPort::DtAddressMsgPair & msg ) [virtual]

Process and Send Msg from IN to OUT.

References localNodeAddress(), myToOutMsgProcessor, DtMessageProcessor< Address, Message >::processDestinationList(), DtMessageProcessor< Address, Message >::processMessage(), routeMap(), and sendToOutPort().

Referenced by DtForwarderFaultProcessor::lostConnection(), and tick().

void DtForwarderNode::processLanToOutMsg ( DtForwarderPort::DtAddressMsgPair & msg ) [virtual]

Process and Send Msg from LAN to OUT.

References localNodeAddress(), myToOutMsgProcessor, DtMessageProcessor< Address, Message >::processDestinationList(), DtMessageProcessor< Address, Message >::processMessage(), routeMap(), and sendToOutPort().

Referenced by tick().

bool DtForwarderNode::ready ( ) const [inline, virtual]

Is the forwarder fully connected and actively forwarding?

References myIsReady.

int DtForwarderNode::refreshConnections ( ) [protected]

Ensure that all connections are stable and connected.

References DtForwarderPort::checkConnectionStatus(), DtForwarderPort::isReady(), myIsReady, myLocalPort, myRemoteInputPort, myRemoteOutputPort, and DtForwarderPort::updateRoutes().

Referenced by tick().

void DtForwarderNode::registerLanPortProcessor ( DtForwarderMessageProcessor::Filter * processor ) [virtual]

Add/Remove a Message Processor for IN to LAN messages.

References DtMessageProcessor< Address, Message >::addDestinationFilter(), DtMessageProcessor< Address, Message >::addMessageFilter(), and myToLanMsgProcessor.

void DtForwarderNode::registerOutPortProcessor ( DtForwarderMessageProcessor::Filter * processor ) [virtual]

Add/Remove a Message Processor for IN or LAN to OUT messages (LAN to OUT messages identifiable since src == local)

References DtMessageProcessor< Address, Message >::addDestinationFilter(), DtMessageProcessor< Address, Message >::addMessageFilter(), and myToOutMsgProcessor.

Referenced by DtForwarderFaultProcessor::DtForwarderFaultProcessor().

void DtForwarderNode::removeTickCallback	(	DtTickCbFn	fn,
		void *	usr
	)		`[virtual]`

References myTickCallbacks.

DtInetAddrAndPort DtForwarderNode::rootForwarder ( ) [virtual]

Return the IP address of the rtiexec's root forwarder.

References myFaultProcessor, and DtForwarderFaultProcessor::rootForwarder().

DtBoost::shared_ptr< DtRouteMap > DtForwarderNode::routeMap ( ) const [inline, virtual]

Get the Route Map.

References myRoutes.

Referenced by DtForwarderFaultProcessor::isLocalGroupMember(), DtForwarderFaultProcessor::newConnection(), nextForwarderOnRoute(), DtForwarderFaultProcessor::processExecConnectDestinations(), processInToOutMsg(), processLanToOutMsg(), and sendToOutPort().

void DtForwarderNode::selectParams ( MAKRti::DtSelectParamWithWrite & selectParams ) [virtual]

Get the current set of file descriptors to select against for notification.

References myLocalPort, myRemoteInputPort, myRemoteOutputPort, and DtForwarderPort::selectParams().

void DtForwarderNode::sendToLanPort ( DtForwarderPort::DtAddressMsgPair & msg ) [virtual]

Send message directly to LAN port.

References myLocalPort, and DtForwarderPort::sendByTransport().

Referenced by DtConnectionLossDetectorFilter::doMessageProcessing(), packageAndSendReliable(), and processInToLanMsg().

void DtForwarderNode::sendToOutPort ( DtForwarderPort::DtAddressMsgPair & msg ) [virtual]

Send message directly to OUT port (all destinations)

References localNodeAddress(), myRemoteOutputPort, routeMap(), and DtForwarderPort::sendToListReliable().

Referenced by DtConnectionLossDetectorFilter::doMessageProcessing(), packageAndSendReliable(), processInToOutMsg(), and processLanToOutMsg().

void DtForwarderNode::sendToOutPort	(	DtForwarderPort::DtAddressMsgPair &	msg,
		const DtRouteMap::DtAddressPortList &	destinations
	)		`[virtual]`

Send message directly to the specified OUT port destinations.

References myRemoteOutputPort, and DtForwarderPort::sendToListReliable().

void DtForwarderNode::setCreatorFunction ( DtForwarderNodeCreatorFcn creator ) [static]

Call this function to set an alternate creator function With this function, users can replace this DtForwarderNode with their own derived class.

References create(), DtBindCreator(), and theCreator.

void DtForwarderNode::setMetadataControl	(	DtMetadataType	type,
		bool	onOff
	)		`[virtual]`

Set/Get metadata control indicators.

References DtMetadataTypeDestinationList, DtMetadataTypeMcastAddr, DtMetadataTypeTransport, myAddMcastMetadata, and myAddTransportTypeMetadata.

int DtForwarderNode::tick ( double maxTime = 0.0f ) [virtual]

Forward pending inbound messages.

maxTime allows the caller to specify a time-out after which tick will return even if msgs are still pending
default: 0.0f implies process msgs until there are NO more pending

References DtForwarderPort::flush(), DtForwarderPort::getNextMsg(), myClock, myIsReady, myLocalPort, myRemoteInputPort, myRemoteOutputPort, myTickCallbacks, myWriteToPipeWhenReady, processInToLanMsg(), processInToOutMsg(), processLanToOutMsg(), refreshConnections(), and writeMessageToPipe().