DtTcpMessageClient.h

Go to the documentation of this file.

/******************************************************************************
** Copyright (c) 2015 MAK Technologies, Inc.
** All rights reserved.
******************************************************************************/
/******************************************************************************
** $RCSfile: DtTcpMessageClient.h,v $ $Revision: 1.20 $ $State: Exp $
******************************************************************************/


#ifndef DtRemoteIGITCPClient_H_
#define DtRemoteIGITCPClient_H_

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

#include <string>

namespace makVrv
{
   class DtDe;

   class DT_DLL_VRVCORE DtTcpMessageClient : public DtMessageClient
   {
   public:

      DtTcpMessageClient( DtDe& de,int socket, const std::string& localAddress, int port,
         bool useBlockingSend=false);

      virtual ~DtTcpMessageClient();

      virtual void deliver(DtMessage& msg);

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

      void connectToListener(const std::string& address,int port);

      void disconnect();

      virtual bool validateConnection();

      virtual bool isConnected() const;

      int socket() const;

      virtual int port() const;

      const std::string& address() const;
     
      void readData();
      
      bool isOk() const;

      static void getUniqueClientName(std::string& nameOut);

      virtual const std::string& name() const;

      static  std::string errorString(int code);

      const DtDeRecord& connectionRecord();

      double sendTimeout() const;

   protected:

      void setSocket(int socket);

      bool receiveIgRecord(DtDeRecord& name);

      bool receiveString(std::string& string);
      bool receiveInt( int& value);
      bool sendString( const std::string& name );
      bool sendInt( int value);

      bool sendIGRecord(const DtDeRecord& record);

      
      int lastError();

      void getMessagesFromData();     
     
      DtDe& myDe;

      int mySocket;
      std::string myAddress;
      int myPort;
      bool myOkFlag;
      double mySendTimeout;


      DtMessageStream myInputStream;
      DtMessageStream myOutputStream;
      DtDeRecord myRecord;
      bool myUseBlockingSend;

   };
}

#endif