DtCigiNetworkIO.h

Go to the documentation of this file.

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


#pragma once

#include <vrvCigi/vrvCigi.h> 
#include <vrvCigi/DtCigiConnectionInitializer.h>

#include <vrvUtil/DtVirtualBaseClass.h>

#include <vlutil/vlInetSocket.h>

#include "CigiTypes.h"

class CigiHatHotRespV3_2;
class CigiLosRespV3_2;
class CigiLosXRespV3_2;

class DtInetSocket;
class DtInetSocketMgr;
class DtInetTcpSocket;
class CigiIGSession;
class CigiBasePacket;
class CigiBaseIGCtrl;

namespace makCigiExt
{
   class DtCigiDiGuyCtrl;
   class DtCigiDiGuyCtrlExt;
}

namespace makVrv
{
   class DtCigiConnectionInitializer;
   class DtCigiSignalProcessor;
   class DtCigiConnection;
   class DtCigiLosBasicResponse;
   class DtCigiLosExtendedResponse;

   class DT_DLL_VRVCIGI DtCigiNetworkIO
   {
   public:
      friend class DtCigiNetworkIOCreator;

      virtual ~DtCigiNetworkIO();

      virtual bool receiveCigiMessages();

      virtual bool sendCigiMessages(unsigned int frameNumber, unsigned int lastHostFrameNumber,
         int igMode, int databaseNumber);

      virtual bool readyToSendCigiMessages() const;

      virtual void setSignalProcessor(DtCigiSignalProcessor& sigProcessor);

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

      virtual void sendLosBasicResponse(DtCigiLosBasicResponse* losResponse);

      virtual void sendLosExtendedResponse(DtCigiLosExtendedResponse* losResponse);

      virtual void sendUserPacket( CigiBasePacket* packet );



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

      bool cigiSessionExists() const;

      virtual void packLosBasicResponse(const DtCigiLosBasicResponse& response, CigiLosRespV3_2& respPacket);

      virtual void packLosExtendedResponse(const DtCigiLosExtendedResponse& response, CigiLosXRespV3_2& respPacket);

      virtual bool registerUserPacket(CigiBasePacket *packet, 
         unsigned int packetId, bool hostSend, bool igSend);
 
      static bool addSocketCb(DtInetSocket* sock, void* usr);

      static bool removeSocketCb(DtInetSocket* sock, void* usr);

   protected:
      DtCigiNetworkIO(const DtCigiConnectionInitializer& initializer, 
         DtCigiConnection& connection );

      virtual void initializeUdpSocket(const DtInetEndpoint& endpoint, 
         unsigned int listenPort, DtInetDevice* device);

      virtual void initializeTcpSocket(const DtInetEndpoint& endpoint, 
         DtInetDevice* device, int localPort);

      virtual void addSocket(DtInetTcpSocket* sock);
      
      virtual void removeSocket(DtInetTcpSocket* sock);

      virtual DtInetAddr findFirstNetworkDeviceAddress(bool& found) const;

      CigiBaseIGCtrl* igControlPacket( Cigi_uint8* Dta );

      DtCigiNetworkIO(const DtCigiNetworkIO& orig);

      DtCigiNetworkIO& operator=(const DtCigiNetworkIO& orig);

   protected:
      struct HatHotResponseData
      {
         double       hatHotValue;
         int          hatHotId;
         bool         sendHatResponse;
         unsigned int lastHostFrameNumber;
         bool         valid;
      };

      DtCigiConnection& myConnection;

      DtInetSocket*     mySocket;

      CigiIGSession*    myCigiIgSession;

      DtInetBufferChain myReceiveBufferChain;

      DtInetBuffer      myReceiveBuffer;

      unsigned int      myReceiveBufferSize;

      DtInetEndpoint    myDestinationAddress;

      DtCigiSignalProcessor* mySignalProcessor;

      DtInetSocketMgr*  mySocketMgr;

      bool              myUseTcpClient;

      bool               myUseTcpServer;

      bool myUseSynchronousMode;

      std::vector<HatHotResponseData> myHatHotResponses;

      std::vector<DtCigiLosBasicResponse*> myLosBasicResponses;
      std::vector<DtCigiLosExtendedResponse*> myLosExtendedResponses;

      std::vector<CigiBasePacket*> myUserPacketsToSend;

      double myTimeSlice;

      makCigiExt::DtCigiDiGuyCtrl* myDiGuyCtrlPacket;

      makCigiExt::DtCigiDiGuyCtrlExt* myDiGuyCtrlExtPacket;
   };

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

      virtual ~DtCigiNetworkIOCreator();

      static DtCigiNetworkIOCreator& instance( DtDe& de );

      static DtCigiNetworkIOCreator& instance( DtCigiConnection& con );

      static void copyInstance(DtCigiConnection& con, DtDe& de);

      virtual DtCigiNetworkIO* create( const DtCigiConnectionInitializer& initializer, 
         DtCigiConnection& connection ) const;
   };
}