DtUdpMessageClient.h

Go to the documentation of this file.

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


#pragma once

#include <vrvCore/vrvCore.h>
#include <vrvUtil/DtMessageClient.h>
#include <vrvUtil/DtMessageStream.h>
#include <vrvUtil/DtVirtualBaseClass.h>

#include <string>

class DtInetSocket;

namespace makVrv
{
   class DtDe;

   class DT_DLL_VRVCORE DtUdpMessageClient : public DtMessageClient
   {
   public:

      DtUdpMessageClient( DtDe& de, DtInetSocket* socket, size_t maxPacketSize);

      virtual ~DtUdpMessageClient();

      virtual void deliver(DtMessage& msg);

      virtual void sendAndFlush();
      
      virtual void getServerMessages(MessageList&);

      DtInetSocket* socket() const;

      virtual void readData();
      
      bool isOk() const;

      size_t maxPacketSize() const;

      static  std::string errorString(int code);

   protected:

      int lastError();

   protected:

      DtDe& myDe;

      DtInetSocket* mySocket;
      bool myOkFlag;
      double mySendTimeout;
      DtMessageStream myInputStream;
      DtMessageStream myOutputStream;
      size_t myMaxPacketSize;
   };


   class DT_DLL_VRVCORE DtUdpMessageClientCreator : public DtVirtualBaseClass
   {
   public:

      static DtUdpMessageClientCreator& instance(DtDe&);

      static void registerInstance(DtDe& de,DtUdpMessageClientCreator*);

      virtual DtUdpMessageClient* create( DtDe& de, const std::string& udpDevice, 
         const std::string& udpAddress, int port );
   };

}