vrfDriver.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2015 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/



#pragma once

#include <vrfGuiCore/guiThreadVrfRemoteController.h>
#include <vrfGuiCore/sharedNetworkSignaler.h>
#include <vrvVrl/DtConnection.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrfVrlSharedSource/vrfProtocol.h>
#include <vrfVrlSharedSource/DtVrfEnvironmentProcessor.h>
#include <vrfVrlSharedSource/vrfAggregateProcessor.h>
#include <vrfVrlSharedSource/extendedStateDataProcessor.h>
#include <vrfVrlSharedSource/stateCacheManager.h>
#include <vrfcontrol/vrfRemoteController.h>
#include <vrfmsgs/ifSavedSimulationObjectGroup.h>

#include <vrvVrl/DtVrlinkConnection.h>

#include <vlpi/entityType.h>
#include <matrix/vlVector.h>

#include <vrfutil/scenario.h>

#include <vl/commentInteraction.h>

#if DtHLA
#include <vrfExtObjects/influenceInteractionHLA.h>
#endif

class DtVrfObjectMessage;

class DtVrfRemoteController;
class DtVrfMessageInterface;
class DtScenarioLoadInformation;
class DtSetDataRequest;
class DtSimTask;
class DtSimInterfaceContent;
class DtRemoteLoggerController;
class DtAddressMap;
class DtBackendMap;

#if DtDIS
#define DtCommentCallbackFcn DtCommentPduCb
#elif DtHLA
#define DtCommentCallbackFcn DtCommentInteractionCb
#endif

namespace makVrv
{
   class DtVrlinkElement;

   namespace DT_PROTOCOL_NAMESPACE
   {
      class DtVrlinkEntityStateListener;
      class DtAggregateElement;
      class DtEntityElement;
      class DtEntitySimDataProcessor;
   }
}

namespace makVrf 
{
   class DtNetworkMessageInterface;
   class DtNetworkMessageInterfaceHandlerAgent;

   namespace VRF_PROTOCOL_NAMESPACE
   {
      class DtVrfBackendInterceptor;
      class DtVrfConnectionHelper;
      class DtVrfObjectDataStateProcessor;
      class DtVrfWeatherStateProcessor;
      class DtVrfEnvironmentObjectDataStateProcessor;
      class DtEnvironmentSimDataProcessor;
      class DtEmitterSystemSimDataProcessor;
      class DtActiveSonarSimDataProcessor;
      class DtVrfAggregateObjectDataStateProcessor;
      class DtAggregateSimDataProcessor;
      class DtVrfFogOfWarHandler;
      class DtVrfEmbarkationProcessor;
      class DtIffSimDataProcessor;
      class DtPropulsionNoiseSimDataProcessor;
      class DtWeatherStateCacheManager;
      class DtVrfWeatherProcessor;
      class DtSensorFieldOfViewSimDataProcessor;

      class VRF_PROTOCOL_EXPORT DtVrfDriver : public VRF_DRIVER_BASE_CLASS
      {
      public:
         DtVrfDriver(makVrv::DtAgentManager& agentManager, const std::string& uniqueName);

         virtual ~DtVrfDriver();

      public:
         virtual bool onStart();

      public:
         virtual void realizeConfiguration(const makVrv::DtConfiguration& config);

         virtual void sendLoggerSetFilename(std::string filename);

         virtual void sendLoggerRecordMessage();

         virtual void sendLoggerStopMessage();

         virtual void newScenario(const DtScenario*, time_t startTimeOfDay = 12 * 3600);

         virtual void loadScenario(const DtScenarioLoadInformation*, bool deleteMemory = false);

         virtual void saveScenario(const DtScenario*, DtPreserveMappingsFcn fcn = 0, void* userData = 0,
            bool queueSave = false, int putIntoPlayMode = 0, bool deleteMemory = false);

         virtual void saveCheckpoints(const std::vector<DtScenario*>&, const DtFilename& baseName);

         virtual void saveNextCheckpoint();

         virtual void clearSavingCheckpoints();

         virtual void closeScenario(DtFilename, bool forceCloseAll = false);

         virtual void createEnvironmentalObject(DtSimulationAddress addr,
            DtSharedNetworkSignaler::EnvironmentalSignalCreationData sigData);

         virtual void getMessageFilterStatus(std::map<std::string,bool>& statusMap) const;

         virtual void setMessageFilterStatus(const std::map<std::string,bool>& statusMap);

         virtual void getMessageProcessorStatus(std::map<std::string,bool>& statusMap) const;

         virtual void setMessageProcessorStatus(const std::map<std::string,bool>& statusMap);

         virtual void registerSimMessageCallbackFor(int t, bool reg);

         virtual void registerSimReportMessageCallbackFor(const DtSimReportMessageType& s, bool reg);

         virtual void registerSimTaskMessageCallbackFor(const DtSimTaskMessageType& s, bool reg);

         virtual void registerSetMessageCallbackFor(const DtSetMessageType& s, bool reg);

         virtual void registerAdminMessageCallbackFor(const DtAdminContentMessageType& t, bool reg);

         virtual void setTimeoutInterval(int i);

         virtual void sendMessageToObject(const DtVrfObjectMessage* m, DtSimulationAddress addr);

         virtual void sendMessage(const DtSimInterfaceContent* m, DtSimulationAddress addr);

         virtual void addSetCreatorFcn(const DtSetMessageType&, DtSetDataRequestCreatorFcn);

         virtual void addTaskCreatorFcn(const DtSimTaskMessageType&, DtSimTaskCreatorFcn);

         virtual void addInterfaceContentCreatorFcn(int, DtInterfaceContentCreatorFcn);

         virtual void addObjectMessageCreatorFcn(int, DtVrfObjectMessageCreatorFcn);

         virtual void addReportCreatorFcn(const DtSimReportMessageType&, DtSimReportCreatorFcn);

         virtual void addAdminContentCreatorFcn(const DtAdminContentMessageType&, DtAdminContentCreatorFcn);

         virtual void addSimulationCommandCreatorFcn(const DtSimCommandMessageType&, DtSimCommandCreatorFcn);

         virtual void addConditionCreatorFcn(std::string, int, DtCondExprCreatorFcn);

#if DtHLA

         virtual void regsiterInfluenceIteractionCallback(DtInfluenceInterCb, void*);

         virtual void unregsiterInfluenceIteractionCallback(DtInfluenceInterCb, void*);
#endif

         virtual void startFreezeScenario(DtSimulationAddress, bool sendStart);

         virtual void sendSensorFieldOfViewControl(const DtSensorFieldOfViewControlInteractionData* d);

         virtual void registerCommentInteractionCallback(DtCommentCallbackFcn, void*);

         virtual void unregisterCommentInteractionCallback(DtCommentCallbackFcn, void*);

         virtual void importScenarioDescriptionFile(std::string file, DtSimulationAddress address, std::string format,
            std::map<std::string, std::string> importData);

         virtual void exportScenarioDescriptionFile(std::string file, DtSimulationAddress address, std::string format,
            std::map<std::string, std::string> importData);

         virtual DtSimpleTypedDictionary& extendedStateFor(makVrv::DtUniqueID id, bool forceUpdate = true);

         DtVrfObjectDataStateProcessor* vrfObjectDataProcessor()
         {
            return myVrfObjectDataStateDataProcessor;
         }

         makVrv::DT_PROTOCOL_NAMESPACE::DtEntitySimDataProcessor* dataProcessor()
         {
            return myDataProcessor;
         }

         DtEmitterSystemSimDataProcessor*  emitterSystemDataProcessor()
         {
            return myEmitterSystemDataProcessor;
         }

         DtVrfWeatherStateProcessor* weatherDataProcessor()
         {
            return myWeatherDataProcessor;
         }

         DtActiveSonarSimDataProcessor*  activeSonarDataProcessor()
         {
            return myActiveSonarDataProcessor;
         }

         DtEnvironmentSimDataProcessor*  environmentDataProcessor()
         {
            return myEnvironmentDataProcessor;
         }

         DtAggregateSimDataProcessor*  aggregtateDataProcessor()
         {
            return myAggregateDataProcessor;
         }

         DtExtendedStateDataProcessor*  extendedDataStateProcessor()
         {
            return myExtendedStateDataProcessor;
         }

         DtSensorFieldOfViewSimDataProcessor*  sensorFieldOfViewDataProcessor()
         {
            return mySensorFieldOfViewDataProcessor;
         }

         void setUseThreadFlag(bool b)
         {
            myUseThreadFlag = b;
         }

         bool connected() const
         {
            return myConnected;
         }

         virtual bool onStop();

         virtual bool onTick();
         virtual void receivedNetworkMessage(DtNetworkMessageInterface* iface);

         boost::signal<void ()> signal_connectionSetUp;
         boost::signal<void ()> signal_connectionCleanedUp;
         boost::signal<void ()> signal_connectionAboutToBeCleanedUp;

      public:

         virtual DtVrfRemoteController* remoteController();
         virtual const DtVrfRemoteController* remoteController() const;

         virtual DtVrfMessageInterface* messageInterface();
         virtual const DtVrfMessageInterface* messageInterface() const;

         const std::string& nonVrfObjectsUseUUIDScheme() const;

      protected:
         virtual void onSetupExerciseConnection();
         virtual void onCleanupExerciseConnection();

         virtual void connectionConnected();

         static void scenarioSavedCallback(DtSaveResult result, const DtString& error, void* usr);
         virtual void processScenarioSaved(DtSaveResult, const DtString&);

         virtual void setupEntityData();
         virtual void setupAggregateData();
         virtual void setupEnvironmentalData();

         static void simMessageCallback(DtSimMessage* msg, void* usr);
         virtual void processSimMessage(DtSimMessage* msg);

         static void radioMessageCallback(const DtVrfObjectMessage* msg, void* usr);
         virtual void processRadioMessage(const DtVrfObjectMessage* msg);

         virtual void elementAttributeChangeRequested( 
            makVrv::DtUniqueID id, makVrv::DtUniqueID parentId, DtBoost::shared_ptr<const makVrv::DtElementAttribute> atr );

         makVrv::DtVrlinkElement* findElementWithId(makVrv::DtUniqueID id) const;

         virtual makVrv::DtConnection* createConnection();

         virtual void symbolDecorationsChanged();
         virtual void slot_entityElementCreated(makVrv::DT_PROTOCOL_NAMESPACE::DtVrlinkEntityStateListener& l,
            makVrv::DT_PROTOCOL_NAMESPACE::DtEntityElement* e);

         static void scenarioCheckpointed(DtSaveResult result, double, void*);
         virtual void processScenarioCheckpointed(DtSaveResult result, double);

      protected:
         DtVrfRemoteController*     myRemoteController;
         DtVrfMessageInterface*     myVrfMessageInterface;
         DtVrfBackendInterceptor*   myBackEndInterceptor;
         DtVrfConnectionHelper*     myConnectionHelper;
         DtRemoteLoggerController*  myLoggerControl;

         makVrv::DT_PROTOCOL_NAMESPACE::DtEntitySimDataProcessor*  myDataProcessor;
         DtEntityStateCacheManager* myEntityStateCacheManager;

         DtEmitterSystemSimDataProcessor*  myEmitterSystemDataProcessor;
         DtActiveSonarSimDataProcessor*  myActiveSonarDataProcessor;
         DtEnvironmentSimDataProcessor*  myEnvironmentDataProcessor;
         DtEnvironmentProcessStateCacheManager*   myEnvironmentProcessCacheManager;
         DtExtendedStateDataProcessor*  myExtendedStateDataProcessor;
         DtVrfObjectDataStateProcessor*   myVrfObjectDataStateDataProcessor;
         DtVrfEnvironmentObjectDataStateProcessor*   myVrfEnvironmentObjectDataStateDataProcessor;
         DtVrfWeatherStateProcessor* myWeatherDataProcessor;
         DtSensorFieldOfViewSimDataProcessor* mySensorFieldOfViewDataProcessor;

         DtAggregateSimDataProcessor*  myAggregateDataProcessor;
         DtAggregateStateCacheManager* myAggregateStateCacheManager;
         DtWeatherStateCacheManager* myWeatherStateCacheManager;

         DtIffSimDataProcessor*        myIffDataProcessor;
         DtPropulsionNoiseSimDataProcessor*        myPropulsionNoiseDataProcessor;

         DtVrfAggregateObjectDataStateProcessor*   myVrfAggregateObjectDataStateDataProcessor;

         bool myRtiError;
         std::string                   myHostAddressString;
         int                           mySessionId;
         DtVrfFogOfWarHandler*         myFogOfWarHandler;

         DtVrfEmbarkationProcessor*    myVrfEmbarkationProcessor;
         makVrv::DtSignalConnectionManager     myConnectionManager;

         DtVrfWeatherProcessor*        myVrfWeatherProcessor;

         DtAddressMap* myLastAddressMap;
         DtBackendMap* myLastBackendMap;

         DtNetworkMessageInterfaceHandlerAgent* myNetworkMessageInterfaceHandlerAgent;

         typedef std::map<unsigned int, bool> ContextMap;
         typedef std::map<makVrv::DtUniqueID, ContextMap> ShowHideContextMap;

         ShowHideContextMap myShowHideContextMap;
         bool myConnected;
         std::string myLocalSettingsDesignator;

         int myFileTransporterReceivePort;
         std::string myNonVrfObjectsUseUUIDScheme;

         typedef std::map<double, 
            std::pair<DtScenario, int> > CheckpointsToSave;
         CheckpointsToSave myCheckpointsToSave;
         CheckpointsToSave myCheckpointsSaving;

#ifdef DtDIS
         int mySiteId;
         int myAppNumber;
#endif
      };

      inline DtVrfMessageInterface* DtVrfDriver::messageInterface()
      {
         return (myVrfMessageInterface);
      }

      inline const DtVrfMessageInterface* DtVrfDriver::messageInterface() const
      {
         return (myVrfMessageInterface);
      }

      inline DtVrfRemoteController* DtVrfDriver::remoteController()
      {
         return (myRemoteController);
      }

      inline const DtVrfRemoteController* DtVrfDriver::remoteController() const
      {
         return (myRemoteController);
      }

      inline const std::string& DtVrfDriver::nonVrfObjectsUseUUIDScheme() const
      {
         return myNonVrfObjectsUseUUIDScheme;
      }
   }
}