---

CChainTask.hpp

Go to the documentation of this file.

#ifndef CChainTask_h
#define CChainTask_h 1

// CTask
#include "jic/task/CTask.hpp"
#include "jic/task/CMessageBlock.hpp"

namespace TASK {
  template <class MessageType> class CTasksChainControler;

} // namespace TASK

namespace TASK {

  //    Clase que auna funcionalidad común a una cadena objetos,
  //    y clase padre de todos los objetos de la cadena.
  //    - El objeto no es instanciable
  //    Notas:
  //    - De momento solo se soporta un controlador por cadena
  //    de produccion.
  //    - @@ La problematica de más de 1 cotnrolador está en que
  //    si una tarea se pone como error o se para y la siguiente
  //    está bajo otro controlador, habrá que decidir como se
  //    actua (pegar a esto una pensada)

  template <class MessageType>
  class CChainTask : public CTask  
  {

    public:
        CChainTask();

        CChainTask (std::string strName, int nThreads = 1, CTasksChainControler<MessageType> *pTaskControler = 0);

        virtual ~CChainTask();

        virtual EStoppingWay stoppingWay ();

        //      Se ha creado a pelusqui, ya que Rational no la generaba
        //      correctamente automáticamente (será por lo de ser un ptr
        //      a template).
        CChainTask<MessageType> * get_pNext ();

        //      Se ha creado a pelusqui, ya que Rational no la generaba
        //      correctamente automáticamente (será por lo de ser un ptr
        //      a template).
        void set_pNext (CChainTask<MessageType> *pNext);

        //      Funcion que permite a un cliente meter desde fuera
        //      mensajes en la cola de entrada del task
        //      Nos aseguramos que el tipo sea correcto
        void put(CMessageBlock<MessageType> *data);
        
        //      Version que se encarga de la creación del bloque
        void put(MessageType *data);

    protected:

        //      Metodo a invocar para poner los mensajes en la cola de
        //      salida
        void msgToOutput (ACE_Message_Block *data) /*throw (CTaskException)*/;

        //      Metodo a invocar para obtener mensajes de la cola
        void msgFromInput (ACE_Message_Block *&data) /*throw (CTaskException)*/;

        virtual void preStoppingActions ();

        //      Metodo para implementar por lo hijos. Cada tipo de
        //      componente de la cadena realizará unas acciones
        //      especificas.
        //      En el sólo se tratarán mensajes de tipo MB_DATA
        virtual void specificStep () /* throw (CTaskException) */ = 0;

      // Additional Protected Declarations

    private:
        CChainTask(const CChainTask< MessageType > &right);

        CChainTask< MessageType > & operator=(const CChainTask< MessageType > &right);

        void step ();

        bool haveToStop () throw (CTaskException);

        //      Metodo para retirar un mensaje que sabemos que existe en
        //      la cola
        void retrieveExistingMessage (ACE_Message_Block *&data) throw (CTaskException);
        
        void putMessageToTask(CChainTask *task,ACE_Message_Block *data);

      // Additional Private Declarations

    private: 
      // Data Members for Associations

        CChainTask *m_pNext;

      // Additional Implementation Declarations

  };

  // Parameterized Class TASK::CChainTask 

  template <class MessageType>
  inline CChainTask<MessageType> * CChainTask<MessageType>::get_pNext ()
  {
    return m_pNext;
  }

  template <class MessageType>
  inline void CChainTask<MessageType>::set_pNext (CChainTask<MessageType> *pNext)
  {
    m_pNext = pNext;
  }

} // namespace TASK

#if defined (ACE_TEMPLATES_REQUIRE_SOURCE)
#include "CChainTask.cpp"
#endif /* ACE_TEMPLATES_REQUIRE_SOURCE */

#endif

---