Handles activities related to running latency tests and reporting results. More...

Inheritance diagram for DtAssistantLatencyTestMgr:

Collaboration diagram for DtAssistantLatencyTestMgr:

Public Slots
void	processConnectionsUpdate (const DtRtiConnectionAndConfiguration &conns)
	Makes sure updated connections are not for shutdown of the rtiexec used in testing.
void	processConnectionsRemoval (const DtRtiConnectionAndConfiguration &conns)
	Makes sure removed connections are not for rtiexec.
void	showLrcLatencyTestDialog (int id)
	Display the latency test dialog for the LRC component.
void	showRtiexecLatencyTestDialog (const DtRtiConnectionInfoDataPair &, unsigned int federationHdl, const MAKRti::DtString &federationName, unsigned int federateHdl)
	Display the latency test dialog for the rtiexec component.
void	processLatencyTestObserve ()
	Processes notification from a latency test dialog that it would like to receive test reports.
void	processLatencyTestDismiss ()
	Processes the dismissal of the latency test dialog.
void	initiateLatencyTest ()
	Initiates a latency test for the selected component.
void	initiateContinuousLatencyTest ()
	Initiate a continuous latency test for the selected component.
void	haltContinuousLatencyTest ()
	Stop a continuous latency test for the selected component.
void	renameComponent (int id)
	Renames an existing component.
void	removeLrcComponent (int id)
	Removes an existing LRC component and its current latency test.
void	updateFederateTestStatus (const DtRtiConnectionInfo &conn, const MAKRti::DtString &federationName, unsigned federateHandle)
	Updates the test status of the given federate.
void	updateLatencyTestConfig (unsigned int interactionPeriod, unsigned int numInteractions, unsigned int payloadBytes)
	Updates the latency test configuration with the given values.
void	setLatencyTestInteractionPeriod (unsigned int)
void	setLatencyTestNumInteractions (unsigned int)
void	setLatencyTestPayloadBytes (unsigned int)
Public Member Functions
	DtAssistantLatencyTestMgr (DtBoost::shared_ptr< DtRtiAssistantServer > server, DtBoost::shared_ptr< DtRtiAssistantPeer > peer, DtBoost::shared_ptr< DtAssistantPreferencesInfoMgr > prefMgr, DtBoost::shared_ptr< DtAssistantComponentMgr > compMgr, DtBoost::shared_ptr< DtAssistantConnectionInfoMgr > connInfoMgr, DtBoost::shared_ptr< DtAssistantFederationsInfoMgr > fedInfoMgr, DtBoost::shared_ptr< DtAssistantTrayIconMgr > trayIconMgr)
	Constructor.
virtual	~DtAssistantLatencyTestMgr ()
	Destructor.
Protected Types
typedef std::map < DtRtiConnectionInfo, DtAssistantInfoSet >	DtRtiexecToObserversMap
Protected Member Functions
bool	getRtiexecConn (const DtAssistantMsg &msg, DtRtiConnectionInfoDataPair &exec)
	Fills in the rtiexec connection info based on the message.
bool	sendLatencyTestCommand (bool runTest, bool continuous, bool shouldHalt, bool observing)
	Send latency test command message for the currently displayed test.
bool	verifyNewTestCanBeRun ()
	Verifies that either no test is currently being run or checks with user.
Protected Attributes
DtBoost::shared_ptr < DtAssistantPreferencesInfoMgr >	myPrefMgr
	The manager that keeps track of Assistant preferences.
DtBoost::shared_ptr < DtAssistantComponentMgr >	myCompMgr
	The manager that keeps track of all local RTI components.
DtBoost::shared_ptr < DtAssistantConnectionInfoMgr >	myConnInfoMgr
	The manager that keeps track of all known RTI connections.
DtBoost::shared_ptr < DtAssistantFederationsInfoMgr >	myFedInfoMgr
	The manager that keeps track of all known federations.
DtBoost::shared_ptr < DtAssistantTrayIconMgr >	myTrayIconMgr
	The manager that handles interactions with the tray icon and its menu.
DtLatencyTestDialog *	myLatencyTestDialog
	The latency test dialogs.
DtRtiexecToObserversMap	myRemotelyObservedRtiexecs
	List of local rtiexecs and the remote assistants who are observing tests that they are coordinating.
bool	myTestViaRtiexec
	Indicates whether the currently displayed latency test is for a test being conducted through an rtiexec.
int	myLrcCompId
	The local component ID of the LRC initiating the test (only used if myTestViaRtiexec == false)
DtRtiConnectionInfo	myRtiexecConn
	Connection parameters of the rtiexec through which the test is being run (only used if myIsForRtiexec == true)
unsigned int	myFederationHdl
	The federation handle of this test (only used if myIsForRtiexec == true)
MAKRti::DtString	myFederationName
	The federation name of this test (only used if myIsForRtiexec == true)
unsigned int	myInitFederateHdl
	The initiating federate of this test (only used if myIsForRtiexec == true)

unsigned int	myInteractionPeriod
	Latency test parameters.
unsigned int	myNumInteractions
	Latency test parameters.
unsigned int	myPayloadBytes
	Latency test parameters.
Private Member Functions
	DtAssistantLatencyTestMgr (DtAssistantLatencyTestMgr const &)
	Copy Constructor not implemented -- Copy Not Allowed!
DtAssistantLatencyTestMgr &	operator= (DtAssistantLatencyTestMgr const &)
	Assignment not implemented -- Assignment Not Allowed!
Message Callbacks
Callbacks for latency testing messages
static void	processLatencyTestResults (const DtAssistantLatencyReportMsg &msg, void *usr)
	Callback to process a latency test results msg.
static void	processTestMgrStatusUpdate (const DtAssistantTestMgrStatusMsg &msg, void *usr)
	Callback to process a test status message from a local LRC component.
static void	processTestCommand (const DtAssistantChangeLatencyTestModeMsg &msg, void *usr)
	Callback to process a test command message.
virtual void	processLatencyTestResults (const DtAssistantLatencyReportMsg &msg)
	Called by the callback function to process latency results messages.
virtual void	processTestMgrStatusUpdate (const DtAssistantTestMgrStatusMsg &msg)
	Called by the callback function to process testMgr status messages from local LRC components.
virtual void	processTestCommand (const DtAssistantChangeLatencyTestModeMsg &msg)
	Called by the callback function to process a test command message.

Detailed Description

Handles activities related to running latency tests and reporting results.

Member Typedef Documentation

typedef std::map< DtRtiConnectionInfo, DtAssistantInfoSet > DtAssistantLatencyTestMgr::DtRtiexecToObserversMap [protected]

Constructor & Destructor Documentation

DtAssistantLatencyTestMgr::DtAssistantLatencyTestMgr	(	DtBoost::shared_ptr< DtRtiAssistantServer >	server,
		DtBoost::shared_ptr< DtRtiAssistantPeer >	peer,
		DtBoost::shared_ptr< DtAssistantPreferencesInfoMgr >	prefMgr,
		DtBoost::shared_ptr< DtAssistantComponentMgr >	compMgr,
		DtBoost::shared_ptr< DtAssistantConnectionInfoMgr >	connInfoMgr,
		DtBoost::shared_ptr< DtAssistantFederationsInfoMgr >	fedInfoMgr,
		DtBoost::shared_ptr< DtAssistantTrayIconMgr >	trayIconMgr
	)

Constructor.

References DtAssistantLatencyReportMsg::addCallback(), DtAssistantTestMgrStatusMsg::addCallback(), DtAssistantChangeLatencyTestModeMsg::addCallback(), connect(), haltContinuousLatencyTest(), initiateContinuousLatencyTest(), initiateLatencyTest(), myCompMgr, myConnInfoMgr, myFedInfoMgr, myLatencyTestDialog, DtAssistantMgr::myPeer, myPrefMgr, DtAssistantMgr::myServer, myTrayIconMgr, processConnectionsRemoval(), processConnectionsUpdate(), processLatencyTestDismiss(), processLatencyTestObserve(), processLatencyTestResults(), processTestCommand(), processTestMgrStatusUpdate(), removeLrcComponent(), renameComponent(), setLatencyTestInteractionPeriod(), setLatencyTestNumInteractions(), setLatencyTestPayloadBytes(), showLrcLatencyTestDialog(), DtAssistantMgr::startDialog(), updateFederateTestStatus(), and updateLatencyTestConfig().

DtAssistantLatencyTestMgr::~DtAssistantLatencyTestMgr ( ) [virtual]

Destructor.

References DtAssistantMgr::myPeer, DtAssistantMgr::myServer, processLatencyTestResults(), processTestCommand(), processTestMgrStatusUpdate(), DtAssistantLatencyReportMsg::removeCallback(), DtAssistantTestMgrStatusMsg::removeCallback(), and DtAssistantChangeLatencyTestModeMsg::removeCallback().

DtAssistantLatencyTestMgr::DtAssistantLatencyTestMgr ( DtAssistantLatencyTestMgr const & ) [private]

Copy Constructor not implemented -- Copy Not Allowed!

Member Function Documentation

bool DtAssistantLatencyTestMgr::getRtiexecConn	(	const DtAssistantMsg &	msg,
		DtRtiConnectionInfoDataPair &	exec
	)		`[protected]`

Fills in the rtiexec connection info based on the message.

References DtAssistantComponentInfo::compId(), DtAssistantMsg::compId(), DtAssistantComponentInfo::compType(), DtAssistantComponentInfo::connUsed(), DtAssistantRtiexecComponent, DtAssistantMsg::isAssistantToAssistantMessage(), myCompMgr, myConnInfoMgr, DtAssistantMgr::myPeer, DtAssistantMgr::myServer, DtAssistantInfo::setAddress(), DtAssistantInfo::setId(), DtAssistantInfo::setNetworkInterfaceAddress(), DtAssistantMsg::sourceAddr(), DtAssistantMsg::sourceHost(), and DtAssistantMsg::sourceId().

Referenced by processLatencyTestResults().

void DtAssistantLatencyTestMgr::haltContinuousLatencyTest ( ) [slot]

Stop a continuous latency test for the selected component.

If one is not running, this is a nop at the component endpoint.

References sendLatencyTestCommand().

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::initiateContinuousLatencyTest ( ) [slot]

Initiate a continuous latency test for the selected component.

References sendLatencyTestCommand().

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::initiateLatencyTest ( ) [slot]

Initiates a latency test for the selected component.

References sendLatencyTestCommand().

Referenced by DtAssistantLatencyTestMgr().

DtAssistantLatencyTestMgr& DtAssistantLatencyTestMgr::operator= ( DtAssistantLatencyTestMgr const & ) [private]

Assignment not implemented -- Assignment Not Allowed!

void DtAssistantLatencyTestMgr::processConnectionsRemoval ( const DtRtiConnectionAndConfiguration & conns ) [slot]

Makes sure removed connections are not for rtiexec.

References DtRtiConnectionAndConfiguration::connections(), DtLatencyTestDialog::indicateRtiexecShutdown(), myLatencyTestDialog, myRtiexecConn, and myTestViaRtiexec.

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::processConnectionsUpdate ( const DtRtiConnectionAndConfiguration & conns ) [slot]

Makes sure updated connections are not for shutdown of the rtiexec used in testing.

References DtRtiConnectionAndConfiguration::connections(), DtLatencyTestDialog::indicateRtiexecShutdown(), myLatencyTestDialog, myRtiexecConn, and myTestViaRtiexec.

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::processLatencyTestDismiss ( ) [slot]

Processes the dismissal of the latency test dialog.

References DtRtiConnectionInfo::invalidConn(), myLrcCompId, myRemotelyObservedRtiexecs, myRtiexecConn, myTestViaRtiexec, and sendLatencyTestCommand().

Referenced by DtAssistantLatencyTestMgr(), and verifyNewTestCanBeRun().

void DtAssistantLatencyTestMgr::processLatencyTestObserve ( ) [slot]

Processes notification from a latency test dialog that it would like to receive test reports.

References sendLatencyTestCommand().

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::processLatencyTestResults	(	const DtAssistantLatencyReportMsg &	msg,
		void *	usr
	)		`[static, protected]`

Callback to process a latency test results msg.

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

void DtAssistantLatencyTestMgr::processLatencyTestResults ( const DtAssistantLatencyReportMsg & msg ) [protected, virtual]

Called by the callback function to process latency results messages.

void DtAssistantLatencyTestMgr::processTestCommand	(	const DtAssistantChangeLatencyTestModeMsg &	msg,
		void *	usr
	)		`[static, protected]`

Callback to process a test command message.

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

void DtAssistantLatencyTestMgr::processTestCommand ( const DtAssistantChangeLatencyTestModeMsg & msg ) [protected, virtual]

Called by the callback function to process a test command message.

void DtAssistantLatencyTestMgr::processTestMgrStatusUpdate	(	const DtAssistantTestMgrStatusMsg &	msg,
		void *	usr
	)		`[static, protected]`

Callback to process a test status message from a local LRC component.

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

void DtAssistantLatencyTestMgr::processTestMgrStatusUpdate ( const DtAssistantTestMgrStatusMsg & msg ) [protected, virtual]

Called by the callback function to process testMgr status messages from local LRC components.

References DtAssistantComponentInfo::compType(), DtAssistantTestMgrStatusMsg::continuousTesting(), DtAssistantLrcComponent, myCompMgr, myLatencyTestDialog, myLrcCompId, DtAssistantMgr::myServer, myTestViaRtiexec, myTrayIconMgr, DtAssistantTestMgrStatusMsg::testCapable(), DtAssistantTestMgrStatusMsg::testingEnabled(), DtAssistantTestMgrStatusMsg::testInProgress(), and DtLatencyTestDialog::updateStatus().

void DtAssistantLatencyTestMgr::removeLrcComponent ( int id ) [slot]

Removes an existing LRC component and its current latency test.

References DtLatencyTestDialog::indicateFederateResigned(), myLatencyTestDialog, myLrcCompId, and myTestViaRtiexec.

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::renameComponent ( int id ) [slot]

Renames an existing component.

References myCompMgr, myLatencyTestDialog, myLrcCompId, myTestViaRtiexec, DtAssistantComponentInfo::name(), and DtLatencyTestDialog::setName().

Referenced by DtAssistantLatencyTestMgr().

bool DtAssistantLatencyTestMgr::sendLatencyTestCommand	(	bool	runTest,
		bool	continuous,
		bool	shouldHalt,
		bool	observing
	)		`[protected]`

Send latency test command message for the currently displayed test.

References myCompMgr, myConnInfoMgr, myFederationHdl, myInitFederateHdl, myInteractionPeriod, myLrcCompId, myNumInteractions, myPayloadBytes, DtAssistantMgr::myPeer, myRtiexecConn, DtAssistantMgr::myServer, and myTestViaRtiexec.

Referenced by haltContinuousLatencyTest(), initiateContinuousLatencyTest(), initiateLatencyTest(), processLatencyTestDismiss(), and processLatencyTestObserve().

void DtAssistantLatencyTestMgr::setLatencyTestInteractionPeriod ( unsigned int period ) [slot]

References myInteractionPeriod, and period.

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::setLatencyTestNumInteractions ( unsigned int num ) [slot]

References myNumInteractions.

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::setLatencyTestPayloadBytes ( unsigned int bytes ) [slot]

References myPayloadBytes.

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::showLrcLatencyTestDialog ( int id ) [slot]

Display the latency test dialog for the LRC component.

References DtAssistantComponentInfo::compType(), DtAssistantLrcComponent, myCompMgr, myInteractionPeriod, myLatencyTestDialog, myLrcCompId, myNumInteractions, myPayloadBytes, myTestViaRtiexec, DtAssistantComponentInfo::name(), DtLatencyTestDialog::setName(), DtLatencyTestDialog::setTestConfig(), DtAssistantMgr::showDialog(), and verifyNewTestCanBeRun().

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::showRtiexecLatencyTestDialog	(	const DtRtiConnectionInfoDataPair &	exec,
		unsigned int	federationHdl,
		const MAKRti::DtString &	federationName,
		unsigned int	federateHdl
	)		`[slot]`

Display the latency test dialog for the rtiexec component.

References federationName(), myConnInfoMgr, myFederationHdl, myFederationName, myInitFederateHdl, myInteractionPeriod, myLatencyTestDialog, myNumInteractions, myPayloadBytes, myRtiexecConn, myTestViaRtiexec, DtLatencyTestDialog::setName(), DtLatencyTestDialog::setTestConfig(), DtAssistantMgr::showDialog(), and verifyNewTestCanBeRun().

void DtAssistantLatencyTestMgr::updateFederateTestStatus	(	const DtRtiConnectionInfo &	conn,
		const MAKRti::DtString &	federationName,
		unsigned	federateHandle
	)		`[slot]`

Updates the test status of the given federate.

References DtAssistantFederateInfo::continuousTest(), myFederationName, myFedInfoMgr, myInitFederateHdl, myLatencyTestDialog, myRtiexecConn, myTestViaRtiexec, DtAssistantFederateInfo::testEnabled(), DtAssistantFederateInfo::testInProgress(), and DtLatencyTestDialog::updateStatus().

Referenced by DtAssistantLatencyTestMgr().

void DtAssistantLatencyTestMgr::updateLatencyTestConfig	(	unsigned int	interactionPeriod,
		unsigned int	numInteractions,
		unsigned int	payloadBytes
	)		`[slot]`