execObserverForAssistant.h

Go to the documentation of this file.

/****************************************************************************
 * Copyright (c) 2016 VT MAK
 * All rights reserved.
 ****************************************************************************/


#pragma once

#include "execObserver.h"
#include "execCmdProc.h"
#include <rtiMsConfig.h>
#include <vlutil/vlUtil.h>
#include <vlutil/vlTime.h>
#include <vlutil/vlInetAddr.h>
#include <RIDparams.h>
#include <testMgrStatusMsg.h>
#include <latencyReportMsg.h>
#include <federationInfo.h>
#include <assistantConnectionInfo.h>
#include <map>
#include <vector>
#include <list>

class DtRtiMsg;
class DtRtiAssistantExecClient;
class DtAssistantPrinter;
class DtBufferPrinter;
class DtPrinterBuf;
class DtAssistantLogEnableMsg;
class DtAssistantNtfyLvlUpdateMsg;
class DtAssistantExitMsg;
class DtAssistantStateObserveMsg;
class DtAssistantDeleteFederateMsg;
class DtAssistantDeleteFederationMsg;
class DtAssistantNetworkTestEnableMsg;
class DtAssistantChangeLatencyTestModeMsg;
class DtAssistantRidParamsMsg;
class DtAssistantLogRequestMsg;
class DtRtiConnectionInfo;
class DtRtiConnectionConfigurationInfo;

class DT_DLL_EXEC DtRtiexecObserverForAssistant : public DtRtiexecObserver
{
public:

   DtRtiexecObserverForAssistant();

   virtual ~DtRtiexecObserverForAssistant();

   virtual void initialize( DtRIDParameters* params,
      std::shared_ptr<DtRtiexecCmdProc> cmdProc );

   virtual void startObservation();


   static void tick( void* usr );

   virtual void tick();


   virtual void queryForConnectionInfo( DtRtiConnectionInfoDataPair& connInfo,
      DtRtiConnectionConfigurationInfo& config );

   virtual void performParameterOverrides( DtRIDParameters& ridParams ) const;

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

   virtual void enableNotifications();

   virtual void disableNotifications();


   virtual void processFedExCreatedEvent( DtFedExec* exec );

   virtual void processFedExDestroyedEvent( DtFedExec* exec );

   virtual void processFederateJoinedEvent( DtFedExec* exec, DtFederate* federate );

   virtual void processFederateResignedEvent( DtFedExec* exec, DtFederate* federate );

   virtual void processSyncPtRegisteredEvent( DtFedExec* exec, DtSyncPt* pt );

   virtual void processFederationSynchronizedEvent( DtFedExec* exec, DtSyncPt* pt );

   virtual void processSyncPtAchievedEvent( DtFedExec* exec, DtFederate* federate, DtSyncPt* pt );

   virtual void processFederateDisconnectedEvent( DtFedExec* exec, DtFederate* federate );

   virtual void processFederateReconnectSucceededEvent( DtFedExec* exec, DtFederate* federate );

   virtual void processFederateReconnectFailedEvent( DtFedExec* exec, DtFederate* federate );

   virtual void processLogFileUpdatedEvent( const MAKRti::DtFilename& logFile );

   static void processTimeStateEvent( const DtRtiExec& exec, void* usr );
   virtual void processTimeStateEvent( const DtRtiExec& exec );



   static void processLatencyTestStatusMsg( const DtRtiMsg& msg, void* usr );
   virtual void processLatencyTestStatusMsg( const DtTestMgrStatusMsg& msg );

   static void processLatencyTestResultsMsg( const DtRtiMsg& msg, void* usr );
   virtual void processLatencyTestResultsMsg( const DtLatencyReportMsg& msg );



   static void processExecObserveMsg( const DtAssistantStateObserveMsg& msg, void* usr );
   virtual void processExecObserveMsg( const DtAssistantStateObserveMsg& msg );

   static void processDeleteFederateMsg( const DtAssistantDeleteFederateMsg& msg, void* usr );
   virtual void processDeleteFederateMsg( const DtAssistantDeleteFederateMsg& msg );

   static void processDeleteFederationMsg( const DtAssistantDeleteFederationMsg& msg, void* usr );
   virtual void processDeleteFederationMsg( const DtAssistantDeleteFederationMsg& msg );

   static void processEnableLoggingMsg( const DtAssistantLogEnableMsg& msg, void* usr );
   virtual void processEnableLoggingMsg( const DtAssistantLogEnableMsg& msg );

   static void processNotifyLevelChangeMsg( const DtAssistantNtfyLvlUpdateMsg& msg, void* usr );
   virtual void processNotifyLevelChangeMsg( const DtAssistantNtfyLvlUpdateMsg& msg );

   static void processNetworkTestingEnableMsg( const DtAssistantNetworkTestEnableMsg& msg, void* usr );
   virtual void processNetworkTestingEnableMsg( const DtAssistantNetworkTestEnableMsg& msg );

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

   static void processRidParamRequestMsg( const DtAssistantRidParamsMsg& msg, void* usr );
   virtual void processRidParamRequestMsg( const DtAssistantRidParamsMsg& msg );

   static void processLogRequestMsg( const DtAssistantLogRequestMsg& msg, void* usr );
   virtual void processLogRequestMsg( const DtAssistantLogRequestMsg& msg );

   static void processExitCmndMsg( const DtAssistantExitMsg& msg, void* usr );
   virtual void processExitCmndMsg( const DtAssistantExitMsg& msg );

   static void processAssistantDisconnect( void* usr );
   virtual void processAssistantDisconnect();


   bool gotConnInfoFromAssistant();

   virtual void sendTrayNotification( const MAKRti::DtString& text, DtNotifyLevelType notifyLevel );

   inline const DtRIDParameters* ridParams() const { return myParams; }
   inline DtRIDParameters* ridParams() { return myParams; }

protected:

   virtual void addCallbacks();

   virtual void removeCallbacks();

   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 );

   virtual void sendConnectionInfo( bool isConnected );

protected:

   std::shared_ptr<DtRtiAssistantExecClient> myAssistantClient;

   DtAssistantPrinter* myAssistantPrinter;

   DtBufferPrinter* myBufferPrinter;

   std::shared_ptr<DtPrinterBuf> myPrinterBuffer;

   std::shared_ptr<DtRtiexecCmdProc> myCmdProc;

   bool myFedReconnectEnabled;

   bool myAllowNetworkTesting;

   DtFederationStateByNameMap myFederations;

   DtFederationNameByHandleMap myFederationNames;

   MAKRti::DtTime myMinTimeBetweenUpdates;

   bool myGotConnInfoFromAssistant;

   bool myExecIsObserved;

   DtRIDParameters* myParams;


   int myForwarderPort;
   MAKRti::DtInetAddr myForwarderToConnectTo;


};


inline bool DtRtiexecObserverForAssistant::gotConnInfoFromAssistant()
{
   return myGotConnInfoFromAssistant;
}