manager.hpp

Go to the documentation of this file.

 
#ifndef CCF_MPTK_MANAGER_HPP_
#define CCF_MPTK_MANAGER_HPP_
 
#include <core/utils/system/system.hpp>
 
#include <ccf/mptk/message.hpp>
#include <ccf/mptk/thread.hpp>
 
// TODO: Make own logger for this library. Remove all RAD_LOG_TRACE etc.
 
namespace ccf::mptk {
 
  class Manager {
  public:
 
    Manager();
 
    ~Manager();
 
    void Reset();
 
    void StartThreads();
 
    void PauseThreads();
 
    void StopThreads();
 
    int16_t WaitForThreadTerm(const double time_out = core::utils::base::NO_TIMEOUT);
 
    int16_t NbOfThreadsRunning() const;
 
    MessageBus& MsgBus();
 
    std::string ToString() const;
 
    template <class THREAD_TYPE>
    void CreateThread(const std::string& thread_id,
                      const double period = 0.1,
                      THREAD_TYPE** thread_obj = nullptr) {
      RAD_LOG_TRACE();
 
      BEGIN_CRIT_SEC(m_mgr_id) {
        m_threads[thread_id] = std::make_shared<THREAD_TYPE>(thread_id, MsgBus(), period);
        if (m_threads[thread_id].get() == nullptr) {
          throw rad::Exception(fmt::format("Could not create thread with ID: %s in MPTK instance", thread_id.c_str()));
        }
        MsgBus().RegisterThread(thread_id);
      } END_CRIT_SEC();
      if (thread_obj != nullptr) {
        *thread_obj = static_cast<THREAD_TYPE*>(m_threads[thread_id].get());
      } 
    }
 
    template <class THREAD_TYPE>
    void CreateThread(const THREAD_TYPE& factory_object,
                      const std::string& thread_id,
                      const double period = 0.1,
                      THREAD_TYPE** thread_obj = nullptr) {
      RAD_LOG_TRACE();
 
      BEGIN_CRIT_SEC(m_mgr_id) {
        m_threads[thread_id] = std::make_shared<THREAD_TYPE>(thread_id, MsgBus(), period);
        if (m_threads[thread_id].get() == nullptr) {
          throw rad::Exception(fmt::format("Could not create thread with ID: %s in MPTK instance", thread_id.c_str()));
        }
        MsgBus().RegisterThread(thread_id);
      } END_CRIT_SEC();
      if (thread_obj != nullptr) {
        *thread_obj = static_cast<THREAD_TYPE*>(m_threads[thread_id].get());
      }
    }
 
    template <class THREAD_TYPE>
    void GetThread(const std::string& thread_id,
                   THREAD_TYPE** thread_obj) {
      RAD_LOG_TRACE();
 
      core::utils::system::Mutex tmp_mutex(m_mgr_id); { 
      //BEGIN_CRIT_SEC(m_mgr_id) 
        auto thr_obj_it = m_threads.find(thread_id);
        if (thr_obj_it == m_threads.end()) {
            throw rad::Exception(fmt::format("%s: Undefined Thread ID: %s",
                                            m_mgr_id.c_str(), thread_id.c_str()));
          }
        *thread_obj = static_cast<THREAD_TYPE*>(thr_obj_it->second.get());
        } // END_CRIT_SEC();
 
    }
 
    void GetThreadIds(std::list<std::string>& thread_ids) const;
 
  private:
    std::string                    m_mgr_id;
    MessageBus                     m_message_bus;
    std::map<std::string, std::shared_ptr<Thread>> m_threads;
  };
 
}
 
#endif // CCF_MPTK_MANAGER_HPP_