TcpServer.h

Go to the documentation of this file.

#ifndef INC_TCPSERVER_H
#define INC_TCPSERVER_H
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
#include "TcpTypes.h"
#include "TcpMain.h"
#include "TcpMessage.h"
#include <queue>
#include <map>
//-----------------------------------------------------------------------------
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 Transmitter;
  class ServerReceiver;
  class ServerAcceptReceiver;
  //---------------------------------------------------------------------------
  class __tcp_export_dll Server : public TcpMain
  {
    public:
      //-----------------------------------------------------------------------
      // >>>>>>>>>>>>>>>>>> ServerReceiverTransmitter >>>>>>>>>>>>>>>>>>>>>>>>>
      //-----------------------------------------------------------------------
      class __tcp_export_dll ServerReceiverTransmitter
      {
        private:
          //============== Attribute
          //---------------------------------------------------------------------
          ServerReceiver * m_pReceiver;
          //---------------------------------------------------------------------
          Transmitter * m_pTransmitter;
          //---------------------------------------------------------------------
 
        protected:
          //============== Konstruktoren
          //---------------------------------------------------------------------
          ServerReceiverTransmitter();
          //---------------------------------------------------------------------
 
        public:
          //============== Konstruktoren
          //---------------------------------------------------------------------
          ServerReceiverTransmitter( Transmitter * pTransmitter, ServerReceiver * pReceiver );
          //---------------------------------------------------------------------
          virtual ~ServerReceiverTransmitter();
          //---------------------------------------------------------------------
 
        private:
          //============== Copy-Konstruktor
          //---------------------------------------------------------------------
          ServerReceiverTransmitter( const ServerReceiverTransmitter & rT );
          //---------------------------------------------------------------------
 
        public:
          //============== Methoden
          //---------------------------------------------------------------------
          int send( char * pszRawMsg,
                    unsigned int uiRawMsgSize,
                    unsigned int uiMessageID = 0,
                    int iActionCode = 0,
                    const std::string & rstrInfo = "" );
          //---------------------------------------------------------------------
          int send( Message * pTcpMessage );
          //---------------------------------------------------------------------
          void setValid( bool bValid );
          //---------------------------------------------------------------------
          int getPeerName( std::string & rstrIPAdress, unsigned int & ruiPort ) const;
          //---------------------------------------------------------------------
          SOCKET Socket() const;
          //---------------------------------------------------------------------
        private:
          //============== Operatoren
          //---------------------------------------------------------------------
          Server::ServerReceiverTransmitter & operator= ( const ServerReceiverTransmitter & );
        //---------------------------------------------------------------------
      };
      //-----------------------------------------------------------------------
      // <<<<<<<<<<<<<<<<< ServerReceiverTransmitter <<<<<<<<<<<<<<<<<<<<<<<<<<
      //-----------------------------------------------------------------------
 
    private:
      //============== Attribute
      //-----------------------------------------------------------------------
      unsigned long m_ulMaxClients;
      //-----------------------------------------------------------------------
      std::queue<AbstractMessage *> m_MsgQueue;
      //-----------------------------------------------------------------------
 
    protected:
      //-----------------------------------------------------------------------
      ServerAcceptReceiver * m_pAcceptReceiver;
      //-----------------------------------------------------------------------
      std::map< SOCKET, ServerReceiverTransmitter *, std::less< SOCKET > > m_ClientMap;
      //-----------------------------------------------------------------------
 
      //============== Konstruktor
      //-----------------------------------------------------------------------
      Server();
      //-----------------------------------------------------------------------
      Server( unsigned int, int, int, int, int );
      //-----------------------------------------------------------------------
      Server( unsigned int, int, int, int, unsigned int, int );
      //-----------------------------------------------------------------------
 
    public:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      Server( unsigned int uiPort,
              int iAdressFamily,
              int iSocketType,
              int iProtocol,
              unsigned int uiDataSize,
              unsigned long ulMaxClients,
              int iSecTimeOut );
      //-----------------------------------------------------------------------
      virtual ~Server();
      //-----------------------------------------------------------------------
 
    private:
      //============== Copy-Konstruktor
      //-----------------------------------------------------------------------
      Server( const Server & rT );
      //-----------------------------------------------------------------------
 
      //============== Methoden
      //-----------------------------------------------------------------------
      void init();
      //-----------------------------------------------------------------------
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual void work() override;
      //-----------------------------------------------------------------------
      #if defined (__PTHREADS)
      virtual void cleanUp();
      //-----------------------------------------------------------------------
      #else
 
    public:
      //============== Methoden
    //-------------------------------------------------------------------------
      virtual void cancel() override;
      //-----------------------------------------------------------------------
      #endif
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual void insertNewClient( Server::ServerReceiverTransmitter * pNewServerReceiverTransmitter );
      //-----------------------------------------------------------------------
      Server::ServerReceiverTransmitter * getClient( SOCKET Socket );
      //-----------------------------------------------------------------------
      int virtual removeClient( SOCKET Socket );
      //-----------------------------------------------------------------------
      virtual Server::ServerReceiverTransmitter * generateNewServerReceiverTransmitter( Server * pParent,
                                                                                        SOCKET Socket,
                                                                                        unsigned int iDataSize ) const;
      //-----------------------------------------------------------------------
      void setClientMapReceiverValid( bool bValid );
      //-----------------------------------------------------------------------
      void clearClientMap();
      //-----------------------------------------------------------------------
      unsigned long getMaxClients() const;
      //-----------------------------------------------------------------------
      virtual void processClientMessage (AbstractMessage * pTcpMessage);
      //-----------------------------------------------------------------------
      virtual int send( SOCKET ClientSocket,
                        char * pszRawMsg,
                        unsigned int uiRawMsgSize,
                        unsigned int uiMessageID = 0,
                        int iActionCode = 0,
                        const std::string & rstrInfo = "" );
      //-----------------------------------------------------------------------
      virtual int send( Message * pTcpMessage ) override;
      //-----------------------------------------------------------------------
 
    public:
      //============== Methoden
      //-----------------------------------------------------------------------
      int acceptClientMessage( AbstractMessage * pTcpMessage );
      //-----------------------------------------------------------------------
 
    private:
      //============== Operatoren
      //-----------------------------------------------------------------------
      Server & operator= ( const Server & );
      //-----------------------------------------------------------------------
  };
  //---------------------------------------------------------------------------
  #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