GloClientThread.h

Go to the documentation of this file.

#ifndef INC_GLOCLIENTTHREAD_H
#define INC_GLOCLIENTTHREAD_H
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
#include <string>
#include <map>
#include "GloTypes.h"
#include "GloCommunicator.h"
#include "GloClient.h"
//-----------------------------------------------------------------------------
namespace glo
{
  //---------------------------------------------------------------------------
  /* Forwards */
  class ClassInfo;
  class Client;
  //---------------------------------------------------------------------------
  class __glo_export_dll ClientThread : public Communicator
  {
    private:
      //============== Attribute
      //-----------------------------------------------------------------------
      std::map< unsigned long, ClassInfo *, std::less<unsigned long> > * m_pSchemaMap;
      //-----------------------------------------------------------------------
      Client * m_pTcpClient;
      //-----------------------------------------------------------------------
      bool m_bOrderstop;
      //-----------------------------------------------------------------------
 
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      ClientThread();
      //-----------------------------------------------------------------------
 
    public:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      ClientThread( const std::string & rstrHostname,
                    unsigned int uiPort,
                    int iSecTimeOut );
      //-----------------------------------------------------------------------
      ~ClientThread();
      //-----------------------------------------------------------------------
 
    private:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      ClientThread( const ClientThread & );
      //-----------------------------------------------------------------------
 
      //============== Methoden
      //-----------------------------------------------------------------------
      int initTcpClient( const std::string & rstrHostname, unsigned int uiPort, int iSecTimeOut );
      //-----------------------------------------------------------------------
 
    public:
      //============== Methoden
      //-----------------------------------------------------------------------
      Client * tcpClient();
      //-----------------------------------------------------------------------
      void setOrderstop( bool bOrderstop = true );
      //-----------------------------------------------------------------------
      bool Orderstop() const;
      //-----------------------------------------------------------------------
      void setSchemaMap( std::map< unsigned long, ClassInfo *> * pSchemaMap );
      //-----------------------------------------------------------------------
      const std::map< unsigned long, ClassInfo *> * getSchemaMap();
      //-----------------------------------------------------------------------
      virtual int assignDBManager( OrderMsg * pOrderMsg ) override;
      //-----------------------------------------------------------------------
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      #if defined (__PTHREADS)
      virtual void cleanUp();
      //-----------------------------------------------------------------------
      #else
 
    public:
      //============== Methoden
    //-------------------------------------------------------------------------
      virtual void cancel() override;
      //-----------------------------------------------------------------------
      #endif
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual int sendToDBManager( OrderMsg * pOrderMsg ) const override;
      //-----------------------------------------------------------------------
      void deleteSchemaMap();
      //-----------------------------------------------------------------------
 
    public:
      //============== Operatoren
      //-----------------------------------------------------------------------
      bool operator== ( const ClientThread & rT ) const;
      bool operator!= ( const ClientThread & rT ) const;
      //-----------------------------------------------------------------------
 
    private:
      //============== Operatoren
      //-----------------------------------------------------------------------
      ClientThread & operator= ( const ClientThread & );
      //-----------------------------------------------------------------------
  };
  //---------------------------------------------------------------------------
} // namespace glo
#endif