DtRtiexecObserverForAssistant Class Reference

Observes the rtiexec and is responsible sending information on rtiexec to the RTI Assistant. More...

Inheritance diagram for DtRtiexecObserverForAssistant:

Collaboration diagram for DtRtiexecObserverForAssistant:

Public Member Functions
	DtRtiexecObserverForAssistant ()
virtual	~DtRtiexecObserverForAssistant ()
virtual void	initialize (DtRIDParameters *params, DtBoost::shared_ptr< DtRtiexecCmdProc > cmdProc)
	Initializes the observer.
virtual void	startObservation ()
	Indicates that observation of the exec has begun.
bool	gotConnInfoFromAssistant ()
	Returns true if the assistant supplied the rtiexec connection info.
Public Member Functions inherited from DtRtiexecObserver
	DtRtiexecObserver ()
	Constructor.
virtual	~DtRtiexecObserver ()
	Destructor.
virtual void	setMgr (DtRtiexecObserverMgr *mgr)
	Sets the manager for this observer.
virtual void	removeMgr ()
	Removes the manager for this observer.
virtual void	addRtiMsgCallback (DtRtiMsgKind msgKind, DtRtiMsgCbMgr::DtCallbackFcn fcn, bool isMomCallback=false)
	Register to receive an event whenever an RTI Msg of the specified kind is received.
virtual void	removeRtiMsgCallback (DtRtiMsgKind msgKind, DtRtiMsgCbMgr::DtCallbackFcn fcn, bool isMomCallback=false)
	Unregister to receive an event whenever an RTI Msg of the specified kind is received.
virtual void	addTickCallback (DtTickCbFn fcn, DtTime interval)
	Add a tick callback function to be called periodically at the given time interval.
virtual void	removeTickCallback (DtTickCbFn fcn)
	Remove tick callback.
virtual void	addTickCallback (DtTickWithExecCbFn fcn, DtTime interval)
	Add a tick callback function that takes a reference to a DtRtiExec to be called periodically at the given time interval.
virtual void	removeTickCallback (DtTickWithExecCbFn fcn)
	Remove tick callback that takes a reference to a DtRtiExec.
virtual unsigned long	connectionId () const
	Get the connection ID for this exec (threadsafe)

Protected Member Functions
virtual void	addCallbacks ()
	Adds all RTI message and tick callbacks. Called when a manager is set.
virtual void	removeCallbacks ()
	Removes all RTI message and tick callbacks.
void	fillFederateTimeStateInfo (DtAssistantFederateInfo &stateInfo, unsigned long connId, const MAKRti::DtString &fedType, const MAKRti::DtString &fedName, DtFederateHandle fedHandle, const MAKRti::DtString &fedHostName, const MAKRti::DtInetAddr &fedHost, DtHlaVersionId hlaVersion, int astntCompId, const DtFedExec &fedExec)
	Fills in the federate time state using the given information.
virtual void	sendConnectionInfo (bool isConnected)
	Send the connection info to the assistant.

Protected Attributes
DtBoost::shared_ptr < DtRtiAssistantExecClient >	myAssistantClient
	The assistant client.
DtAssistantPrinter *	myAssistantPrinter
	The printer which sends notifications to the assistant.
DtBufferPrinter *	myBufferPrinter
	The printer which stores all rtiexec output.
DtBoost::shared_ptr< DtPrinterBuf >	myPrinterBuffer
	Buffer which the buffer printer writes to.
DtBoost::shared_ptr < DtRtiexecCmdProc >	myCmdProc
	Processes commands to be performed by the rtiexec.
bool	myFedReconnectEnabled
	Is federate reconnect enabled?
bool	myAllowNetworkTesting
	Whether or not this rtiexec allows network testing for its federations.
DtFederationStateByNameMap	myFederations
	Cache the complete state of the federations.
DtFederationNameByHandleMap	myFederationNames
	Map of federation handles to names.
MAKRti::DtTime	myMinTimeBetweenUpdates
	Min. time exec should wait between time state updates.
bool	myGotConnInfoFromAssistant
	Whether or not the assistant supplied connection info.
bool	myExecIsObserved
	Whether or not there is currently an assistant observing this rtiexec.
DtRIDParameters *	myParams
	The RID parameter settings.
int	myForwarderPort
	Stored information about the forwarder.
MAKRti::DtInetAddr	myForwarderToConnectTo
	Stored information about the forwarder.
Protected Attributes inherited from DtRtiexecObserver
DtRtiexecObserverMgr *	myMgr
	Pointer to the observer manager.

Rtiexec event processing functions
virtual void	tick ()
	Periodic processing.
virtual void	queryForConnectionInfo (DtRtiConnectionInfoDataPair &connInfo, DtRtiConnectionConfigurationInfo &config)
	Periodic processing.
virtual void	setForwarderInfo (int forwarderPort, const MAKRti::DtInetAddr &forwarderToConnectTo)
	If we're not querying the assistant, provide some way for the forwarder to indicate what its forwarderConnInfo is.
virtual void	enableNotifications ()
	Enables sending DtWarn & DtFatal to assistant as notifications.
virtual void	disableNotifications ()
	Disables sending DtWarn & DtFatal to assistant as notifications.
virtual void	processFedExCreatedEvent (DtFedExec *exec)
	Process a new federation execution created event.
virtual void	processFedExDestroyedEvent (DtFedExec *exec)
	Process a federation execution destroyed event.
virtual void	processFederateJoinedEvent (DtFedExec *exec, DtFederate *federate)
	Process a federate joined event.
virtual void	processFederateResignedEvent (DtFedExec *exec, DtFederate *federate)
	Process a federate resigned event.
virtual void	processSyncPtRegisteredEvent (DtFedExec *exec, DtSyncPt *pt)
	Process a new sync. point registered event.
virtual void	processFederationSynchronizedEvent (DtFedExec *exec, DtSyncPt *pt)
	Process a federation synchronized to an existing sync. point event.
virtual void	processSyncPtAchievedEvent (DtFedExec *exec, DtFederate *federate, DtSyncPt *pt)
	Process an existing sync. point achieved event.
virtual void	processFederateDisconnectedEvent (DtFedExec *exec, DtFederate *federate)
	Process a federate disconnect event.
virtual void	processFederateReconnectSucceededEvent (DtFedExec *exec, DtFederate *federate)
	Process a federate reconnect succeeded event.
virtual void	processFederateReconnectFailedEvent (DtFedExec *exec, DtFederate *federate)
	Process a federate reconnect failed event.
virtual void	processLogFileUpdatedEvent (const MAKRti::DtFilename &logFile)
	Process a log file name update event.
virtual void	processTimeStateEvent (const DtRtiExec &exec)
	Process a federate reconnect failed event.
static void	tick (void *usr)
	Callback for periodic processing.
static void	processTimeStateEvent (const DtRtiExec &exec, void *usr)
	Callback for periodic time state processing.

RTI message processing callbacks
virtual void	processLatencyTestStatusMsg (const DtTestMgrStatusMsg &msg)
	Process latency test status message.
virtual void	processLatencyTestResultsMsg (const DtLatencyReportMsg &msg)
	Process latency test status message.
static void	processLatencyTestStatusMsg (const DtRtiMsg &msg, void *usr)
	Callback for latency test status message.
static void	processLatencyTestResultsMsg (const DtRtiMsg &msg, void *usr)
	Callback for latency test results message.

RTI Assistant message processing callbacks
virtual void	processExecObserveMsg (const DtAssistantStateObserveMsg &msg)
	Process exec observe message by enabling or disabling rtiexec update messages to the assistant.
virtual void	processDeleteFederateMsg (const DtAssistantDeleteFederateMsg &msg)
	Process delete federate command.
virtual void	processDeleteFederationMsg (const DtAssistantDeleteFederationMsg &msg)
	Process delete federation command.
virtual void	processEnableLoggingMsg (const DtAssistantLogEnableMsg &msg)
	Process logging enable command.
virtual void	processNotifyLevelChangeMsg (const DtAssistantNtfyLvlUpdateMsg &msg)
	Process notify level change command.
virtual void	processNetworkTestingEnableMsg (const DtAssistantNetworkTestEnableMsg &msg)
	Process network testing enable/disable command.
virtual void	processLatencyTestCmndMsg (const DtAssistantChangeLatencyTestModeMsg &msg)
	Process latency command.
virtual void	processRidParamRequestMsg (const DtAssistantRidParamsMsg &msg)
	Process RID request.
virtual void	processLogRequestMsg (const DtAssistantLogRequestMsg &msg)
	Process log request.
virtual void	processExitCmndMsg (const DtAssistantExitMsg &msg)
	Process exit command.
virtual void	processAssistantDisconnect ()
	Process assistant disconnect.
static void	processExecObserveMsg (const DtAssistantStateObserveMsg &msg, void *usr)
	Callback for a command message notifying this exec that it is or is not being observed.
static void	processDeleteFederateMsg (const DtAssistantDeleteFederateMsg &msg, void *usr)
	Callback for federate delete command message.
static void	processDeleteFederationMsg (const DtAssistantDeleteFederationMsg &msg, void *usr)
	Callback for federation delete command message.
static void	processEnableLoggingMsg (const DtAssistantLogEnableMsg &msg, void *usr)
	Callback for logging enable command message.
static void	processNotifyLevelChangeMsg (const DtAssistantNtfyLvlUpdateMsg &msg, void *usr)
	Callback for notify level change command message.
static void	processNetworkTestingEnableMsg (const DtAssistantNetworkTestEnableMsg &msg, void *usr)
	Callback for networking testing enable/disable command message.
static void	processLatencyTestCmndMsg (const DtAssistantChangeLatencyTestModeMsg &msg, void *usr)
	Callback for latency testing command message.
static void	processRidParamRequestMsg (const DtAssistantRidParamsMsg &msg, void *usr)
	Callback for RID parameter request.
static void	processLogRequestMsg (const DtAssistantLogRequestMsg &msg, void *usr)
	Callback for log request.
static void	processExitCmndMsg (const DtAssistantExitMsg &msg, void *usr)
	Callback for exit command message.
static void	processAssistantDisconnect (void *usr)
	Callback for assistant disconnect.

Detailed Description

Observes the rtiexec and is responsible sending information on rtiexec to the RTI Assistant.

Also accepts commands from the Assistant and gives them to the rtiexec for processing.

Constructor & Destructor Documentation

DtRtiexecObserverForAssistant::DtRtiexecObserverForAssistant

(

)

References DtAssistantExitMsg::addCallback(), DtAssistantLogEnableMsg::addCallback(), DtAssistantLogRequestMsg::addCallback(), DtAssistantDeleteFederationMsg::addCallback(), DtAssistantNtfyLvlUpdateMsg::addCallback(), DtAssistantDeleteFederateMsg::addCallback(), DtAssistantNetworkTestEnableMsg::addCallback(), DtAssistantRidParamsMsg::addCallback(), DtAssistantChangeLatencyTestModeMsg::addCallback(), DtAssistantStateObserveMsg::addCallback(), determineClientAndServerPorts(), myAssistantClient, myAssistantPrinter, myBufferPrinter, myPrinterBuffer, processAssistantDisconnect(), processDeleteFederateMsg(), processDeleteFederationMsg(), processEnableLoggingMsg(), processExecObserveMsg(), processExitCmndMsg(), processLatencyTestCmndMsg(), processLogRequestMsg(), processNetworkTestingEnableMsg(), processNotifyLevelChangeMsg(), and processRidParamRequestMsg().

DtRtiexecObserverForAssistant::~DtRtiexecObserverForAssistant ( )

virtual

References myAssistantClient, myAssistantPrinter, myBufferPrinter, processAssistantDisconnect(), processDeleteFederateMsg(), processDeleteFederationMsg(), processEnableLoggingMsg(), processExecObserveMsg(), processExitCmndMsg(), processLatencyTestCmndMsg(), processLogRequestMsg(), processNetworkTestingEnableMsg(), processNotifyLevelChangeMsg(), DtAssistantExitMsg::removeCallback(), DtAssistantLogRequestMsg::removeCallback(), DtAssistantLogEnableMsg::removeCallback(), DtAssistantDeleteFederationMsg::removeCallback(), DtAssistantNtfyLvlUpdateMsg::removeCallback(), DtAssistantDeleteFederateMsg::removeCallback(), DtAssistantNetworkTestEnableMsg::removeCallback(), DtAssistantChangeLatencyTestModeMsg::removeCallback(), DtAssistantStateObserveMsg::removeCallback(), and DtRtiexecObserver::removeMgr().

Member Function Documentation

void DtRtiexecObserverForAssistant::addCallbacks ( )

protectedvirtual

Adds all RTI message and tick callbacks. Called when a manager is set.

Implements DtRtiexecObserver.

References DtRtiexecObserver::addRtiMsgCallback(), DtRtiexecObserver::addTickCallback(), DtLatencyReportMsgKind, DtTestMgrStatusMsgKind, myMinTimeBetweenUpdates, processLatencyTestResultsMsg(), processLatencyTestStatusMsg(), processTimeStateEvent(), and tick().

void DtRtiexecObserverForAssistant::disableNotifications ( )

virtual

Disables sending DtWarn & DtFatal to assistant as notifications.

References myAssistantPrinter.

void DtRtiexecObserverForAssistant::enableNotifications ( )

virtual

Enables sending DtWarn & DtFatal to assistant as notifications.

References myAssistantPrinter.

void DtRtiexecObserverForAssistant::fillFederateTimeStateInfo ( DtAssistantFederateInfo &  stateInfo, unsigned long  connId, const MAKRti::DtString &  fedType, const MAKRti::DtString &  fedName, DtFederateHandle  fedHandle, const MAKRti::DtString &  fedHostName, const MAKRti::DtInetAddr &  fedHost, DtHlaVersionId  hlaVersion, int  astntCompId, const DtFedExec &  fedExec  )

protected

Fills in the federate time state using the given information.

References DtToString(), DtAssistantFederateInfo::setAssistantCompId(), DtAssistantFederateInfo::setConnId(), DtAssistantFederateInfo::setFederateHandle(), DtAssistantFederateInfo::setFederateHostAddr(), DtAssistantFederateInfo::setFederateHostName(), DtAssistantFederateInfo::setFederateName(), DtAssistantFederateInfo::setFederateType(), DtAssistantFederateInfo::setHlaVersion(), DtAssistantFederateInfo::setIsConstrained(), DtAssistantFederateInfo::setIsRegulating(), DtAssistantFederateInfo::setLbtsString(), DtAssistantFederateInfo::setLookAheadString(), and DtAssistantFederateInfo::setTimeString().

Referenced by processFederateJoinedEvent(), and processTimeStateEvent().

bool DtRtiexecObserverForAssistant::gotConnInfoFromAssistant ( )

inline

Returns true if the assistant supplied the rtiexec connection info.

References myGotConnInfoFromAssistant.

void DtRtiexecObserverForAssistant::initialize ( DtRIDParameters *  params, DtBoost::shared_ptr< DtRtiexecCmdProc >  cmdProc  )

virtual

Initializes the observer.

References DtRIDParameters::enableNetworkTesting, DtFedExec::init(), myAllowNetworkTesting, myAssistantClient, myCmdProc, myFedReconnectEnabled, myParams, and DtRIDParameters::rtiExecPerformsLicensing.

void DtRtiexecObserverForAssistant::processAssistantDisconnect ( void *  usr )

static

Callback for assistant disconnect.

References processAssistantDisconnect().

void DtRtiexecObserverForAssistant::processAssistantDisconnect ( )

virtual

Process assistant disconnect.

Referenced by DtRtiexecObserverForAssistant(), processAssistantDisconnect(), and ~DtRtiexecObserverForAssistant().

void DtRtiexecObserverForAssistant::processDeleteFederateMsg ( const DtAssistantDeleteFederateMsg &  msg, void *  usr  )

static

Callback for federate delete command message.

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

void DtRtiexecObserverForAssistant::processDeleteFederateMsg ( const DtAssistantDeleteFederateMsg &  msg )

virtual

Process delete federate command.

References DtAssistantDeleteFederateMsg::federateHandle(), DtAssistantFederationInfo::federates(), DtAssistantDeleteFederateMsg::federationHandle(), myAssistantClient, myCmdProc, myExecIsObserved, myFederationNames, and myFederations.

void DtRtiexecObserverForAssistant::processDeleteFederationMsg ( const DtAssistantDeleteFederationMsg &  msg, void *  usr  )

static

Callback for federation delete command message.

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

void DtRtiexecObserverForAssistant::processDeleteFederationMsg ( const DtAssistantDeleteFederationMsg &  msg )

virtual

Process delete federation command.

References DtAssistantFederationInfo::federates(), DtAssistantDeleteFederationMsg::federationHandle(), myAssistantClient, myCmdProc, myExecIsObserved, myFederationNames, and myFederations.

void DtRtiexecObserverForAssistant::processEnableLoggingMsg ( const DtAssistantLogEnableMsg &  msg, void *  usr  )

static

Callback for logging enable command message.

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

void DtRtiexecObserverForAssistant::processEnableLoggingMsg ( const DtAssistantLogEnableMsg &  msg )

virtual

Process logging enable command.

References myCmdProc.

void DtRtiexecObserverForAssistant::processExecObserveMsg ( const DtAssistantStateObserveMsg &  msg, void *  usr  )

static

Callback for a command message notifying this exec that it is or is not being observed.

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

void DtRtiexecObserverForAssistant::processExecObserveMsg ( const DtAssistantStateObserveMsg &  msg )

virtual

Process exec observe message by enabling or disabling rtiexec update messages to the assistant.

References DtRtiexecObserver::addTickCallback(), DtAssistantStateObserveFederationsOrRtiexec, false, DtAssistantStateObserveMsg::isLogRequest(), DtAssistantStateObserveMsg::isObserved(), DtAssistantStateObserveMsg::isSingleView(), myAssistantClient, myAssistantPrinter, myExecIsObserved, myFederations, myMinTimeBetweenUpdates, processTimeStateEvent(), DtRtiexecObserver::removeTickCallback(), DtAssistantFederationInfo::syncPoint(), DtAssistantStateObserveMsg::targetType(), and DtAssistantStateObserveMsg::timeStateUpdateInterval().

void DtRtiexecObserverForAssistant::processExitCmndMsg ( const DtAssistantExitMsg &  msg, void *  usr  )

static

Callback for exit command message.

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

void DtRtiexecObserverForAssistant::processExitCmndMsg ( const DtAssistantExitMsg &  msg )

virtual

Process exit command.

References myAssistantClient, and myCmdProc.

void DtRtiexecObserverForAssistant::processFederateDisconnectedEvent ( DtFedExec *  exec, DtFederate *  federate  )

virtual

Process a federate disconnect event.

Reimplemented from DtRtiexecObserver.

References DtAssistantFederationInfo::federateInfo(), DtFedExec::fedExName(), DtFederate::getHandle(), myAssistantClient, myExecIsObserved, myFederations, myFedReconnectEnabled, DtAssistantFederateInfo::setIsDisconnected(), DtAssistantFederateInfo::setIsReconnecting(), and DtAssistantFederationInfo::updateFederate().

void DtRtiexecObserverForAssistant::processFederateJoinedEvent ( DtFedExec *  exec, DtFederate *  federate  )

virtual

Process a federate joined event.

Reimplemented from DtRtiexecObserver.

References DtAssistantFederationInfo::addFomModule(), DtFederate::assistantCompId(), DtFedExec::fedExName(), fillFederateTimeStateInfo(), DtAssistantFederationInfo::fomModules(), DtFedExec::fomModules(), DtFederate::getConnectionHandle(), DtFederate::getFederateHost(), DtFederate::getFederateHostName(), DtFederate::getHandle(), DtFederate::getName(), DtFederate::getType(), DtFederate::hlaVersion(), myAssistantClient, myExecIsObserved, myFederations, and DtAssistantFederationInfo::updateFederate().

void DtRtiexecObserverForAssistant::processFederateReconnectFailedEvent ( DtFedExec *  exec, DtFederate *  federate  )

virtual

Process a federate reconnect failed event.

Reimplemented from DtRtiexecObserver.

References DtAssistantFederationInfo::federateInfo(), DtFedExec::fedExName(), DtFederate::getHandle(), myAssistantClient, myExecIsObserved, myFederations, DtAssistantFederateInfo::setIsDisconnected(), DtAssistantFederateInfo::setIsReconnecting(), and DtAssistantFederationInfo::updateFederate().

void DtRtiexecObserverForAssistant::processFederateReconnectSucceededEvent ( DtFedExec *  exec, DtFederate *  federate  )

virtual

Process a federate reconnect succeeded event.

Reimplemented from DtRtiexecObserver.

References DtAssistantFederationInfo::federateInfo(), DtFedExec::fedExName(), DtFederate::getHandle(), myAssistantClient, myExecIsObserved, myFederations, DtAssistantFederateInfo::setIsDisconnected(), DtAssistantFederateInfo::setIsReconnecting(), and DtAssistantFederationInfo::updateFederate().

void DtRtiexecObserverForAssistant::processFederateResignedEvent ( DtFedExec *  exec, DtFederate *  federate  )

virtual

Process a federate resigned event.

Reimplemented from DtRtiexecObserver.

References DtAssistantFederationInfo::federateInfo(), DtFedExec::fedExName(), DtFederate::getHandle(), myAssistantClient, myExecIsObserved, myFederations, and DtAssistantFederationInfo::removeFederate().

void DtRtiexecObserverForAssistant::processFederationSynchronizedEvent ( DtFedExec *  exec, DtSyncPt *  pt  )

virtual

Process a federation synchronized to an existing sync. point event.

Reimplemented from DtRtiexecObserver.

References DtFedExec::fedExName(), myAssistantClient, myExecIsObserved, myFederations, DtSyncPt::name(), DtAssistantFederationInfo::removeSyncPoint(), and DtAssistantFederationInfo::syncPoint().

void DtRtiexecObserverForAssistant::processFedExCreatedEvent ( DtFedExec *  exec )

virtual

Process a new federation execution created event.

Reimplemented from DtRtiexecObserver.

References DtAssistantFederationInfo::addFomModule(), DtAssistantFederationInfo::enableTesting(), DtAssistantFederationInfo::federationHandle(), DtAssistantFederationInfo::federationName(), DtFedExec::fedExHandle(), DtFedExec::fedExName(), DtFedExec::fedFileName(), DtFedExec::fomModules(), myAllowNetworkTesting, myAssistantClient, myExecIsObserved, myFederationNames, myFederations, DtAssistantFederationInfo::setFederationHandle(), and DtAssistantFederationInfo::setFederationName().

void DtRtiexecObserverForAssistant::processFedExDestroyedEvent ( DtFedExec *  exec )

virtual

Process a federation execution destroyed event.

Reimplemented from DtRtiexecObserver.

References DtFedExec::fedExHandle(), DtFedExec::fedExName(), myAssistantClient, myExecIsObserved, myFederationNames, and myFederations.

void DtRtiexecObserverForAssistant::processLatencyTestCmndMsg ( const DtAssistantChangeLatencyTestModeMsg &  msg, void *  usr  )

static

Callback for latency testing command message.

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

void DtRtiexecObserverForAssistant::processLatencyTestCmndMsg ( const DtAssistantChangeLatencyTestModeMsg &  msg )

virtual

Process latency command.

References DtAssistantChangeLatencyTestModeMsg::continuousUpdate(), DtAssistantChangeLatencyTestModeMsg::federationHandle(), DtAssistantChangeLatencyTestModeMsg::initFedHandle(), DtAssistantChangeLatencyTestModeMsg::interactionPeriod(), myCmdProc, myFederationNames, DtAssistantChangeLatencyTestModeMsg::numInteractions(), DtAssistantChangeLatencyTestModeMsg::observingResults(), DtAssistantChangeLatencyTestModeMsg::payloadBytes(), DtAssistantChangeLatencyTestModeMsg::runTest(), and DtAssistantChangeLatencyTestModeMsg::shouldHaltContinuous().

void DtRtiexecObserverForAssistant::processLatencyTestResultsMsg ( const DtRtiMsg &  msg, void *  usr  )

static

Callback for latency test results message.

Referenced by addCallbacks(), and removeCallbacks().

void DtRtiexecObserverForAssistant::processLatencyTestResultsMsg ( const DtLatencyReportMsg &  msg )

virtual

Process latency test status message.

References DtRtiMsg::fedExHandle(), DtLatencyReportMsg::get(), myAssistantClient, myExecIsObserved, and DtAveragedLatencyTestReport::setFederationHandle().

void DtRtiexecObserverForAssistant::processLatencyTestStatusMsg ( const DtRtiMsg &  msg, void *  usr  )

static

Callback for latency test status message.

Referenced by addCallbacks(), and removeCallbacks().

void DtRtiexecObserverForAssistant::processLatencyTestStatusMsg ( const DtTestMgrStatusMsg &  msg )

virtual

Process latency test status message.

References DtTestMgrStatusMsg::continuousTesting(), DtRtiMsg::federateHandle(), DtAssistantFederationInfo::federateInfo(), DtRtiMsg::fedExHandle(), myAssistantClient, myExecIsObserved, myFederationNames, myFederations, DtTestMgrStatusMsg::numTestReports(), DtTestMgrStatusMsg::numTestsInitiated(), DtAssistantFederateInfo::setContinuousTest(), DtAssistantFederateInfo::setNumInitiatedTests(), DtAssistantFederateInfo::setNumTestReports(), DtAssistantFederateInfo::setTestEnabled(), DtAssistantFederateInfo::setTestInProgress(), DtTestMgrStatusMsg::testCapable(), DtTestMgrStatusMsg::testingEnabled(), and DtTestMgrStatusMsg::testInProgress().

void DtRtiexecObserverForAssistant::processLogFileUpdatedEvent ( const MAKRti::DtFilename &  logFile )

virtual

Process a log file name update event.

Reimplemented from DtRtiexecObserver.

References myAssistantClient.

void DtRtiexecObserverForAssistant::processLogRequestMsg ( const DtAssistantLogRequestMsg &  msg, void *  usr  )

static

Callback for log request.

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

void DtRtiexecObserverForAssistant::processLogRequestMsg ( const DtAssistantLogRequestMsg &  msg )

virtual

Process log request.

References DtAssistantMsg::isAssistantToAssistantMessage(), DtAssistantLogRequestMsg::maxLogSize(), myAssistantClient, myPrinterBuffer, DtAssistantMsg::sourceAddr(), and DtAssistantMsg::sourceId().

void DtRtiexecObserverForAssistant::processNetworkTestingEnableMsg ( const DtAssistantNetworkTestEnableMsg &  msg, void *  usr  )

static

Callback for networking testing enable/disable command message.

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

void DtRtiexecObserverForAssistant::processNetworkTestingEnableMsg ( const DtAssistantNetworkTestEnableMsg &  msg )

virtual

Process network testing enable/disable command.

References DtAssistantNetworkTestEnableMsg::enableTesting(), DtAssistantNetworkTestEnableMsg::federationHandle(), myCmdProc, and myFederationNames.

void DtRtiexecObserverForAssistant::processNotifyLevelChangeMsg ( const DtAssistantNtfyLvlUpdateMsg &  msg, void *  usr  )

static

Callback for notify level change command message.

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

void DtRtiexecObserverForAssistant::processNotifyLevelChangeMsg ( const DtAssistantNtfyLvlUpdateMsg &  msg )

virtual

Process notify level change command.

References myCmdProc, and DtAssistantNtfyLvlUpdateMsg::notifyLevel().

void DtRtiexecObserverForAssistant::processRidParamRequestMsg ( const DtAssistantRidParamsMsg &  msg, void *  usr  )

static

Callback for RID parameter request.

Referenced by DtRtiexecObserverForAssistant().

void DtRtiexecObserverForAssistant::processRidParamRequestMsg ( const DtAssistantRidParamsMsg &  msg )

virtual

Process RID request.

References DtRIDParameters::getFullPathToRidFile(), myAssistantClient, myParams, and DtRIDParameters::toLispString().

void DtRtiexecObserverForAssistant::processSyncPtAchievedEvent ( DtFedExec *  exec, DtFederate *  federate, DtSyncPt *  pt  )

virtual

Process an existing sync. point achieved event.

Reimplemented from DtRtiexecObserver.

References DtFedExec::fedExName(), DtFederate::getHandle(), DtFederate::getType(), myAssistantClient, myExecIsObserved, myFederations, DtSyncPt::name(), and DtAssistantFederationInfo::syncPoint().

void DtRtiexecObserverForAssistant::processSyncPtRegisteredEvent ( DtFedExec *  exec, DtSyncPt *  pt  )

virtual

Process a new sync. point registered event.

Reimplemented from DtRtiexecObserver.

References false, DtSyncPt::federates(), DtFedExec::federates(), DtFedExec::fedExName(), DtFederate::getHandle(), DtFederateHandleSet::isMember(), myAssistantClient, myExecIsObserved, myFederations, DtSyncPt::name(), DtAssistantFederationInfo::syncPoint(), and DtAssistantFederationInfo::updateSyncPoint().

void DtRtiexecObserverForAssistant::processTimeStateEvent ( const DtRtiExec &  exec, void *  usr  )

static

Callback for periodic time state processing.

Referenced by addCallbacks(), processExecObserveMsg(), and removeCallbacks().

void DtRtiexecObserverForAssistant::processTimeStateEvent ( const DtRtiExec &  exec )

virtual

Process a federate reconnect failed event.

References DtFederate::assistantCompId(), DtAssistantFederationInfo::federateInfo(), DtFedExec::federates(), DtRtiExec::fedExec(), fillFederateTimeStateInfo(), DtFederate::getConnectionHandle(), DtFederate::getFederateHost(), DtFederate::getFederateHostName(), DtFederate::getHandle(), DtFederate::getName(), DtFederate::getType(), DtFederate::hlaVersion(), myAssistantClient, myExecIsObserved, myFederations, myParams, DtRIDParameters::timeMgmt, and DtAssistantFederationInfo::updateFederate().

void DtRtiexecObserverForAssistant::queryForConnectionInfo ( DtRtiConnectionInfoDataPair &  connInfo, DtRtiConnectionConfigurationInfo &  config  )

virtual

Periodic processing.

References DtRIDParameters::DtFomTransportTypeUseFomSettings, DtRIDParameters::forceParametersToCompliance(), myAssistantClient, myForwarderPort, myForwarderToConnectTo, myGotConnInfoFromAssistant, myParams, sendConnectionInfo(), DtRtiConnectionConfigurationInfo::setForceFullCompliance(), DtRIDParameters::setNetworkInterfaceAddr(), DtRIDParameters::setTcpForwarderAddr(), DtRIDParameters::setUseRoutesFile(), and tcpPort.

void DtRtiexecObserverForAssistant::removeCallbacks ( )

protectedvirtual

Removes all RTI message and tick callbacks.

Called when a manager is removed or the observer is destroyed.

Implements DtRtiexecObserver.

References DtLatencyReportMsgKind, DtTestMgrStatusMsgKind, processLatencyTestResultsMsg(), processLatencyTestStatusMsg(), processTimeStateEvent(), DtRtiexecObserver::removeRtiMsgCallback(), DtRtiexecObserver::removeTickCallback(), and tick().

void DtRtiexecObserverForAssistant::sendConnectionInfo ( bool  isConnected )

protectedvirtual

Send the connection info to the assistant.

References DtRIDParameters::destAddr(), DtDefaultInterfaceAddr(), DtRIDParameters::DtFomTransportTypeUseBestEffort, DtRIDParameters::isFullyCompliant(), myAssistantClient, myForwarderPort, myForwarderToConnectTo, myParams, DtRIDParameters::networkInterfaceAddr(), DtRIDParameters::tcpForwarderAddr(), and DtRIDParameters::udpPort.

Referenced by queryForConnectionInfo(), and startObservation().

void DtRtiexecObserverForAssistant::setForwarderInfo ( int  forwarderPort, const MAKRti::DtInetAddr &  forwarderToConnectTo  )

virtual

If we're not querying the assistant, provide some way for the forwarder to indicate what its forwarderConnInfo is.

References myForwarderPort, and myForwarderToConnectTo.

void DtRtiexecObserverForAssistant::startObservation ( )

virtual

Indicates that observation of the exec has begun.

Reimplemented from DtRtiexecObserver.

References sendConnectionInfo().

void DtRtiexecObserverForAssistant::tick ( void *  usr )

static

Callback for periodic processing.

References tick().

void DtRtiexecObserverForAssistant::tick ( )

virtual

Periodic processing.

References myAssistantClient.

Referenced by addCallbacks(), removeCallbacks(), and tick().

Member Data Documentation

bool DtRtiexecObserverForAssistant::myAllowNetworkTesting

protected

Whether or not this rtiexec allows network testing for its federations.

Referenced by initialize(), and processFedExCreatedEvent().

DtBoost::shared_ptr<DtRtiAssistantExecClient> DtRtiexecObserverForAssistant::myAssistantClient

protected

The assistant client.

Referenced by DtRtiexecObserverForAssistant(), initialize(), processDeleteFederateMsg(), processDeleteFederationMsg(), processExecObserveMsg(), processExitCmndMsg(), processFederateDisconnectedEvent(), processFederateJoinedEvent(), processFederateReconnectFailedEvent(), processFederateReconnectSucceededEvent(), processFederateResignedEvent(), processFederationSynchronizedEvent(), processFedExCreatedEvent(), processFedExDestroyedEvent(), processLatencyTestResultsMsg(), processLatencyTestStatusMsg(), processLogFileUpdatedEvent(), processLogRequestMsg(), processRidParamRequestMsg(), processSyncPtAchievedEvent(), processSyncPtRegisteredEvent(), processTimeStateEvent(), queryForConnectionInfo(), sendConnectionInfo(), tick(), and ~DtRtiexecObserverForAssistant().

DtAssistantPrinter* DtRtiexecObserverForAssistant::myAssistantPrinter

protected

The printer which sends notifications to the assistant.

Referenced by disableNotifications(), DtRtiexecObserverForAssistant(), enableNotifications(), processExecObserveMsg(), and ~DtRtiexecObserverForAssistant().

DtBufferPrinter* DtRtiexecObserverForAssistant::myBufferPrinter

protected

The printer which stores all rtiexec output.

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

DtBoost::shared_ptr<DtRtiexecCmdProc> DtRtiexecObserverForAssistant::myCmdProc

protected

Processes commands to be performed by the rtiexec.

Referenced by initialize(), processDeleteFederateMsg(), processDeleteFederationMsg(), processEnableLoggingMsg(), processExitCmndMsg(), processLatencyTestCmndMsg(), processNetworkTestingEnableMsg(), and processNotifyLevelChangeMsg().

bool DtRtiexecObserverForAssistant::myExecIsObserved

protected

Whether or not there is currently an assistant observing this rtiexec.

Referenced by processDeleteFederateMsg(), processDeleteFederationMsg(), processExecObserveMsg(), processFederateDisconnectedEvent(), processFederateJoinedEvent(), processFederateReconnectFailedEvent(), processFederateReconnectSucceededEvent(), processFederateResignedEvent(), processFederationSynchronizedEvent(), processFedExCreatedEvent(), processFedExDestroyedEvent(), processLatencyTestResultsMsg(), processLatencyTestStatusMsg(), processSyncPtAchievedEvent(), processSyncPtRegisteredEvent(), and processTimeStateEvent().

DtFederationNameByHandleMap DtRtiexecObserverForAssistant::myFederationNames

protected

Map of federation handles to names.

Referenced by processDeleteFederateMsg(), processDeleteFederationMsg(), processFedExCreatedEvent(), processFedExDestroyedEvent(), processLatencyTestCmndMsg(), processLatencyTestStatusMsg(), and processNetworkTestingEnableMsg().

DtFederationStateByNameMap DtRtiexecObserverForAssistant::myFederations

protected

Cache the complete state of the federations.

Referenced by processDeleteFederateMsg(), processDeleteFederationMsg(), processExecObserveMsg(), processFederateDisconnectedEvent(), processFederateJoinedEvent(), processFederateReconnectFailedEvent(), processFederateReconnectSucceededEvent(), processFederateResignedEvent(), processFederationSynchronizedEvent(), processFedExCreatedEvent(), processFedExDestroyedEvent(), processLatencyTestStatusMsg(), processSyncPtAchievedEvent(), processSyncPtRegisteredEvent(), and processTimeStateEvent().

bool DtRtiexecObserverForAssistant::myFedReconnectEnabled

protected

Is federate reconnect enabled?

Referenced by initialize(), and processFederateDisconnectedEvent().

int DtRtiexecObserverForAssistant::myForwarderPort

protected

Stored information about the forwarder.

Referenced by queryForConnectionInfo(), sendConnectionInfo(), and setForwarderInfo().

MAKRti::DtInetAddr DtRtiexecObserverForAssistant::myForwarderToConnectTo

protected

Stored information about the forwarder.

Referenced by queryForConnectionInfo(), sendConnectionInfo(), and setForwarderInfo().

bool DtRtiexecObserverForAssistant::myGotConnInfoFromAssistant

protected

Whether or not the assistant supplied connection info.

Referenced by gotConnInfoFromAssistant(), and queryForConnectionInfo().

MAKRti::DtTime DtRtiexecObserverForAssistant::myMinTimeBetweenUpdates

protected

Min. time exec should wait between time state updates.

Referenced by addCallbacks(), and processExecObserveMsg().

DtRIDParameters* DtRtiexecObserverForAssistant::myParams

protected

The RID parameter settings.

Referenced by initialize(), processRidParamRequestMsg(), processTimeStateEvent(), queryForConnectionInfo(), and sendConnectionInfo().

DtBoost::shared_ptr<DtPrinterBuf> DtRtiexecObserverForAssistant::myPrinterBuffer

protected

Buffer which the buffer printer writes to.

Referenced by DtRtiexecObserverForAssistant(), and processLogRequestMsg().

---

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

• execObserverForAssistant.h
• execObserverForAssistant.cxx