TcpClient.h

Go to the documentation of this file.

#ifndef INC_TCPCLIENT_H
#define INC_TCPCLIENT_H
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
#include "TcpTypes.h"
#include "TcpMain.h"
#include "TcpReceiverTransmitter.h"
#include <string>
#include <queue>
#include "TcpMessage.h"
#if defined(_MSC_VER) || defined(__MINGW32__) || defined(__MINGW64__)
  #include <winsock.h>
#endif
//-----------------------------------------------------------------------------
namespace tcp
{
  //---------------------------------------------------------------------------
  #ifdef _MSC_VER
    /* 'Bezeichner': Klasse 'Typ' benötigt eine DLL-Schnittstelle, die von... */
    #pragma warning( disable : 4251 )
    /* class 'TYP' ist keine DLL-Schnittstelle und wurde als Basisklasse... */
    #pragma warning( disable : 4275 )
  #endif
  //---------------------------------------------------------------------------
  //Forwards
  class ClientReceiver;
  class Transmitter;
  //---------------------------------------------------------------------------
  class __tcp_export_dll Client : public TcpMain
  {
    protected:
      //============== Attribute
      //-----------------------------------------------------------------------
      ClientReceiver * m_pReceiver;
      //-----------------------------------------------------------------------
      Transmitter * m_pTransmitter;
      //-----------------------------------------------------------------------
 
    private:
      //============== Attribute
      //-----------------------------------------------------------------------
      SOCKADDR_IN m_Socketadress;
      //-----------------------------------------------------------------------
      std::string m_sHostname;
      //-----------------------------------------------------------------------
      std::queue<Message *> m_MsgQueue;
      //-----------------------------------------------------------------------
      ActionCode m_eToWaitingForServer;
      //-----------------------------------------------------------------------
 
    protected:
      //============== Konstruktor
      //-----------------------------------------------------------------------
      Client();
      //-----------------------------------------------------------------------
      Client( unsigned int,
              int,
              int,
              int,
              int );
      //-----------------------------------------------------------------------
 
    public:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      Client( const std::string & rsHostname,
              unsigned int uiPort,
              int iAdressFamily,
              int iSocketType,
              int iProtocol,
              int iSecTimeOut );
      //-----------------------------------------------------------------------
      Client( const std::string & rsHostname,
              unsigned int uiPort,
              int iAdressFamily,
              int iSocketType,
              int iProtocol,
              unsigned int uiDataSize,
              int iSecTimeOut );
      //-----------------------------------------------------------------------
 
       //============== Destruktore
      //-----------------------------------------------------------------------
      virtual ~Client();
      //-----------------------------------------------------------------------
 
    private:
      //============== Copy-Konstruktor
      //-----------------------------------------------------------------------
      Client( const Client & );
      //-----------------------------------------------------------------------
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual void work() override;
      //-----------------------------------------------------------------------
      #if defined (__PTHREADS)
      virtual void cleanUp();
      //-----------------------------------------------------------------------
      #else
      //-----------------------------------------------------------------------
 
    public:
      //============== Methoden
      virtual void cancel() override;
      #endif
      //-----------------------------------------------------------------------
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual Transmitter * generateNewTransmitter();
      //-----------------------------------------------------------------------
      virtual ClientReceiver * generateNewReceiver();
      //-----------------------------------------------------------------------
 
    public:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual void setDataSize( unsigned int uiDataSize ) override;
      //-----------------------------------------------------------------------
      int connectServer();
      //-----------------------------------------------------------------------
      virtual int disconnectServer();
      //-----------------------------------------------------------------------
      bool isServerConnected() const;
      //-----------------------------------------------------------------------
      virtual int send( char * pszRawMsg,
                        unsigned int uiRawMsgSize,
                        unsigned int uiMessageID = 0,
                        int iActionCode = 0,
                        const std::string & rsInfo = "" );
      //-----------------------------------------------------------------------
      virtual int send( Message * pTcpMessage ) override;
      //-----------------------------------------------------------------------
      int acceptServerMessage( Message * pTcpServerMessage );
      //-----------------------------------------------------------------------
      int getSocketAdrFromString( SOCKADDR_IN * Socketadress,
                                  const std::string & rsHostnameOrIp ) const;
      //-----------------------------------------------------------------------
      std::string getHostName() const;
      //-----------------------------------------------------------------------
      int getPeerName( std::string& rsIPAdress, unsigned int& ruiPort ) const;
      //-----------------------------------------------------------------------
      ActionCode getWaitingServerMsgActionCode() const;
      //-----------------------------------------------------------------------
 
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual void processServerMessage( Message * pTcpMessage );
      //-----------------------------------------------------------------------
      virtual int syncDataSize();
      //-----------------------------------------------------------------------
 
    private:
      //============== Operatoren
      //-----------------------------------------------------------------------
      Client & operator= ( const Client & );
      //-----------------------------------------------------------------------
  };
  //---------------------------------------------------------------------------
  #ifdef _MSC_VER
    /* 'Bezeichner': Klasse 'Typ' benötigt eine DLL-Schnittstelle, die von... */
    #pragma warning( default : 4251 )
    /* class 'TYP' ist keine DLL-Schnittstelle und wurde als Basisklasse... */
    #pragma warning( default : 4275 )
  #endif
  //---------------------------------------------------------------------------
} // namespace tcp
//-----------------------------------------------------------------------------
#endif