GloServer.h

Go to the documentation of this file.

#ifndef INC_GLOSERVER_H
#define INC_GLOSERVER_H
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
#include "GloTypes.h"
#include <TcpServer.h>
//-----------------------------------------------------------------------------
namespace glo
{
  //---------------------------------------------------------------------------
  /* Forwards */
  struct ClientInfo;
  class ServerThread;
  class OrderMsg;
  class Manager;
  class ManagerActionVisualiser;
  //---------------------------------------------------------------------------
  class __glo_export_dll Server : public tcp::Server
  {
    public:
      //-----------------------------------------------------------------------
      // >>>>>>>>>>>>>> TcpServerReceiverTransmitter >>>>>>>>>>>>>>>>>>>>>>>>>>
      //-----------------------------------------------------------------------
      class __glo_export_dll TcpServerReceiverTransmitter : public tcp::Server::ServerReceiverTransmitter
      {
        private:
          //============== Attribute
          //---------------------------------------------------------------------
          ServerThread * m_pServerThread;
          //---------------------------------------------------------------------
 
        protected:
          //============== Konstruktoren
          //---------------------------------------------------------------------
          TcpServerReceiverTransmitter();
          //---------------------------------------------------------------------
 
        public:
          //============== Konstruktoren
          //---------------------------------------------------------------------
          TcpServerReceiverTransmitter( tcp::Transmitter * pTransmitter, tcp::ServerReceiver * pReceiver );
          //---------------------------------------------------------------------
          virtual ~TcpServerReceiverTransmitter();
          //---------------------------------------------------------------------
 
        private:
          //============== Copy-Konstruktor
          //---------------------------------------------------------------------
          TcpServerReceiverTransmitter( const TcpServerReceiverTransmitter & );
          //---------------------------------------------------------------------
 
        public:
          //============== Methoden
          //---------------------------------------------------------------------
          ServerThread * getServerThread();
          //---------------------------------------------------------------------
          virtual int sendOrder( OrderMsg * pOrderMsg, tcp::ActionCode eTcpActionCode );
          //---------------------------------------------------------------------
 
        private:
          //============== Operatoren
          //---------------------------------------------------------------------
          TcpServerReceiverTransmitter & operator= ( const TcpServerReceiverTransmitter & );
          //---------------------------------------------------------------------
      };
      //-----------------------------------------------------------------------
      // <<<<<<<<<<<<<<<< TcpServerReceiverTransmitter <<<<<<<<<<<<<<<<<<<<<<<<
      //-----------------------------------------------------------------------
 
    private:
      //============== Attribute
      //-----------------------------------------------------------------------
      Manager * m_pGloManager;
      //-----------------------------------------------------------------------
 
    protected:
      //============== Konstruktor
      //-----------------------------------------------------------------------
 
      Server();
      Server( unsigned int, int, int, int, int );
      Server( unsigned int, int, int, int, unsigned int, int);
      Server( unsigned int, int, int, int, unsigned int, unsigned long, int);
      //-----------------------------------------------------------------------
 
    public:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      Server( const std::string & rsSchemaPath,
              const std::vector< std::string > & rKnownSchemesVector,
              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 & );
      //-----------------------------------------------------------------------
 
    public:
      //============== Methoden
      //-----------------------------------------------------------------------
      std::string getSchemaPath() const;
      //-----------------------------------------------------------------------
      void getAllKnownBases( std::vector< std::string > & rKnownBasesVector ) const;
      //-----------------------------------------------------------------------
      void getAllClients( std::vector< ClientInfo > & rClientInfoVector ) const;
      //-----------------------------------------------------------------------
      void setActionVisualiser( ManagerActionVisualiser * pActionVisualiser );
      //-----------------------------------------------------------------------
      void setShowLevel( ShowLevel ulLevel );
      //-----------------------------------------------------------------------
      ShowLevel getShowLevel();
      //-----------------------------------------------------------------------
      virtual void processClientMessage( tcp::AbstractMessage * pTcpMessage ) override;
      //-----------------------------------------------------------------------
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      #if defined (__PTHREADS)
      virtual void cleanUp();
      //-----------------------------------------------------------------------
      #else
 
    public:
      //============== Methoden
      virtual void cancel() override;
      #endif
      //-----------------------------------------------------------------------
      virtual void insertNewClient( Server::ServerReceiverTransmitter * pNewServerReceiverTransmitter ) override;
      //-----------------------------------------------------------------------
      virtual int removeClient( SOCKET nSocket ) override;
      //-----------------------------------------------------------------------
      virtual tcp::Server::ServerReceiverTransmitter * generateNewServerReceiverTransmitter(  tcp::Server * pParent,
                                                                                              SOCKET nSocket,
                                                                                              unsigned int uiDataSize ) const override;
      //-----------------------------------------------------------------------
 
    private:
      //============== Operatoren
      //-----------------------------------------------------------------------
      Server & operator= ( const Server & );
      //-----------------------------------------------------------------------
  };
  //---------------------------------------------------------------------------
} // namespace glo
#endif