GloCommunicaterThread.h

Go to the documentation of this file.

#ifndef INC_GLOCOMMUNICATORTHREAD_H
#define INC_GLOCOMMUNICATORTHREAD_H
//-----------------------------------------------------------------------------
//-----------------------------------------------------------------------------
#include <queue>
#include "GloTypes.h"
#include "GloTableReaderInterface.h"
#include "GloOrderMsg.h"
#if defined (__PTHREADS)
  #include <EuEndlessPThread.h>
  #include <semaphore.h>
#else
  #include "EuRepeatingThread.h"
#endif
//-----------------------------------------------------------------------------
namespace glo
{
  //---------------------------------------------------------------------------
  /* Forwards */
  class IndexQueryBaseStruct;
  //---------------------------------------------------------------------------
  #if defined (__PTHREADS)
    class CommunicaterThread : public EuEndlessPThread
  #else
    class CommunicaterThread : public eut::RepeatingThread
  #endif
 
  {
    private:
      //============== Attribute
      //-----------------------------------------------------------------------
      TableReaderInterface * m_pTableReader;
      //-----------------------------------------------------------------------
      std::queue<OrderMsg *> m_MsgQueue;
      //-----------------------------------------------------------------------
 
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      CommunicaterThread();
      //-----------------------------------------------------------------------
 
    public:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      CommunicaterThread( SchemaInterface * pSchema,
                          RealIndexPool * pRealIndexPool );
      //-----------------------------------------------------------------------
      ~CommunicaterThread();
      //-----------------------------------------------------------------------
 
    private:
      //============== Konstruktoren
      //-----------------------------------------------------------------------
      CommunicaterThread( const CommunicaterThread & );
      //-----------------------------------------------------------------------
 
    public:
      //============== Methoden
      //-----------------------------------------------------------------------
      TableReaderInterface * getReader() const;
      //-----------------------------------------------------------------------
      void takeOrder( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void clearMsgQueue();
      //-----------------------------------------------------------------------
 
    protected:
      //============== Methoden
      //-----------------------------------------------------------------------
      void getRecord( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void getObjectData( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void checkStored( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void openAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void closeAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void getObjIdFromAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void getIndexedObjIdListBySearchValueFromAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void getIndexedObjIdListByComparingFromAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void getIndexedObjIdListByRangeFromAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void getAnyIndexedObjIdListFromAllSet(  OrderMsg * pOrderMsg,
                                              IndexQueryBaseStruct * pGloIndexQueryBaseStruct );
      //-----------------------------------------------------------------------
      void setIndexFilterBySearchValueInSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void setIndexFilterByComparingInSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void setIndexFilterByRangeInSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void removeIndexFilter( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void transformIndexStrings( IndexQueryBaseStruct & rGloIndexQueryBaseStruct );
      //-----------------------------------------------------------------------
      void setAnyIndexFilterInAllSet( OrderMsg * pOrderMsg,
                                      IndexQueryBaseStruct * pGloIndexQueryBaseStruct );
      //-----------------------------------------------------------------------
      void getSizeFromAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void setCurrentObjectInAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void setPositionInAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
      void objIDInAllSet( OrderMsg * pOrderMsg );
      //-----------------------------------------------------------------------
 
      //============== Die Thread-Methode
      //-----------------------------------------------------------------------
      virtual void work() override;
      //-----------------------------------------------------------------------
      #if defined (__PTHREADS)
      virtual void cleanUp();
      //-----------------------------------------------------------------------
      #else
 
    public:
      //============== Methoden
    //-------------------------------------------------------------------------
      virtual void cancel()  override;
      //-----------------------------------------------------------------------
      #endif
 
    protected:
      //============== Operatoren
      //-----------------------------------------------------------------------
      bool operator== ( const CommunicaterThread & rT ) const;
      bool operator!= ( const CommunicaterThread & rT ) const;
      //-----------------------------------------------------------------------
 
    private:
      //============== Operatoren
      //-----------------------------------------------------------------------
      CommunicaterThread & operator= ( const CommunicaterThread & );
      //-----------------------------------------------------------------------
  };
  //---------------------------------------------------------------------------
} // namespace glo
#endif