threaddispatch.hh

Go to the documentation of this file.

#ifndef _DRAMA2_THREADDISPATCH_INC
#define _DRAMA2_THREADDISPATCH_INC
 
/*
 * History:
     29-Sep-2020 - TJF - Original version
 
 * The above ID is for Doxygen, this one has the format ACMM is looking for.
 * "@(#) $Id$"
 */
#include "drama.hh"
#include "drama/path.hh"
namespace drama { 
 
    class ThreadDispatcher {
 
    private:
        
        drama::Task           *_theTask;          /* DRAMA Task reference */
        std::string           _threadName;        /* For log messages */
        std::string           _messageName;       /* Message name */
        std::future<void>     _future;            /* Used to manage the thread */
        bool                  _running  =  false; /* Is the thread running? */
 
        std::string           _targetTaskName;    /* Name of the task we are sending message to */
 
        /*
         *  Invoked to run the thread.
         */
        void runThread(drama::thread::TMessHandler *messHandler,
                       drama::Path *path,
                       sds::IdPtr arg);
 
        virtual void SendMessage(drama::thread::TMessHandler *messHandler,
                                 const std::string &messageName,
                                 drama::Path *path,
                                 sds::IdPtr arg) = 0;
 
        virtual std::string MessageTypeName() const = 0;
    public:
        ThreadDispatcher(drama::Task *theTask,
                         const std::string &threadName,
                         const std::string &messageName) :
            _theTask(theTask),  _threadName(threadName), _messageName(messageName) {}
        
        virtual ~ThreadDispatcher() {}
 
        bool IsRunning()  { return _running; }
 
        bool CheckResult(StatusType *status);
        
        void Send(drama::thread::TMessHandler *messHandler,
                  drama::Path *path,
                  sds::IdPtr arg = nullptr);
    };
 
    class ObeyThreadDispatcher : public ThreadDispatcher {
 
    public:
        using ThreadDispatcher::ThreadDispatcher;
    private:
        void SendMessage(drama::thread::TMessHandler *messHandler,
                         const std::string &messageName,
                         drama::Path *path,
                         sds::IdPtr arg) override;
        
        virtual std::string MessageTypeName() const override;
        
 
    };
 
} // namespace drama
 
#endif