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:

List of all members.

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.
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, const DtFedExec &fedExec, const MAKRti::DtInetAddr &fedWebServHost, int fedWebServPort)
	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.
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	processWebServerUpdatedEvent (const MAKRti::DtInetAddr &webSpyIpAddr, int webSpyPort)
	Process a web server 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

(

)

[protected, virtual]

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,
		const DtFedExec &	fedExec,
		const MAKRti::DtInetAddr &	fedWebServHost,
		int	fedWebServPort
	)		[protected]

Fills in the federate time state using the given information.

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

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 DtFedExec::init(), myAllowNetworkTesting, myAssistantClient, myCmdProc, myFedReconnectEnabled, and myParams.

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, 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(), DtFedExec::fedExName(), fillFederateTimeStateInfo(), DtAssistantFederationInfo::fomModules(), DtFedExec::fomModules(), DtFederate::getConnectionHandle(), DtFederate::getFederateHost(), DtFederate::getFederateHostName(), DtFederate::getHandle(), DtFederate::getName(), DtFederate::getType(), DtFederate::getWebServerHost(), DtFederate::getWebServerPort(), 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 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 DtAssistantFederationInfo::federateInfo(), DtFedExec::federates(), DtRtiExec::fedExec(), fillFederateTimeStateInfo(), DtFederate::getConnectionHandle(), DtFederate::getFederateHost(), DtFederate::getFederateHostName(), DtFederate::getHandle(), DtFederate::getName(), DtFederate::getType(), DtFederate::getWebServerHost(), DtFederate::getWebServerPort(), DtFederate::hlaVersion(), myAssistantClient, myExecIsObserved, myFederations, myParams, and DtAssistantFederationInfo::updateFederate().

void DtRtiexecObserverForAssistant::processWebServerUpdatedEvent	(	const MAKRti::DtInetAddr &	webSpyIpAddr,
		int	webSpyPort
	)		[virtual]

Process a web server update event.

Reimplemented from DtRtiexecObserver.

References myAssistantClient.

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

Periodic processing.

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

void DtRtiexecObserverForAssistant::removeCallbacks

(

)

[protected, virtual]

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

)

[protected, virtual]

Send the connection info to the assistant.

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

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(), processWebServerUpdatedEvent(), 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