execObserverForAssistant.h

Go to the documentation of this file.

/*******************************************************************************
** Copyright (c) 2008 MaK Technologies, Inc.
** All rights reserved.
*******************************************************************************/
/*******************************************************************************
** $RCSfile: execObserverForAssistant.h,v $ $Revision: 1.11 $ $State: Exp $
*******************************************************************************/



#ifndef execObserverForAssistant_H_
#define execObserverForAssistant_H_

#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,
      DtBoost::shared_ptr<DtRtiexecCmdProc> cmdProc );

   virtual void startObservation();



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

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

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

   virtual void processWebServerUpdatedEvent( const MAKRti::DtInetAddr& webSpyIpAddr,
      int webSpyPort );

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

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,
      const MAKRti::DtInetAddr& fedWebServHost, int fedWebServPort );

   virtual void sendConnectionInfo( bool isConnected );
   
protected:

   DtBoost::shared_ptr<DtRtiAssistantExecClient> myAssistantClient;

   DtAssistantPrinter* myAssistantPrinter;

   DtBufferPrinter* myBufferPrinter;

   DtBoost::shared_ptr<DtPrinterBuf> myPrinterBuffer;

   DtBoost::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;
}

#endif