include/vrvCigi/DtCigiNetworkIO.h

Go to the documentation of this file.

/*********************************************************************
** Copyright (c) 2009 MaK Technologies, Inc.
** All rights reserved.
*********************************************************************/
/*********************************************************************
** $RCSfile: DtCigiNetworkIO.h,v $ $Revision: 1.1 $ $State: Exp $
*********************************************************************/


#ifndef DtCigiNetworkIO_H_
#define DtCigiNetworkIO_H_

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

#include <vlutil/vlInetSocket.h>

class CigiHatHotRespV3_2;

class DtInetSocket;
class DtInetSocketMgr;
class DtInetTcpSocket;
class CigiIGSession;

namespace makVrv
{
   class DtCigiConnectionInitializer;
   class DtCigiSignalProcessor;

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

      virtual ~DtCigiNetworkIO();

      virtual bool receiveCigiMessages();

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

      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);

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

      DtInetSocket*     mySocket;

      CigiIGSession*    myCigiIgSession;

      DtInetBufferChain myReceiveBufferChain;

      DtInetBuffer      myReceiveBuffer;

      unsigned int      myReceiveBufferSize;

      DtInetEndpoint    myDestinationAddress;

      DtInetSocketMgr*  mySocketMgr;

      bool              myUseTcpClient;

      bool               myUseTcpServer;

      bool myUseSychronousMode;
      

      std::vector<HatHotResponseData> myHatHotResponses;

      std::vector<LosResponseData> myLosResponses;
   };
}


#endif