GloCommunicator.h

Go to the documentation of this file.

#ifndef INC_GLOCOMMUNICATOR_H
#define INC_GLOCOMMUNICATOR_H
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
#include <string>
#include <queue>
#include "GloTypes.h"
#include "GloCallBackSpy.h"
#if defined (__PTHREADS)
  #include <EuEndlessPThread.h>
  #include <semaphore.h>
#else
  #include "EuRepeatingThread.h"
#endif
//-----------------------------------------------------------------------------
namespace glo
{
  //---------------------------------------------------------------------------
  /* Forwards */
  class OrderMsg;
  //---------------------------------------------------------------------------
  #ifdef _MSC_VER
    /* 'Bezeichner': Klasse 'Typ' benötigt eine DLL-Schnittstelle, die von... */
    #pragma warning( disable : 4251 )
  #endif
  //---------------------------------------------------------------------------
  #if defined (__PTHREADS)
    class __glo_export_dll Communicator : public EuEndlessPThread
  #else
    class __glo_export_dll Communicator : public eut::RepeatingThread
  #endif
  {
    private:
      //============== Attribute
      //-----------------------------------------------------------------------
      unsigned int m_uiID;
      //-----------------------------------------------------------------------
      std::string m_sClientName;
      //-----------------------------------------------------------------------
      std::queue<OrderMsg *> m_MsgQueue;
      //-----------------------------------------------------------------------
 
    protected:
      //============== Attribute
      //-----------------------------------------------------------------------
      unsigned int m_uiOrderCounter;
      //-----------------------------------------------------------------------
 
    public:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      Communicator();
      //-----------------------------------------------------------------------
      virtual ~Communicator();
      //-----------------------------------------------------------------------
 
    private:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      Communicator( const Communicator & );
      //-----------------------------------------------------------------------
 
    public:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual void setCommunicatorID( unsigned int uiID );
      //-----------------------------------------------------------------------
      unsigned int getCommunicatorID() const;
      //-----------------------------------------------------------------------
      virtual void setClientName( const std::string & rstrClientName );
      //-----------------------------------------------------------------------
      std::string getClientName() const;
      //-----------------------------------------------------------------------
      const std::string & getClientNameAsRef();
      //-----------------------------------------------------------------------
      virtual int takeOverResult( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      virtual int assignDBManager( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      virtual int sendToDBManager( OrderMsg * pOrderMsg ) const = 0;
      //-----------------------------------------------------------------------
      virtual void processServerMsg( OrderMsg * pOrderMsg ) const;
      //-----------------------------------------------------------------------
      virtual void work() override;
      //-----------------------------------------------------------------------
 
    public:
      //============== Operatoren
      //-----------------------------------------------------------------------
      bool operator== ( const Communicator & rT ) const;
      bool operator!= ( const Communicator & rT ) const;
      //-----------------------------------------------------------------------
 
    private:
      //============== Operatoren
      //-----------------------------------------------------------------------
      Communicator & operator= ( const Communicator & );
      //-----------------------------------------------------------------------
  };
  //---------------------------------------------------------------------------
  #ifdef _MSC_VER
    /* 'Bezeichner': Klasse 'Typ' benötigt eine DLL-Schnittstelle, die von... */
    #pragma warning( default : 4251 )
  #endif
  //---------------------------------------------------------------------------
} // namespace glo
#endif