Inheritance diagram for DtExtendedRtiMsgForwarder:

Collaboration diagram for DtExtendedRtiMsgForwarder:

Public Types
typedef DtThreadSafeBufferQueue< char >	DtCharBufferQueue
Public Types inherited from DtRtiMsgForwarder
typedef DtBoost::shared_ptr < ConnectionInfo >	ConnectionInfoSP
typedef DtBoost::weak_ptr < ConnectionInfo >	ConnectionInfoWP
typedef std::map< const DtTcpMsgSocket *, ConnectionInfoSP >	SocketToConnInfoMap

Public Member Functions
virtual	~DtExtendedRtiMsgForwarder ()
	Default Dtor.
virtual void	applyFilters ()
	Instruct the forwarder to register all filters - called after all desired filters are registered (accessor for protected base member: applyRegisteredFilters)
virtual void	sendByTransport (const DtForwarderPort::DtForwarderMsg &msg)
	Check transport metadata and send message to appropriate socket(s)
virtual void	sendToAllReliable (const DtForwarderPort::DtForwarderMsg &msg)
	Apply registered filters and send message to unfiltered TCP sockets.
virtual void	sendBestEffort (const DtForwarderPort::DtForwarderMsg &msg)
	Apply registered filters and send message to LAN via UDP socket.
virtual void	sendMessageToWan (const DtRtiMsg &msg)
	Allow filters to send messages only to the WAN (not back to the LAN) (useful to distributed forwarder mode filters)
virtual bool	flush ()
	Send buffered messages.
virtual const DtCharBufferQueue::Buffer *	getNextMsg ()
	Get the next message received from the connected sockets.
virtual void	selectParams (MAKRti::DtSelectParamWithWrite &selectParams)
	Get a set of file descriptors to select against for socket notification.
virtual DtForwarderPort::DtAddressPortList	newConnections () const
	Get the list of connections created since last call.
virtual DtForwarderPort::DtAddressPortList	droppedConnections () const
	Get the list of connections lost since last call.
virtual DtForwarderPort::DtAddressPortList	connections () const
	Get the list of all current connections to this port.
virtual void	listenToMulticastGroup (const MAKRti::DtInetAddr &mcastAddr)
	Listen / drop multicast groups.
virtual void	dropMulticastGroup (const MAKRti::DtInetAddr &mcastAddr)
virtual void	federateJoined (const MAKRti::DtString &, const MAKRti::DtString &, const MAKRti::DtString &, unsigned int, unsigned int, const DtInetAddrAndPort &, const MAKRti::DtString &, unsigned int, const MAKRti::DtString &, const MAKRti::DtString &, DtHlaVersionId)
	callbacks when the federate tracking filter notices a federate join/resign event.
virtual void	federateResigned (const MAKRti::DtString &, const MAKRti::DtString &, unsigned int, unsigned int, const DtInetAddrAndPort &)
virtual void	updateSocketQueueStatus (unsigned int connId, int connQueueStatus)
virtual void	addFederateJoinedCb (DtForwarderPort::DtFederateAddedCb callback, void *usr)
virtual void	addFederateResignedCb (DtForwarderPort::DtFederateRemovedCb callback, void *usr)
virtual void	addSocketAdditionCb (DtForwarderPort::DtConnectionChangeCb cb, void *usr)
virtual void	addSocketRemovalCb (DtForwarderPort::DtConnectionChangeCb cb, void *usr)
virtual void	addSocketQueueCb (DtForwarderPort::DtSocketQueueCb cb, void *usr)
virtual void	addExecConnectionEstablishedCb (DtForwarderPort::DtExecAddChangeCb callback, void *usr)
	Register/Unregister a callback for new connections.
virtual void	removeExecConnectionEstablishedCb (DtForwarderPort::DtExecAddChangeCb callback, void *usr)
virtual void	addExecConnectionLostCb (DtForwarderPort::DtExecRemovedChangeCb callback, void *usr)
	Register/Unregister a callback for new connections.
virtual void	removeExecConnectionLostCb (DtForwarderPort::DtExecRemovedChangeCb callback, void *usr)
virtual const DtFederateTrackingFilter *	fedHandleTrackingFilter () const
Public Member Functions inherited from DtRtiMsgForwarder
virtual	~DtRtiMsgForwarder ()
	Destructor.
virtual bool	hasExec () const
	Query the rtiExec Handshake monitor for whether it has an exec.
virtual void	run ()
	Main execution routine.
virtual void	setEnableBundling (unsigned int maxBundleSize)
	Get the rtiexec's socket if known.
virtual void	setUseSmartForwarding (bool yesNo)
	Enable Smart DM Subscription Filtering.
virtual void	setRouteFedexMessages (bool yesNo)
	Enable Smart Fedex Message Filtering.
virtual void	addPacketFilter (DtMessageFilter *filter)
	[Un]Register a forwarding filter on incoming packets
virtual void	removePacketFilter (DtMessageFilter *filter)
virtual unsigned long	forwarderId () const
	Return the forwarder ID (defines the address space for connIds for this forwarder)
virtual void	setForwarderId (unsigned long newId)
	set the forwarder ID.
void	updateTcpForwarderQueuedSockets ()
	update the tcp forwarders queued sockets
virtual const DtRtiMsgForwarder::SocketToConnInfoMap &	getConnToConnInfoMap () const
	WARNING: These methods are not thread-safe and may only be called by the back-end forwarder thread!
virtual ConnectionInfoSP	getConnectionInfoByConnId (unsigned long connId) const
	Get a shared pointer to the connection info for a connection by Conn ID.
virtual ConnectionInfoSP	getConnectionInfoByHandle (unsigned long federateHandle) const
	Get a shared pointer to the connection info for a connection by Federate Handle.
virtual ConnectionInfoSP	getConnectionInfoBySocket (const DtTcpMsgSocket *sock) const
	Get a shared pointer to the connection info for a connection by Socket.
virtual std::pair< bool, unsigned long >	rtiExecConnected () const
	Is the rtiexec connected and if so what is its connId?
virtual void	sendMessage (const DtRtiMsg &msg, const DtTcpMsgSocket *src=0)
	Send a message to all local sockets (filters will be applied)
virtual void	requestCloseAllConnections ()
	Disconnect all open connections after this pass through run-loop completes.
virtual void	requestKillSingleConnection (const DtTcpMsgSocket *sock)
	Disconnect the requestedTcpSocket.
virtual void	markConnectionAsAboutToBeDeleted (DtTcpMsgSocket const *socket, unsigned int connectionId)
	Mark the given socket as one that is to be deleted silently.
virtual bool	isConnectionMarkedForDeletion (unsigned int connectionId) const
	Return boolean: given connection has been marked for deletion?
virtual void	removeOldConnection (unsigned int connectionId)
	Remove the socket specified by the given connection.
virtual void	shutdownRequestedByExec ()
	Shutdown the forwarder application.
virtual bool	updateFederateConnectionId (unsigned long orig, unsigned long final)
	Set a locally connected federate's connId in the associated connection info struct.
virtual bool	updateFederateWebServer (unsigned long connId, MAKRti::DtInetAddr ip, int port)
	Set a locally connected federate's web server address.
virtual void	updateConnectionProcessParameters (unsigned long connId, unsigned long processId, MAKRti::DtString processName, MAKRti::DtString commandArgs)
	Set a connections process information.
virtual bool	shouldStop ()
	should this forwarder stop.

Static Public Member Functions
static DtExtendedRtiMsgForwarder *	create (unsigned int id, const DtRIDParameters &params, bool postMessagesToParent=true)
	Creator.
Static Public Member Functions inherited from DtRtiMsgForwarder
static DtRtiMsgForwarder *	create (unsigned long id, const DtRIDParameters &params)
	Create an instance of a DtRtiMsgForwarder.
static void	setCreatorFunction (DtRtiMsgFwderCreator fn)
	Call this function to set an alternate creator function With this function, users can replace this DtRtiMsgForwarder with their own derived class.
static void	tcpSocketAdditionCb (DtTcpMsgSocket sock, void usr)
	Callbacks on addition/removal of TCP sockets.
static void	tcpSocketRemovalCb (DtTcpMsgSocket sock, void usr)

Static Public Attributes
static const unsigned int	theForwarderId
	Address space for connection IDs for this LAN.

Protected Types
typedef std::pair < DtInetAddrAndPort, int >	DtAddressAndSockIdPair
typedef std::pair< bool, DtAddressAndSockIdPair >	DtBoolAddressSocketIdPair
	These lists are mutable since they are simply used to cache a reflection of back-end thread lists (rather than requiring synchronization)

Protected Member Functions
	DtExtendedRtiMsgForwarder (unsigned long id, const DtRIDParameters &params, bool postMessagesToParent=true)
	Default Ctor.
virtual void	init ()
	Virtual ctor idiom (continues initialization after both base and derived are initialized)
virtual void	tcpSocketAdditionCb (DtTcpMsgSocket *sock)
	Over-ride socket addition/removal callback to track socket list.
virtual void	tcpSocketRemovalCb (DtTcpMsgSocket *sock)
virtual void	refreshConnectionList () const
	Get all changes to connections since last call This method is const so that const front-end threads can call it.
Protected Member Functions inherited from DtRtiMsgForwarder
	DtRtiMsgForwarder (unsigned long id, const DtRIDParameters &params)
	Default Constructor.
virtual void	performMcastDiscovery ()
virtual void	applyRegisteredFilters ()
	Enable / Disable all filters registered with forwarder.
virtual void	disableRegisteredFilters ()
virtual void	waitForIo ()
	Wait on sockets for next IO event (allows RTIspy users to control the wait mechanism and period)
virtual unsigned long	consumeConnId ()
	Get and consume Connection ID.
virtual void	preRunLoopEvent ()
	Plug-in defined Run Loop operations Gives users the ability to add functionality to the Run() loop without over-riding it completely.
virtual void	runLoopEvent ()
virtual void	postRunLoopEvent ()
virtual bool	populateConnectionInformation (unsigned int &numForwarderToForwarderConns, std::vector< MAKRti::DtString > &forwarderIdentifiers, std::vector< MAKRti::DtString > &forwarderConnectionHostNames, std::vector< MAKRti::DtInetAddr > &forwarderConnectionAddrs, unsigned int &numForwarderClientConns, std::vector< MAKRti::DtString > &clientConnectionHostNames, std::vector< MAKRti::DtInetAddr > &clientConnectionAddrs) const
virtual void	closeAllConnectionsIfRequested ()
	Disconnect all open connections.
	DtRtiMsgForwarder (const DtRtiMsgForwarder &orig)
	Copy Ctor and Assignment Operator unimplemented.
DtRtiMsgForwarder &	operator= (const DtRtiMsgForwarder &orig)

Protected Attributes
DtUdpMsgSocket *	myUdpRcvSocket
DtUdpMsgSocket *	myUdpSendSocket
std::auto_ptr < DtCharBufferQueue::Buffer >	myLastReceivedMsg
DtCharBufferQueue	myInMsgQueue
DtCharBufferQueue	myOutMsgQueue
DtMessageBufferFilter *	myOutMsgFilter
DtFederateTrackingFilter *	myFedHandleTracker
DtClock	myClock
	Local timer.
MAKRti::DtTime	myLastDiscoveryTickTime
	Time of last pass for mcast discovery.
DtForwarderPort::DtFederateAddedCallbackList	myFederateJoinedCbs
DtForwarderPort::DtFederateRemovedCallbackList	myFederateResignedCbs
DtForwarderPort::DtSocketQueueCallbackList	mySocketQueueCbs
DtForwarderPort::DtCallbackList	mySocketAddedCbs
DtForwarderPort::DtCallbackList	mySocketRemovedCbs
DtThreadSafeQueue < DtBoolAddressSocketIdPair >	mySocketListChanges
std::set< DtAddressAndSockIdPair >	myConnections
DtForwarderPort::DtAddressPortList	myNewConnections
DtForwarderPort::DtAddressPortList	myDroppedConnections
bool	myForwardMessagesToParent
	Should the local forwarder pass a copy of all messages on to the Parent or simply forward within the local LAN (allows optimization when this is a stand-alone forwarder)
Protected Attributes inherited from DtRtiMsgForwarder
unsigned long	myForwarderId
	Data Members.
MAKRti::DtInetAddr	myForwarderAddr
	Local host IP address (used by rtiExec monitor filter, among other uses)
bool	myCloseAllConnectionsRequested
	Connection shutdown requested?
DtFilteredTcpForwarder *	myTcpForwarder
	Tcp Forwarder with Filtering Capabilities.
DtTcpMsgSocketMgr *	mySocketMgr
	Tcp Socket Manager (handles passive connections to Federates)
int	myPort
	Port for local federate connections.
int	myTcpNoDelay
unsigned long	myNextConnectionIdOffset
	The ID to be assigned to the next Federate or Forwarder connection The IDs are offset from the forwarderId.
unsigned int	myPacketBundleSize
	Packet Bundle size (if bundle size = 0, bundling is disabled)
DtRtiExecTrackingFilter *	myRtiExecMonitor
	If registered, Monitors rtiexec connection life-cycle.
DtRoutePrinterFilter *	myRoutePrinter
	Smart DM Forwarding Filters.
DtUpdateInterRoutingFilter *	myDmMsgRouter
DtFedexMsgFilter *	myFedexMsgRouter
	Fedex Routing Filter.
DtConnectConfirmFilter *	myConnectConfirmFilter
	Extracts info from connect confirm messages.
DtDeleteSocketFilter *	mySocketMonitor
	Marks sockets that are being disconnected normally so that no complaint is given when they disconnect versus abnormal disconnect.
const DtRIDParameters &	myParams
	Local access to the RID Parameters.
DtMulitcastDiscoveryMgr	myMcastDiscoveryMgr
DtThreadSafe< std::deque < DtMsgFwdrFunctor * > >	myPendingProxyCommands
std::vector< DtMessageFilter * >	myRegisteredFilters
	Registered Message Filters.
SocketToConnInfoMap	myConnToConnInfoMap
	Map from socket (conn) to ConnectionInfo object for that connection notes:
std::set< DtTcpMsgSocket const * >	myConnectionsAboutToBeDeleted
	Set of connections that when deleted there should be no complaint.
MAKRti::DtSelectParamWithWrite	mySelectParams
bool	myShouldStop
	should this forwarder stop.

Additional Inherited Members
Static Protected Attributes inherited from DtRtiMsgForwarder
static DtRtiMsgFwderCreator	theCreator = NULL

Member Typedef Documentation

typedef std::pair< DtInetAddrAndPort, int > DtExtendedRtiMsgForwarder::DtAddressAndSockIdPair

protected

typedef std::pair< bool, DtAddressAndSockIdPair > DtExtendedRtiMsgForwarder::DtBoolAddressSocketIdPair

protected

These lists are mutable since they are simply used to cache a reflection of back-end thread lists (rather than requiring synchronization)

changes to the actual lists occur asynchronously in the back-end, so these lists may need to be updated before any use.

typedef DtThreadSafeBufferQueue<char> DtExtendedRtiMsgForwarder::DtCharBufferQueue

Constructor & Destructor Documentation

DtExtendedRtiMsgForwarder::DtExtendedRtiMsgForwarder	(	unsigned long	id,
		const DtRIDParameters &	params,
		bool	postMessagesToParent = `true`
	)

protected

Default Ctor.

Referenced by create().

DtExtendedRtiMsgForwarder::~DtExtendedRtiMsgForwarder ( )

virtual

Default Dtor.

References myFedHandleTracker, myOutMsgFilter, myUdpSendSocket, and DtRtiMsgForwarder::removePacketFilter().

Member Function Documentation

void DtExtendedRtiMsgForwarder::addExecConnectionEstablishedCb	(	DtForwarderPort::DtExecAddChangeCb	callback,
		void *	usr
	)

virtual

Register/Unregister a callback for new connections.

References DtRtiExecTrackingFilter::addExecConnectionEstablishedCb(), and DtRtiMsgForwarder::myRtiExecMonitor.

Referenced by DtLanForwarderPort::DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::addExecConnectionLostCb	(	DtForwarderPort::DtExecRemovedChangeCb	callback,
		void *	usr
	)

virtual

Register/Unregister a callback for new connections.

References DtRtiExecTrackingFilter::addExecConnectionLostCb(), and DtRtiMsgForwarder::myRtiExecMonitor.

Referenced by DtLanForwarderPort::DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::addFederateJoinedCb	(	DtForwarderPort::DtFederateAddedCb	callback,
		void *	usr
	)

virtual

References myFederateJoinedCbs.

Referenced by DtLanForwarderPort::DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::addFederateResignedCb	(	DtForwarderPort::DtFederateRemovedCb	callback,
		void *	usr
	)

virtual

References myFederateResignedCbs.

Referenced by DtLanForwarderPort::DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::addSocketAdditionCb	(	DtForwarderPort::DtConnectionChangeCb	cb,
		void *	usr
	)

virtual

References mySocketAddedCbs.

Referenced by DtLanForwarderPort::DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::addSocketQueueCb	(	DtForwarderPort::DtSocketQueueCb	cb,
		void *	usr
	)

virtual

References mySocketQueueCbs.

void DtExtendedRtiMsgForwarder::addSocketRemovalCb	(	DtForwarderPort::DtConnectionChangeCb	cb,
		void *	usr
	)

virtual

References mySocketRemovedCbs.

Referenced by DtLanForwarderPort::DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::applyFilters ( )

virtual

Instruct the forwarder to register all filters - called after all desired filters are registered (accessor for protected base member: applyRegisteredFilters)

References DtRtiMsgForwarder::applyRegisteredFilters().

Referenced by DtLanForwarderPort::DtLanForwarderPort().

DtForwarderPort::DtAddressPortList DtExtendedRtiMsgForwarder::connections ( ) const

virtual

Get the list of all current connections to this port.

References myConnections, and refreshConnectionList().

Referenced by DtLanForwarderPort::connections().

DtExtendedRtiMsgForwarder * DtExtendedRtiMsgForwarder::create	(	unsigned int	id,
		const DtRIDParameters &	params,
		bool	postMessagesToParent = `true`
	)

static

Creator.

Caller may set postMessagesToParent as an optimization if there is never any need for the parent to access the message stream (ie - if this is being used by a stand-alone forwarder and getNextMsg is used simply to tick the Forwarder)

References DtExtendedRtiMsgForwarder(), and init().

void DtExtendedRtiMsgForwarder::dropMulticastGroup ( const MAKRti::DtInetAddr & mcastAddr )

virtual

References DtUdpMsgSocket::dropMulticastGroup(), and myUdpRcvSocket.

Referenced by DtLanForwarderPort::dropMulticastGroup().

DtForwarderPort::DtAddressPortList DtExtendedRtiMsgForwarder::droppedConnections ( ) const

virtual

Get the list of connections lost since last call.

References myDroppedConnections, and refreshConnectionList().

void DtExtendedRtiMsgForwarder::federateJoined	(	const MAKRti::DtString &	federateName,
		const MAKRti::DtString &	federateType,
		const MAKRti::DtString &	federationName,
		unsigned int	connectId,
		unsigned int	fedHandle,
		const DtInetAddrAndPort &	connAddr,
		const MAKRti::DtString &	connHost,
		unsigned int	processId,
		const MAKRti::DtString &	processName,
		const MAKRti::DtString &	commandArgs,
		DtHlaVersionId	hlaVersion
	)

virtual

callbacks when the federate tracking filter notices a federate join/resign event.

References myFederateJoinedCbs.

Referenced by DtFederateTrackingFilter::handleJoinConfirmMsg().

void DtExtendedRtiMsgForwarder::federateResigned	(	const MAKRti::DtString &	federateName,
		const MAKRti::DtString &	federateType,
		unsigned int	connectId,
		unsigned int	fedHandle,
		const DtInetAddrAndPort &	connAddr
	)

virtual

References myFederateResignedCbs.

Referenced by DtFederateTrackingFilter::handleResignMsg().

virtual const DtFederateTrackingFilter* DtExtendedRtiMsgForwarder::fedHandleTrackingFilter ( ) const

inlinevirtual

Referenced by DtLanForwarderPort::fedTrackingFilter().

bool DtExtendedRtiMsgForwarder::flush ( )

inlinevirtual

Send buffered messages.

Returns the status indicating error, flush is complete or incomplete.

References DtUdpMsgSocket::flush(), DtUdpMsgSocket::isOpen(), and myUdpSendSocket.

Referenced by DtLanForwarderPort::flush().

const DtExtendedRtiMsgForwarder::DtCharBufferQueue::Buffer * DtExtendedRtiMsgForwarder::getNextMsg ( )

virtual

Get the next message received from the connected sockets.

Buffer is valid until the next call to getNextMsg()

References DtRtiMsgForwarder::closeAllConnectionsIfRequested(), Dt_SocketReadAllowance, DtTcpMsgSocket::flush(), DtTcpMsgSocket::isConnected(), myClock, myLastDiscoveryTickTime, myLastReceivedMsg, DtRtiMsgForwarder::myMcastDiscoveryMgr, myOutMsgQueue, DtRtiMsgForwarder::myParams, DtRtiMsgForwarder::myRtiExecMonitor, DtRtiMsgForwarder::mySocketMgr, DtRtiMsgForwarder::myTcpForwarder, myUdpRcvSocket, DtThreadSafeBufferQueue< T >::pop(), DtTcpMsgSocketMgr::processConnections(), DtRtiExecTrackingFilter::processTimeout(), DtThreadSafeBufferQueue< T >::push(), DtFilteredTcpForwarder::readAndForward(), DtUdpMsgSocket::recvMessage(), DtThreadSafeBufferQueue< T >::releaseBuffer(), DtTcpMsgSocketMgr::removeAndDelete(), DtThreadSafeBufferQueue< T >::size(), DtTcpMsgSocketMgr::socketSet(), and DtMulitcastDiscoveryMgr::tick().

Referenced by DtLanForwarderPort::getNextMsg().

void DtExtendedRtiMsgForwarder::init ( )

protectedvirtual

Virtual ctor idiom (continues initialization after both base and derived are initialized)

Reimplemented from DtRtiMsgForwarder.

References DtRtiMsgForwarder::addPacketFilter(), DtRIDParameters::bestEffortSendRetryWaitUsec, DtRIDParameters::destAddr(), DtRIDParameters::distributedUdpForwarderMode, DtUdpMsgSocket::enableBundling(), DtUdpMsgSocket::enableCompression(), DtRIDParameters::isUdpCompressionEnabled, DtMsgSocket::localEndpoint(), DtRIDParameters::mcastTtl, DtRtiMsgForwarder::myConnToConnInfoMap, DtRtiMsgForwarder::myFedexMsgRouter, myFedHandleTracker, DtRtiMsgForwarder::myForwarderAddr, myForwardMessagesToParent, myOutMsgFilter, myOutMsgQueue, DtRtiMsgForwarder::myParams, DtRtiMsgForwarder::myPort, DtRtiMsgForwarder::myRtiExecMonitor, myUdpRcvSocket, myUdpSendSocket, DtRIDParameters::networkInterfaceAddr(), DtUdpMsgSocket::openSocket(), DtRtiMsgForwarder::removePacketFilter(), DtRIDParameters::responseInterval, DtRIDParameters::rtiExecReconnectPause, DtUdpMsgSocket::setFilterPort(), DtUdpMsgSocket::setMcastTtlOption(), DtFedexMsgFilter::setMonitor(), DtMsgSocket::setRecvBufferSize(), DtUdpMsgSocket::setRetryOnSend(), DtMsgSocket::setSendBufferSize(), DtRIDParameters::socketReceiveBufferSize, DtRIDParameters::socketSendBufferSize, and DtRIDParameters::udpCompressionLevel.

Referenced by create().

void DtExtendedRtiMsgForwarder::listenToMulticastGroup ( const MAKRti::DtInetAddr & mcastAddr )

virtual

Listen / drop multicast groups.

References DtUdpMsgSocket::joinMulticastGroup(), and myUdpRcvSocket.

Referenced by DtLanForwarderPort::listenToMulticastGroup().

DtForwarderPort::DtAddressPortList DtExtendedRtiMsgForwarder::newConnections ( ) const

virtual

Get the list of connections created since last call.

References myNewConnections, and refreshConnectionList().

void DtExtendedRtiMsgForwarder::refreshConnectionList ( ) const

protectedvirtual

Get all changes to connections since last call This method is const so that const front-end threads can call it.

this hides the fact that changes actually occur in a separate thread and the front-end merely reflects back-end state
ie - the actual state is stored in the back-end and this method IS const with respect to it

References myConnections, myDroppedConnections, myNewConnections, mySocketListChanges, and DtThreadSafeQueue< T >::pop().

Referenced by connections(), droppedConnections(), newConnections(), and selectParams().

void DtExtendedRtiMsgForwarder::removeExecConnectionEstablishedCb	(	DtForwarderPort::DtExecAddChangeCb	callback,
		void *	usr
	)

virtual

References DtRtiMsgForwarder::myRtiExecMonitor, and DtRtiExecTrackingFilter::removeExecConnectionEstablishedCb().

Referenced by DtLanForwarderPort::~DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::removeExecConnectionLostCb	(	DtForwarderPort::DtExecRemovedChangeCb	callback,
		void *	usr
	)

virtual

References DtRtiMsgForwarder::myRtiExecMonitor, and DtRtiExecTrackingFilter::removeExecConnectionLostCb().

Referenced by DtLanForwarderPort::~DtLanForwarderPort().

void DtExtendedRtiMsgForwarder::selectParams ( MAKRti::DtSelectParamWithWrite & selectParams )

virtual

Get a set of file descriptors to select against for socket notification.

References DtMsgSocket::descriptor(), myConnections, myUdpRcvSocket, and refreshConnectionList().

Referenced by DtLanForwarderPort::selectParams().

void DtExtendedRtiMsgForwarder::sendBestEffort ( const DtForwarderPort::DtForwarderMsg & msg )

virtual

Apply registered filters and send message to LAN via UDP socket.

References DtRIDParameters::destAddr(), DtRIDParameters::distributedUdpForwarderMode, DtRtiMtdMcastAddr::get(), DtForwarderPort::DtForwarderMsg::length, DtForwarderPort::DtForwarderMsg::msg, DtRtiMsgForwarder::myParams, myUdpSendSocket, and DtUdpMsgSocket::sendMessage().

Referenced by sendByTransport().

void DtExtendedRtiMsgForwarder::sendByTransport ( const DtForwarderPort::DtForwarderMsg & msg )

virtual

Check transport metadata and send message to appropriate socket(s)

References sendBestEffort(), sendToAllReliable(), and DtForwarderPort::DtForwarderMsg::transport.

Referenced by DtLanForwarderPort::sendByTransport().

void DtExtendedRtiMsgForwarder::sendMessageToWan ( const DtRtiMsg & msg )

virtual

Allow filters to send messages only to the WAN (not back to the LAN) (useful to distributed forwarder mode filters)

References DtRIDParameters::distributedUdpForwarderMode, myOutMsgQueue, DtRtiMsgForwarder::myParams, DtThreadSafeBufferQueue< T >::push(), and DtRtiMtdTransportType::set().

void DtExtendedRtiMsgForwarder::sendToAllReliable ( const DtForwarderPort::DtForwarderMsg & msg )

virtual

Apply registered filters and send message to unfiltered TCP sockets.

References DtFilteredTcpForwarder::filterAndSend(), DtForwarderPort::DtForwarderMsg::length, DtForwarderPort::DtForwarderMsg::msg, and DtRtiMsgForwarder::myTcpForwarder.

Referenced by sendByTransport(), DtLanForwarderPort::sendToAllReliable(), and DtLanForwarderPort::sendToListReliable().

void DtExtendedRtiMsgForwarder::tcpSocketAdditionCb ( DtTcpMsgSocket * sock )

protectedvirtual

Over-ride socket addition/removal callback to track socket list.

Reimplemented from DtRtiMsgForwarder.

References DtMsgSocket::descriptor(), DtTcpMsgSocket::destination(), DtRtiMsgForwarder::getConnectionInfoBySocket(), mySocketAddedCbs, mySocketListChanges, and DtThreadSafeQueue< T >::push_back().

void DtExtendedRtiMsgForwarder::tcpSocketRemovalCb ( DtTcpMsgSocket * sock )

protectedvirtual

Reimplemented from DtRtiMsgForwarder.

References DtMsgSocket::descriptor(), DtTcpMsgSocket::destination(), DtRtiMsgForwarder::getConnectionInfoBySocket(), mySocketListChanges, mySocketRemovedCbs, and DtThreadSafeQueue< T >::push_back().

void DtExtendedRtiMsgForwarder::updateSocketQueueStatus	(	unsigned int	connId,
		int	connQueueStatus
	)

virtual

References mySocketQueueCbs.

Member Data Documentation

DtClock DtExtendedRtiMsgForwarder::myClock

protected

Local timer.

Referenced by getNextMsg().

std::set< DtAddressAndSockIdPair > DtExtendedRtiMsgForwarder::myConnections

mutableprotected

Referenced by connections(), refreshConnectionList(), and selectParams().

DtForwarderPort::DtAddressPortList DtExtendedRtiMsgForwarder::myDroppedConnections

mutableprotected

Referenced by droppedConnections(), and refreshConnectionList().

DtForwarderPort::DtFederateAddedCallbackList DtExtendedRtiMsgForwarder::myFederateJoinedCbs

protected

Referenced by addFederateJoinedCb(), and federateJoined().

DtForwarderPort::DtFederateRemovedCallbackList DtExtendedRtiMsgForwarder::myFederateResignedCbs

protected

Referenced by addFederateResignedCb(), and federateResigned().

DtFederateTrackingFilter* DtExtendedRtiMsgForwarder::myFedHandleTracker

protected

Referenced by init(), and ~DtExtendedRtiMsgForwarder().

bool DtExtendedRtiMsgForwarder::myForwardMessagesToParent

protected

Should the local forwarder pass a copy of all messages on to the Parent or simply forward within the local LAN (allows optimization when this is a stand-alone forwarder)

Referenced by init().

DtCharBufferQueue DtExtendedRtiMsgForwarder::myInMsgQueue

protected

MAKRti::DtTime DtExtendedRtiMsgForwarder::myLastDiscoveryTickTime

protected

Time of last pass for mcast discovery.

Referenced by getNextMsg().

std::auto_ptr<DtCharBufferQueue::Buffer> DtExtendedRtiMsgForwarder::myLastReceivedMsg

protected

Referenced by getNextMsg().

DtForwarderPort::DtAddressPortList DtExtendedRtiMsgForwarder::myNewConnections

mutableprotected