DtCigiNetworkIO.h

Go to the documentation of this file.

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


#pragma once

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

#include <vlutil/vlInetSocket.h>

#include "CigiTypes.h"

class CigiHatHotRespV3_2;

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

namespace makCigiExt
{
   class DtCigiDiGuyCtrl;
}

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

   class DT_DLL_VRVCIGI DtCigiNetworkIO
   {
   public:
      DtCigiNetworkIO(const DtCigiConnectionInitializer& initializer, 
         DtCigiConnection& connection );

      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 sendLosResponse(int losId, int entityId, bool visible, double range,
         int responseCount, int hostFrame);

      virtual void sendUserPacket( CigiBasePacket* packet );



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

      bool cigiSessionExists() const;

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

      struct LosResponseData
      {
         int losId;
         int entityId;
         bool visible;
         double range;
         unsigned int lastHostFrameNumber;
         int responseCount;
      };

      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<LosResponseData> myLosResponses;

      std::vector<CigiBasePacket*> myUserPacketsToSend;

      double myTimeSlice;

      makCigiExt::DtCigiDiGuyCtrl* myDiGuyCtrlPacket;
   };
}