procThread.hpp

Go to the documentation of this file.

 
#ifndef CCF_CONTROL_PROC_THREAD_HPP_H_
#define CCF_CONTROL_PROC_THREAD_HPP_H_
 
#include <ccf/common/base.hpp>
#include <ccf/common/utilities.hpp>
#include <ccf/common/frameQueue.hpp>
#include <ccf/common/recipeBase.hpp>
 
namespace ccf::control {
 
  class ProcThread: public ccf::mptk::Thread, public ccf::Base {
  public:
 
    static void SetStatusAll(const ccf::ProcStatus status);
 
    ProcThread(const std::string& thread_name,
               ccf::mptk::MessageBus& message_bus,
               const double period = 0.1);
 
    virtual ~ProcThread();
 
    void Initialise();
 
    virtual void UserLogic();
 
    void SetInputQ(std::shared_ptr<ccf::common::FrameQueue>& queue);
 
    ccf::common::FrameQueue& GetInputQ();
 
    void SetOutputQ(std::shared_ptr<ccf::common::FrameQueue>& queue);
 
    ccf::common::FrameQueue& GetOutputQ();
 
    void SetStatus(const ccf::ProcStatus status);
 
    ccf::ProcStatus GetStatus() const;
 
    // TODO: Remove these. Use the repository in ccf::common::RecipeBase.
    void AddRecipe(std::shared_ptr<ccf::common::RecipeBase>& recipe_obj);
    uint8_t NbOfRecipes() const;
    const ccf::common::RecipeBase& GetRecipe(const uint16_t nb);
 
    ccf::common::FrameStatistics& GetFrameStat();
 
  protected:
 
  private:
    bool _CheckMessageBus(bool& new_data_available,
                          bool& new_setup);
    void _CopyAndReleaseFrameHandle();
    void _ExecuteRecipes();
    void _SubmitAndNotify();
    void _HandleNewSetup();
 
    bool     m_allow_frame_skippping;
    double   m_time_for_last_frame_skipping_log;
 
    // Names of Publisher Threads associated with this Processing Thread.
    std::vector<std::string> m_pub_thr_names;
 
    ccf::ProcStatus m_proc_thread_status;  // Used to avoid updating OLDB/PubSub unnecessarily.
 
    std::list<std::shared_ptr<ccf::common::RecipeBase>> m_recipes;
 
    // Map to find Recipe objects easily by means of the Instance ID.
    std::map<std::string, std::shared_ptr<ccf::common::RecipeBase>> m_recipe_map;
 
    // Note: The queues are allocated and deleted by the ccf::control::application class.
    std::shared_ptr<ccf::common::FrameQueue>      m_input_q;
    std::shared_ptr<ccf::common::FrameQueue>      m_output_q;
 
    ccf::mptk::Message            m_cur_msg;   // Current thread message being handled.
    ccf::common::DataFrame        m_cur_frame; // Current data frame being handled.
 
    ccf::common::FrameStatistics  m_frame_stat;
 
    bool                          m_pipeline_enabled;
  };
 
}
 
#endif // CCF_CONTROL_PROC_THREAD_HPP_H_