DtRtiForwarderObserverMgr Class Reference

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

Collaboration diagram for DtRtiForwarderObserverMgr:

Public Member Functions
	DtRtiForwarderObserverMgr ()
	Constructor.
virtual	~DtRtiForwarderObserverMgr ()
	Destructor.
virtual void	setForwarderNode (DtBoost::shared_ptr< DtForwarderNode > forwarder)
	Sets the forwarder to be observed.
virtual void	addObserver (DtBoost::shared_ptr< DtRtiForwarderObserver > observer)
	Add a new RTI Forwarder observer.
virtual void	removeObserver (DtBoost::shared_ptr< DtRtiForwarderObserver > observer)
	Remove RTI Forwarder observer.
virtual void	removeAllObservers ()
	Remove all RTI Forwarder observers.
virtual void	addRtiMsgCallback (DtRtiMsgKind msgKind, DtRtiMsgCbMgr::DtCallbackFcn fcn, DtRtiForwarderObserver *observer, bool isMomCallback)
	Add callback for incoming RTI message.
virtual void	removeRtiMsgCallback (DtRtiMsgKind msgKind, DtRtiMsgCbMgr::DtCallbackFcn fcn, DtRtiForwarderObserver *observer, bool isMomCallback)
	Remove callback for incoming RTI message.
virtual int	clientToForwarderConnectionEstablished (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
virtual int	clientToForwarderConnectionLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
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)
virtual int	clientToForwarderSocketQueueUpdate (unsigned int connId, int connQueueStatus)
virtual void	clientToForwarderFederateLost (const MAKRti::DtString &connName, const MAKRti::DtString &connType, unsigned int connID, unsigned int fedHandle, const DtInetAddrAndPort &connAddr)
virtual int	forwarderToForwarderExecConnected (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &connHost, bool fullyCompliant)
virtual int	forwarderToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
virtual int	clientToForwarderExecConnected (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, const MAKRti::DtString &hostName, bool fullyCompliant)
virtual int	clientToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
virtual int	forwarderToForwarderConnectionEstablished (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
virtual int	forwarderToForwarderConnectionLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr)
virtual void	waitingForFowrarderConnections (const DtForwarderPort::DtConnAndNameMap &allNeededFws, const DtForwarderPort::DtConnAndNameMap &stillNeededFws)
virtual void	notWaitingForFowrarderConnections ()
virtual void	addTickCallback (DtTickCbFn fcn, DtRtiForwarderObserver *observer, MAKRti::DtTime interval)
	Add a tick callback function to be called periodically at the given time interval.
virtual void	removeTickCallback (DtTickCbFn fcn, DtRtiForwarderObserver *observer)
	Remove tick callback.
virtual unsigned long	connectionId () const
	Retrieve information about this node.
virtual const DtInetAddrAndPort &	connectionAddr () const
virtual MAKRti::DtString	connectionName () const

Static Public Member Functions
static int	clientToForwarderConnectionEstablished (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for established client<->forwarder connections.
static int	clientToForwarderConnectionLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for lost client<->forwarder connections.
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.
static int	clientToForwarderSocketQueueUpdate (unsigned int connId, int connQueueStatus, void *usr)
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.
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.
static int	forwarderToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for lost forwarder<->forwarder rtiexec connections.
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.
static int	clientToForwarderExecLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for lost client<->forwarder rtiexec connections.
static int	forwarderToForwarderConnectionEstablished (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for established forwarder<->forwarder connections.
static int	forwarderToForwarderConnectionLost (const MAKRti::DtString &connName, unsigned int connID, const DtInetAddrAndPort &connAddr, void *usr)
	Callback for lost forwarder<->forwarder connections.
static void	waitingForFowrarderConnections (const DtForwarderPort::DtConnAndNameMap &allNeededFws, const DtForwarderPort::DtConnAndNameMap &stillNeededFws, void *usr)
	Callback to signal that forwarder is waiting for forwarder<->forwarder connections.
static void	notWaitingForFowrarderConnections (void *usr)
	Callback to signal that forwarder is no longer waiting for forwarder<->forwarder connections.

Protected Types
typedef std::set< DtMsgCbInfo >	DtMsgCbSet
typedef std::set < DtTickCallbackInfo >	DtTickCbSet
typedef std::set < DtForwarderPortCbInfo >	DtForwarderPortCbSet
typedef std::list < DtBoost::shared_ptr < DtRtiForwarderObserver > >	DtForwarderObsList

Protected Member Functions
	DtRtiForwarderObserverMgr (const DtRtiForwarderObserverMgr &orig)
	Copy constructor unimplemented.
DtRtiForwarderObserverMgr &	operator= (const DtRtiForwarderObserverMgr &orig)
	Assignment unimplemented.

Protected Attributes
DtBoost::shared_ptr < DtForwarderNode >	myForwarder
	The RTI Forwarder which is being observed.
DtForwarderObsList	myObservers
	List of RTI Forwarder observers.
DtMsgCbSet	myMsgCbSet
	Set of all registered message callbacks.
DtTickCbSet	myTickCbSet
	Set of all registered tick callbacks.

Detailed Description

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

Member Typedef Documentation

typedef std::list< DtBoost::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 ( DtBoost::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, unsigned int  connID, const DtInetAddrAndPort &  connAddr, void *  usr  )

static

Callback for established client<->forwarder connections.

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

virtual

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

static

Callback for lost client<->forwarder connections.

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

virtual

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

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

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

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

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

static

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

virtual

virtual const DtInetAddrAndPort& DtRtiForwarderObserverMgr::connectionAddr ( ) 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::forwarderToForwarderConnectionEstablished ( const MAKRti::DtString &  connName, unsigned int  connID, const DtInetAddrAndPort &  connAddr, void *  usr  )

static

Callback for established forwarder<->forwarder connections.

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

virtual

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

static

Callback for lost forwarder<->forwarder connections.

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

virtual

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

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

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

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

protected

Assignment unimplemented.

virtual void DtRtiForwarderObserverMgr::removeAllObservers ( )

virtual

Remove all RTI Forwarder observers.

virtual void DtRtiForwarderObserverMgr::removeObserver ( DtBoost::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 ( DtBoost::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

Member Data Documentation

DtBoost::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