vrfLegionDriver.h

Go to the documentation of this file.

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

#pragma once

#include <vrfLegion/vrfLegion.h>
#include <vrvLegion/DtLegionDriver.h>
#include <vrvUtil/DtSignalConnectionManager.h>
#include <vrfutil/backend.h>
#include <boost/signals2.hpp>
#include <vrfMsgTransport/events.h>
#include <vrfcontrol/vrfRemoteController.h>
#include <vrfGuiCore/sharedNetworkSignaler.h>
#include <legionDataStore/dataTypes.h>

class DtVrfRemoteController;
class DtDetonationInteractionData;

namespace makVrv
{
   class DtAggregateEchelonManager;
   class DtElementIDHierarchyNode;
   class DtSceneEnvironmentalsControllerObjectAgent;
}

namespace makVrf
{
   class DtNetworkMessageInterfaceHandlerAgent;
   class DtNetworkMessageInterface;
   class DtSimDataProcessorManager;
   class DtVantageToLegionIdMapper;
   class DtStateDataManager;
   class DtLegionNetworkInterface;
   class DtStateData;
   class DtVrfConnectionHelper;
   class DtStateData;

   namespace vrfLegion
   {
      class DT_DLL_VRFLEGION DtVrfLegionDriver : public makVrv::DtLegionDriver
      {
      public:
         DtVrfLegionDriver(makVrv::DtAgentManager& agentManager, const std::string& uniqueName, const std::string& className = "DtLegionDriver");
         virtual ~DtVrfLegionDriver();

         static void simulationStatusChangedCallback(DtSimulationStatus, void* usr);
         virtual void processSimulationStatusChanged(DtSimulationStatus);

         virtual void sendDetonation(const DtDetonationInteractionData* d);

         boost::signals2::signal<void ()> signal_onFirstTickDriverInitialization;
         boost::signals2::signal<void ()> signal_driverStarted;
         boost::signals2::signal<void (DtSimulationStatus)> signal_simulationStatusChanged;
         boost::signals2::signal<void ()> signal_driverAboutToBeSetUp;
         boost::signals2::signal<void ()> signal_connectionSetUp;
         boost::signals2::signal<void ()> signal_databaseSetUp;
         boost::signals2::signal<void ()> signal_connectionAboutToBeCleanedUp;

      protected:
         virtual void remoteControllerInit(DtVrfConnectionHelper*);
         virtual bool onStart();
         virtual void onSetupExerciseConnection();
         virtual void onDatabaseCreated();
         virtual void onCleanupExerciseConnection();
         virtual makVrv::DtConnection* createConnection();
         virtual bool onTick();

         virtual void slot_elementCreated(makVrv::DtUniqueID uid, Legion::UInt64 lid, bool created);
         virtual void slot_allElementsDestroyed();

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

         virtual void slot_preConnectionTick();
         virtual void slot_postConnectionTick();

         virtual void slot_hierarchyItemModified(makVrv::DtElementIDHierarchyNode* node);

         virtual void stateDataChanged(const DtStateData*, bool created);
         virtual void slot_stateDataAdded(DtStateData*);
         virtual void slot_stateDataRemoved(const DtStateData*);
         virtual void slot_coordinateSystemChanged();

         virtual void setDiscoverBackgroundEntities(bool);
         bool discoverBackgroundEntities() const
         {
            return myDiscoverBackgroundEntities;
         }

         DtVrfConnectionHelper* connectionHelper() const
         {
            return myConnectionHelper;
         }

         virtual double simTimeFromBackend(double& dT);

         virtual void setTimeOfDayAdvancementSpeed(float value);
         virtual void setUseGlobalTimeZone(bool b);
         virtual void setDateAndTimeOfDay(time_t dtod);

         virtual void updateSimulationDateTime();
         virtual void updateGlobalEnvironment();

      protected:
         makVrv::DtSignalConnectionManager myConnectionManager;
         DtVrfConnectionHelper* myConnectionHelper;
         DtLegionNetworkInterface* myLegionNetworkInterface;
         bool myConnected;
         bool myNeedsFirstTickInitialization;
         std::string myHostAddressString;
         std::string myReportedHostAddressString;

         int mySiteId;
         int myAppId;
         int myFileTransporterReceivePort;
         int mySessionId;
         int myNextEventId;

         makVrv::DtAggregateEchelonManager* myEchelonHierarchy;
         double myLastSimTime;

         bool myDisableRemoteDiscovery;
         bool myDiscoverBackgroundEntities;

         unsigned int myIsBackgroundEntity;
         bool mySetupExerciseConnection;

         makVrv::DtSceneEnvironmentalsControllerObjectAgent* myWeatherControllerAgent;
         const DtStateData* myGlobalWeatherObject;
      };
   }
}