latencyTestMgr.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2009 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: latencyTestMgr.h,v $ $Revision: 1.4 $ $State: Exp $
*********************************************************************/

#ifndef latencyTestMgr_H_
#define latencyTestMgr_H_


#include "rtiMsConfig.h"
#include "assistantMgr.h"
#include "componentMgr.h"
#include "assistantInfo.h"

class DtRtiAssistantServer;
class DtRtiAssistantPeer;
class DtAveragedLatencyTestReport;
class DtLatencyTestDialog;
class DtAssistantLatencyReportMsg;
class DtAssistantTestMgrStatusMsg;
class DtAssistantChangeLatencyTestModeMsg;
class DtRtiConnectionAndConfiguration;
class DtAssistantConnectionInfoMgr;
class DtAssistantSignalRouter;
class DtAssistantFederationsInfoMgr;

class DT_DLL_ASSISTANTAPP DtAssistantLatencyTestMgr : public DtAssistantMgr
{
   Q_OBJECT

public:

   DtAssistantLatencyTestMgr( std::shared_ptr<DtRtiAssistantServer> server,
      std::shared_ptr<DtRtiAssistantPeer> peer,
      DtAssistantSignalRouter& signalRouter,
      std::shared_ptr<DtAssistantComponentMgr> compMgr,
      std::shared_ptr<DtAssistantConnectionInfoMgr> connInfoMgr,
      std::shared_ptr<DtAssistantFederationsInfoMgr> fedInfoMgr );

   virtual ~DtAssistantLatencyTestMgr();

private:

   DtAssistantLatencyTestMgr(DtAssistantLatencyTestMgr const& );

   DtAssistantLatencyTestMgr& operator= (DtAssistantLatencyTestMgr const& );

protected:



   static void processLatencyTestResults( const DtAssistantLatencyReportMsg& msg, void* usr );

   virtual void processLatencyTestResults(const DtAssistantLatencyReportMsg& msg);

   static void processTestMgrStatusUpdate( const DtAssistantTestMgrStatusMsg& msg, void* usr );   

   virtual void processTestMgrStatusUpdate( const DtAssistantTestMgrStatusMsg& msg );

   static void processTestCommand( const DtAssistantChangeLatencyTestModeMsg& msg, void* usr );

   virtual void processTestCommand( const DtAssistantChangeLatencyTestModeMsg& msg );


   bool getRtiexecConn( const DtAssistantMsg& msg, DtRtiConnectionInfoDataPair& exec );

   bool sendLatencyTestCommand( bool runTest, bool continuous, bool shouldHalt,
      bool observing );

   bool verifyNewTestCanBeRun();

signals:

   void updateLatencyTestInteractionPeriod( unsigned int );

   void updateLatencyTestNumInteractions( unsigned int );

   void updateLatencyTestPayloadBytes( unsigned int );

   void disableComponentLatencyTest( int );

   void enableComponentLatencyTest( int );

public slots:

   void processConnectionsUpdate( const DtRtiConnectionAndConfiguration& conns );

   void processConnectionsRemoval( const DtRtiConnectionAndConfiguration& conns );

   void showLrcLatencyTestDialog( int id );

   void showRtiexecLatencyTestDialog( const DtRtiConnectionInfoDataPair&, 
      unsigned int federationHdl, const MAKRti::DtString& federationName,
      unsigned int federateHdl);

   void processLatencyTestObserve();

   void processLatencyTestDismiss();

   void initiateLatencyTest();

   void initiateContinuousLatencyTest();

   void haltContinuousLatencyTest();

   void renameComponent( const DtAssistantComponentInfo* );

   void removeLrcComponent( const DtAssistantComponentInfo* );

   void updateFederateTestStatus( const DtRtiConnectionInfo& conn, 
      const MAKRti::DtString& federationName, unsigned federateHandle );

   void updateLatencyTestConfig( unsigned int interactionPeriod, 
      unsigned int numInteractions, unsigned int payloadBytes );

   // Updates the period between latency test interactions
   void setLatencyTestInteractionPeriod( unsigned int );

   // Updates the number of interactions per latency test
   void setLatencyTestNumInteractions( unsigned int );

   // Updates the size of a latency test interaction payload in bytes
   void setLatencyTestPayloadBytes( unsigned int );

protected:

   std::shared_ptr<DtAssistantComponentMgr> myCompMgr;

   std::shared_ptr<DtAssistantConnectionInfoMgr> myConnInfoMgr;

   std::shared_ptr<DtAssistantFederationsInfoMgr> myFedInfoMgr;

   DtLatencyTestDialog* myLatencyTestDialog;

   typedef std::map< DtRtiConnectionInfo, DtAssistantInfoSet > DtRtiexecToObserversMap;
   DtRtiexecToObserversMap myRemotelyObservedRtiexecs;

   bool myTestViaRtiexec;

   int myLrcCompId;

   DtRtiConnectionInfo myRtiexecConn;

   unsigned int myFederationHdl;

   MAKRti::DtString myFederationName;

   unsigned int myInitFederateHdl;

   unsigned int myInteractionPeriod;
   unsigned int myNumInteractions;
   unsigned int myPayloadBytes;

};

#endif