The DtRtiForwarderObserverMgr is the class which manages all RTI Forwarder observers. More...

Collaboration diagram for DtRtiForwarderObserverMgr:

Public Member Functions
	DtRtiForwarderObserverMgr ()
	Constructor. More...

virtual	~DtRtiForwarderObserverMgr ()
	Destructor. More...

virtual void	setForwarderNode (std::shared_ptr< DtForwarderNode > forwarder)
	Sets the forwarder to be observed. More...

virtual void	addObserver (std::shared_ptr< DtRtiForwarderObserver > observer)
	Add a new RTI Forwarder observer. More...

virtual void	removeObserver (std::shared_ptr< DtRtiForwarderObserver > observer)
	Remove RTI Forwarder observer. More...

virtual void	removeAllObservers ()
	Remove all RTI Forwarder observers. More...

virtual void	addRtiMsgCallback (DtRtiMsgKind msgKind, DtRtiMsgCbMgr::DtCallbackFcn fcn, DtRtiForwarderObserver *observer, bool isMomCallback)
	Add callback for incoming RTI message. More...

virtual void	removeRtiMsgCallback (DtRtiMsgKind msgKind, DtRtiMsgCbMgr::DtCallbackFcn fcn, DtRtiForwarderObserver *observer, bool isMomCallback)
	Remove callback for incoming RTI message. More...

virtual void	addTickCallback (DtTickCbFn fcn, DtRtiForwarderObserver *observer, MAKRti::DtTime interval)
	Add a tick callback function to be called periodically at the given time interval. More...

virtual void	removeTickCallback (DtTickCbFn fcn, DtRtiForwarderObserver *observer)
	Remove tick callback. More...

virtual unsigned long	connectionId () const
	Retrieve information about this node. More...

virtual const DtInetAddrAndPort &	connectionAddr () const

virtual MAKRti::DtString	connectionName () const

virtual MAKRti::DtString	connectionHostName () const

Protected Types
typedef std::set< DtMsgCbInfo >	DtMsgCbSet

typedef std::set < DtTickCallbackInfo >	DtTickCbSet

typedef std::set < DtForwarderPortCbInfo >	DtForwarderPortCbSet

typedef std::list < std::shared_ptr < DtRtiForwarderObserver > >	DtForwarderObsList

Protected Member Functions
	DtRtiForwarderObserverMgr (const DtRtiForwarderObserverMgr &orig)
	Copy constructor unimplemented. More...

DtRtiForwarderObserverMgr &	operator= (const DtRtiForwarderObserverMgr &orig)
	Assignment unimplemented. More...

Protected Attributes
std::shared_ptr< DtForwarderNode >	myForwarder
	The RTI Forwarder which is being observed. More...

DtForwarderObsList	myObservers
	List of RTI Forwarder observers. More...

DtMsgCbSet	myMsgCbSet
	Set of all registered message callbacks. More...

DtTickCbSet	myTickCbSet
	Set of all registered tick callbacks. More...

virtual int	clientToForwarderConnectionEstablished (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr)
	Callback for established client<->forwarder connections. More...

static int	clientToForwarderConnectionEstablished (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr, void *usr)
	Callback for established client<->forwarder connections. More...

virtual int	clientToForwarderConnectionLost (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr)
	Callback for lost client<->forwarder connections. More...

static int	clientToForwarderConnectionLost (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr, void *usr)
	Callback for lost client<->forwarder connections. More...

virtual void	clientToForwarderFederateJoined (const MAKRti::DtString &connName, const MAKRti::DtString &connType, const MAKRti::DtString &federationName, unsigned int connID, unsigned int fedHandle, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &hostName, unsigned int procesId, const MAKRti::DtString &processName, const MAKRti::DtString &commandArgs, DtHlaVersionId hlaVersion)
	Callback for established client<->forwarder connections. More...

static void	clientToForwarderFederateJoined (const MAKRti::DtString &connName, const MAKRti::DtString &connType, const MAKRti::DtString &federationName, unsigned int connID, unsigned int fedHandle, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &hostName, unsigned int procesId, const MAKRti::DtString &processName, const MAKRti::DtString &commandArgs, DtHlaVersionId hlaVersion, void *usr)
	Callback for established client<->forwarder connections. More...

virtual int	clientToForwarderSocketQueueUpdate (unsigned int connId, int connQueueStatus)
	Callback for lost client<->forwarder socket queue status update. More...

static int	clientToForwarderSocketQueueUpdate (unsigned int connId, int connQueueStatus, void *usr)
	Callback for lost client<->forwarder socket queue status update. More...

virtual void	clientToForwarderFederateLost (const MAKRti::DtString &connName, const MAKRti::DtString &connType, unsigned int connID, unsigned int fedHandle, const DtInetAddrAndPort &connAddr)
	Callback for lost client<->forwarder connections. More...

static void	clientToForwarderFederateLost (const MAKRti::DtString &connName, const MAKRti::DtString &connType, unsigned int connID, unsigned int fedHandle, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for lost client<->forwarder connections. More...

virtual int	forwarderToForwarderExecConnected (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &connHost, bool fullyCompliant)
	Callback for established forwarder<->forwarder rtiexec connections. More...

static int	forwarderToForwarderExecConnected (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &connHost, bool fullyCompliant, void *usr)
	Callback for established forwarder<->forwarder rtiexec connections. More...

virtual int	forwarderToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
	Callback for lost forwarder<->forwarder rtiexec connections. More...

static int	forwarderToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for lost forwarder<->forwarder rtiexec connections. More...

virtual int	clientToForwarderExecConnected (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &hostName, bool fullyCompliant)
	Callback for established client<->forwarder rtiexec connections. More...

static int	clientToForwarderExecConnected (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &hostName, bool fullyCompliant, void *usr)
	Callback for established client<->forwarder rtiexec connections. More...

virtual int	clientToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
	Callback for lost client<->forwarder rtiexec connections. More...

static int	clientToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for lost client<->forwarder rtiexec connections. More...

virtual int	forwarderToForwarderConnectionEstablished (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr)
	Callback for established forwarder<->forwarder connections. More...

static int	forwarderToForwarderConnectionEstablished (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr, void *usr)
	Callback for established forwarder<->forwarder connections. More...

virtual int	forwarderToForwarderConnectionLost (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr)
	Callback for lost forwarder<->forwarder connections. More...

static int	forwarderToForwarderConnectionLost (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int connID, const std::pair< DtInetAddrAndPort, DtInetAddrAndPort > &connAddr, void *usr)
	Callback for lost forwarder<->forwarder connections. More...

virtual int	forwarderToForwarderConnectionChanged (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int oldConnID, unsigned int newConnID, const DtInetAddrAndPort &connAddr)
	Callback for changed forwarder<->forwarder connections. More...

static int	forwarderToForwarderConnectionChanged (const MAKRti::DtString &connName, const MAKRti::DtString &hostName, unsigned int oldConnID, unsigned int newConnID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for changed forwarder<->forwarder connections. More...

virtual void	waitingForFowrarderConnections (const DtForwarderPort::DtConnAndNameMap &allNeededFws, const DtForwarderPort::DtConnAndNameMap &stillNeededFws)
	Callback to signal that forwarder is waiting for forwarder<->forwarder connections. More...

static void	waitingForFowrarderConnections (const DtForwarderPort::DtConnAndNameMap &allNeededFws, const DtForwarderPort::DtConnAndNameMap &stillNeededFws, void *usr)
	Callback to signal that forwarder is waiting for forwarder<->forwarder connections. More...

virtual void	notWaitingForFowrarderConnections ()
	Callback to signal that forwarder is no longer waiting for forwarder<->forwarder connections. More...

static void	notWaitingForFowrarderConnections (void *usr)
	Callback to signal that forwarder is no longer waiting for forwarder<->forwarder connections. More...

Detailed Description

The DtRtiForwarderObserverMgr is the class which manages all RTI Forwarder observers.

Member Typedef Documentation

typedef std::list< std::shared_ptr<DtRtiForwarderObserver> > DtRtiForwarderObserverMgr::DtForwarderObsList

protected

typedef std::set<DtForwarderPortCbInfo> DtRtiForwarderObserverMgr::DtForwarderPortCbSet

protected

typedef std::set<DtMsgCbInfo> DtRtiForwarderObserverMgr::DtMsgCbSet

protected

typedef std::set<DtTickCallbackInfo> DtRtiForwarderObserverMgr::DtTickCbSet

protected

Constructor & Destructor Documentation

DtRtiForwarderObserverMgr::DtRtiForwarderObserverMgr ( )

Constructor.

virtual DtRtiForwarderObserverMgr::~DtRtiForwarderObserverMgr ( )

virtual

Destructor.

DtRtiForwarderObserverMgr::DtRtiForwarderObserverMgr ( const DtRtiForwarderObserverMgr & orig )

protected

Copy constructor unimplemented.

Member Function Documentation

virtual void DtRtiForwarderObserverMgr::addObserver ( std::shared_ptr< DtRtiForwarderObserver > observer )

virtual

Add a new RTI Forwarder observer.

virtual void DtRtiForwarderObserverMgr::addRtiMsgCallback	(	DtRtiMsgKind	msgKind,
		DtRtiMsgCbMgr::DtCallbackFcn	fcn,
		DtRtiForwarderObserver *	observer,
		bool	isMomCallback
	)

virtual

Add callback for incoming RTI message.

virtual void DtRtiForwarderObserverMgr::addTickCallback	(	DtTickCbFn	fcn,
		DtRtiForwarderObserver *	observer,
		MAKRti::DtTime	interval
	)

virtual

Add a tick callback function to be called periodically at the given time interval.

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

static

Callback for established client<->forwarder connections.

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

virtual

Callback for established client<->forwarder connections.

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

static

Callback for lost client<->forwarder connections.

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

virtual

Callback for lost client<->forwarder connections.

static int DtRtiForwarderObserverMgr::clientToForwarderExecConnected	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		const MAKRti::DtString &	hostName,
		bool	fullyCompliant,
		void *	usr
	)

static

Callback for established client<->forwarder rtiexec connections.

virtual int DtRtiForwarderObserverMgr::clientToForwarderExecConnected	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		const MAKRti::DtString &	hostName,
		bool	fullyCompliant
	)

virtual

Callback for established client<->forwarder rtiexec connections.

static int DtRtiForwarderObserverMgr::clientToForwarderExecLost	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)

static

Callback for lost client<->forwarder rtiexec connections.

virtual int DtRtiForwarderObserverMgr::clientToForwarderExecLost	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr
	)

virtual

Callback for lost client<->forwarder rtiexec connections.

static void DtRtiForwarderObserverMgr::clientToForwarderFederateJoined	(	const MAKRti::DtString &	connName,
		const MAKRti::DtString &	connType,
		const MAKRti::DtString &	federationName,
		unsigned int	connID,
		unsigned int	fedHandle,
		const DtInetAddrAndPort &	connAddr,
		const MAKRti::DtString &	hostName,
		unsigned int	procesId,
		const MAKRti::DtString &	processName,
		const MAKRti::DtString &	commandArgs,
		DtHlaVersionId	hlaVersion,
		void *	usr
	)

static

Callback for established client<->forwarder connections.

virtual void DtRtiForwarderObserverMgr::clientToForwarderFederateJoined	(	const MAKRti::DtString &	connName,
		const MAKRti::DtString &	connType,
		const MAKRti::DtString &	federationName,
		unsigned int	connID,
		unsigned int	fedHandle,
		const DtInetAddrAndPort &	connAddr,
		const MAKRti::DtString &	hostName,
		unsigned int	procesId,
		const MAKRti::DtString &	processName,
		const MAKRti::DtString &	commandArgs,
		DtHlaVersionId	hlaVersion
	)

virtual

Callback for established client<->forwarder connections.

static void DtRtiForwarderObserverMgr::clientToForwarderFederateLost	(	const MAKRti::DtString &	connName,
		const MAKRti::DtString &	connType,
		unsigned int	connID,
		unsigned int	fedHandle,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)

static

Callback for lost client<->forwarder connections.

virtual void DtRtiForwarderObserverMgr::clientToForwarderFederateLost	(	const MAKRti::DtString &	connName,
		const MAKRti::DtString &	connType,
		unsigned int	connID,
		unsigned int	fedHandle,
		const DtInetAddrAndPort &	connAddr
	)

virtual

Callback for lost client<->forwarder connections.

static int DtRtiForwarderObserverMgr::clientToForwarderSocketQueueUpdate	(	unsigned int	connId,
		int	connQueueStatus,
		void *	usr
	)

static

Callback for lost client<->forwarder socket queue status update.

virtual int DtRtiForwarderObserverMgr::clientToForwarderSocketQueueUpdate	(	unsigned int	connId,
		int	connQueueStatus
	)

virtual

Callback for lost client<->forwarder socket queue status update.

virtual const DtInetAddrAndPort& DtRtiForwarderObserverMgr::connectionAddr ( ) const

virtual

virtual MAKRti::DtString DtRtiForwarderObserverMgr::connectionHostName ( ) const

virtual

virtual unsigned long DtRtiForwarderObserverMgr::connectionId ( ) const

virtual

Retrieve information about this node.

Referenced by DtRtiForwarderObserver::connectionId().

virtual MAKRti::DtString DtRtiForwarderObserverMgr::connectionName ( ) const

virtual

static int DtRtiForwarderObserverMgr::forwarderToForwarderConnectionChanged	(	const MAKRti::DtString &	connName,
		const MAKRti::DtString &	hostName,
		unsigned int	oldConnID,
		unsigned int	newConnID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)

static

Callback for changed forwarder<->forwarder connections.

virtual int DtRtiForwarderObserverMgr::forwarderToForwarderConnectionChanged	(	const MAKRti::DtString &	connName,
		const MAKRti::DtString &	hostName,
		unsigned int	oldConnID,
		unsigned int	newConnID,
		const DtInetAddrAndPort &	connAddr
	)

virtual

Callback for changed forwarder<->forwarder connections.

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

static

Callback for established forwarder<->forwarder connections.

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

virtual

Callback for established forwarder<->forwarder connections.

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

static

Callback for lost forwarder<->forwarder connections.

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

virtual

Callback for lost forwarder<->forwarder connections.

static int DtRtiForwarderObserverMgr::forwarderToForwarderExecConnected	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		const MAKRti::DtString &	connHost,
		bool	fullyCompliant,
		void *	usr
	)

static

Callback for established forwarder<->forwarder rtiexec connections.

virtual int DtRtiForwarderObserverMgr::forwarderToForwarderExecConnected	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		const MAKRti::DtString &	connHost,
		bool	fullyCompliant
	)

virtual

Callback for established forwarder<->forwarder rtiexec connections.

static int DtRtiForwarderObserverMgr::forwarderToForwarderExecLost	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr,
		void *	usr
	)

static

Callback for lost forwarder<->forwarder rtiexec connections.

virtual int DtRtiForwarderObserverMgr::forwarderToForwarderExecLost	(	const MAKRti::DtString &	connName,
		unsigned int	connID,
		const DtInetAddrAndPort &	connAddr
	)

virtual

Callback for lost forwarder<->forwarder rtiexec connections.

static void DtRtiForwarderObserverMgr::notWaitingForFowrarderConnections ( void * usr )

static

Callback to signal that forwarder is no longer waiting for forwarder<->forwarder connections.

virtual void DtRtiForwarderObserverMgr::notWaitingForFowrarderConnections ( )

virtual

Callback to signal that forwarder is no longer waiting for forwarder<->forwarder connections.

DtRtiForwarderObserverMgr& DtRtiForwarderObserverMgr::operator= ( const DtRtiForwarderObserverMgr & orig )

protected

Assignment unimplemented.

virtual void DtRtiForwarderObserverMgr::removeAllObservers ( )

virtual

Remove all RTI Forwarder observers.

virtual void DtRtiForwarderObserverMgr::removeObserver ( std::shared_ptr< DtRtiForwarderObserver > observer )

virtual

Remove RTI Forwarder observer.

virtual void DtRtiForwarderObserverMgr::removeRtiMsgCallback	(	DtRtiMsgKind	msgKind,
		DtRtiMsgCbMgr::DtCallbackFcn	fcn,
		DtRtiForwarderObserver *	observer,
		bool	isMomCallback
	)

virtual

Remove callback for incoming RTI message.

virtual void DtRtiForwarderObserverMgr::removeTickCallback	(	DtTickCbFn	fcn,
		DtRtiForwarderObserver *	observer
	)

virtual

Remove tick callback.

virtual void DtRtiForwarderObserverMgr::setForwarderNode ( std::shared_ptr< DtForwarderNode > forwarder )

virtual

Sets the forwarder to be observed.

static void DtRtiForwarderObserverMgr::waitingForFowrarderConnections	(	const DtForwarderPort::DtConnAndNameMap &	allNeededFws,
		const DtForwarderPort::DtConnAndNameMap &	stillNeededFws,
		void *	usr
	)

static

Callback to signal that forwarder is waiting for forwarder<->forwarder connections.

virtual void DtRtiForwarderObserverMgr::waitingForFowrarderConnections	(	const DtForwarderPort::DtConnAndNameMap &	allNeededFws,
		const DtForwarderPort::DtConnAndNameMap &	stillNeededFws
	)

virtual

Callback to signal that forwarder is waiting for forwarder<->forwarder connections.

Member Data Documentation

std::shared_ptr<DtForwarderNode> DtRtiForwarderObserverMgr::myForwarder

protected

The RTI Forwarder which is being observed.

DtMsgCbSet DtRtiForwarderObserverMgr::myMsgCbSet

protected

Set of all registered message callbacks.

DtForwarderObsList DtRtiForwarderObserverMgr::myObservers

protected

List of RTI Forwarder observers.

DtTickCbSet DtRtiForwarderObserverMgr::myTickCbSet

protected

Set of all registered tick callbacks.

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

forwarderObserverMgr.h

Public Member Functions

Protected Types

Protected Member Functions

Protected Attributes

Detailed Description

Member Typedef Documentation

Constructor & Destructor Documentation

Member Function Documentation

Member Data Documentation