DtCigiConnection.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2017 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/


#pragma once

#include <vrvCigi/DtCigiConnSettingsHandler.h>
#include <vrvCigi/DtCigiConnectionInitializer.h>
#include <vrvCigi/DtCigiViewController.h>
#include <vrvCigi/DtComponentSignaler.h>

#include <vrvCore/DtBaseConnection.h>
#include <vrvCore/DtViewStateProcessor.h>

#include <matrix/vlVector.h>
#include <vlutil/vlPerformanceStats.h>
#include <vrvUtil/DtVirtualBaseClass.h>

class CigiViewCtrlV3;
class CigiIGSession;
class CigiBasePacket;

namespace makVrv
{
   class DtDe; // for the creator class
   class DtCigiConnectionInitializer;
   class DtCigiNetworkIO;
   class DtAgentManagerInterface;
   class DtCigiEntityVisualizer;
   class DtCoordinateSystem;
   class DtSharedSettingsManager;
   class DtVirtualBaseClass;
   class DtCigiIgControlProcessor;
   class DtHatHotResponder;
   class DtLosResponder;

   class DT_DLL_VRVCIGI DtCigiConnection : public DtBaseConnection
   {
   public:
      enum DtIgMode
      {
         ResetStandby = 0,
         Operate = 1,
         Debug = 2
      };

      friend class DtCigiConnectionCreator;

      virtual ~DtCigiConnection();

      virtual void init();

      virtual bool tick();

      virtual bool connect();

      virtual bool disconnect();

      virtual void restart();

      virtual void setConnectionInitializer(const DtCigiConnectionInitializer& init);

      virtual int cigiMinorVersion() const;

      virtual void sendCigiMessages();

      virtual void setCoordinateSystem(const std::string& name, 
         const std::string& params);

      virtual DtCoordinateSystem& coordinateSystem();


      virtual const DtCigiEntityVisualizer& entityManager() const;
      virtual DtCigiEntityVisualizer& entityManager();


      virtual const DtCigiIgControlProcessor& igControlProcessor() const;
      virtual DtCigiIgControlProcessor& igControlProcessor();
            

      virtual const DtCigiNetworkIO& networkIO() const;
      virtual DtCigiNetworkIO& networkIO();

      virtual const makArchives::DtCigiSettingsRecord& cigiSettings() const;

      virtual void setLastHostFrameNumber(unsigned int frameNumber);
      
      virtual unsigned int lastHostFrameNumber() const;

      inline bool useSynchronousMode() const
      {
         return myUseSynchronousMode;
      }

      virtual void setIgMode(DtIgMode mode);

      inline DtIgMode igMode() const
      {
         return myMode;
      }

      virtual void setDatabaseNumber(int number);

      virtual int databaseNumber() const;

      virtual void setLoadingDatabase();

      virtual void setDatabaseLoaded();

      virtual void setExtrapolationEnabled(bool enabled);

      virtual bool extrapolationEnabled() const;

      virtual void setTimestampValid(bool valid);

      virtual bool timestampValid() const;

      virtual void setLastTimestamp(unsigned int timestamp);

      virtual unsigned int lastTimestamp() const;

      virtual void sendHatHotResponse(double height, unsigned int hotId, bool hat,
         unsigned int lastFrame, bool valid);

      virtual void sendLosResponse(int losId, int entityId, bool visible, double range,
         int responseCount, int hostFrame);

      virtual void sendUserPacket( CigiBasePacket* packet );


      virtual const DtHatHotResponder& hatHotResponder() const;
      virtual DtHatHotResponder& hatHotResponder();


      virtual const DtLosResponder& losResponder() const;
      virtual DtLosResponder& losResponder();

      virtual unsigned int currentIgFrame() const;

      virtual DtComponentSignaler& componentSignaler();



      virtual CigiIGSession& session();
      virtual const CigiIGSession& session() const;
      
      bool cigiSessionExists() const;

      virtual bool registerUserPacket(CigiBasePacket *packet, 
         unsigned int packetId, bool hostSend, bool igSend);

      virtual bool useThreadFlag() const;

      virtual void queueDriverFunction(boost::function<void ()> func);

      virtual void queueConnectionFunction(boost::function<void ()> func);

      virtual DtCigiDriver& cigiDriver(); 
      


      virtual void startOverloadTimer();

      virtual void stopOverloadTimer();

      virtual bool overloaded();

      virtual void setWarnOnOverload( bool b );

      virtual bool warnOnOverload() const;

      virtual void setDropMessagesOnOverload( bool b );

      virtual bool dropMessagesOnOverload() const;

      virtual double hostFrequency() const;

      boost::signal<void (DtViewStateProcessor::ObserverAction&)>
         signal_viewChanged;

      boost::signal<void (int, DtUniqueID)> signal_alphaChanged;

      boost::signal<void (int, DtCigiViewController::DtViewDefinitionAction) > 
         signal_receivedViewDefinition;

      boost::signal<void (int, DtCigiViewController::DtViewControlAction)>
         signal_receivedViewControl;

      boost::signal<void (int, int, int, int, int)> signal_timeSet;

      boost::signal<void (bool)> signal_ephemerisEnableSet;

      boost::signal<void (const std::string&)> signal_loadDatabase;

      boost::signal<void ()> signal_connected;

      boost::signal<void ()> signal_toBeDisconnected;

      boost::signal<void ()> signal_coordinateSystemChanged;

      boost::signal<void (bool)> signal_deadReckoningAllowedChanged;

      boost::signal<void ()> signal_preTick;

      boost::signal<void ()> signal_postTick;

   protected:
      DtCigiConnection(const DtCigiConnectionInitializer& init,
         DtAgentManagerInterface& sceneInterface,
         DtSharedSettingsManager& settingsManager,
         DtCigiDriver& driver);

      virtual void on_viewControlReceived(const CigiViewCtrlV3& viewControl);

   protected:
      typedef std::map<std::string,DtVirtualBaseClass*> InstanceMap;

      DtCigiDriver&          myCigiDriver;
      DtCigiNetworkIO*       myNetworkIO;
      DtCigiEntityVisualizer*   myEntityManager;
      DtCigiConnectionInitializer myInitializer;
      DtCigiIgControlProcessor*     myIgController;
      DtHatHotResponder*       myHatHotResponder;
      DtLosResponder*          myLosResponder;
      DtCoordinateSystem*    myCoordinateSystem;
      DtComponentSignaler    myComponentSignaler;
      DtCigiConnSettingsHandler mySettingsHandler;
      bool                   myUseSynchronousMode;
      double myHostFrequency;

      unsigned int           myIgFrame;
      unsigned int           myLastHostFrameNumber;
      DtSignalConnectionManager mySignals;
      DtIgMode                  myMode;
      int                       myDatabaseNumber;
      bool                      myDatabaseLoading;
      bool                      myExtrapolationEnabled;
      bool                      myTimestampValid;
      unsigned int              myLastTimestamp;
      int                       myCigiMinorVersion;

      DtTimedSection myOverloadTimer;
      double myFrameTimeSoFar;
      bool myWarnOnOverload;
      bool myDropMessagesOnOverload;
   };

   class DT_DLL_VRVCIGI DtCigiConnectionCreator : public DtVirtualBaseClass
   {
   public:     
      DtCigiConnectionCreator();

      virtual ~DtCigiConnectionCreator();

      static DtCigiConnectionCreator& instance( DtDe& de );

      virtual DtCigiConnection* create(const DtCigiConnectionInitializer& init,
         DtAgentManagerInterface& sceneInterface,
         DtSharedSettingsManager& settingsManager,
         DtCigiDriver& driver) const;
   };
}