testManagerHelper.cpp

Go to the documentation of this file.

 
#include <ifw/ccf/mptk/thread.hpp>
 
class TestThread: public ifw::ccf::mptk::Thread {
public:
    TestThread(const std::string& thread_name,
               ifw::ccf::mptk::MessageBus& message_bus,
               const double period = 0.1):
        ifw::ccf::mptk::Thread(thread_name, message_bus, period) {
        m_msg_count = 0;
    };
 
    ~TestThread() {
        // No special clean up to do here -- nothing was allocated etc ...
    };
 
    void UserLogic() {
        std::map<std::string, std::string>
                receiver_threads = {{"ThreadA", "ThreadB"}, {"ThreadB", "ThreadC"},
                                    {"ThreadC", "ThreadD"}, {"ThreadD", "MainThread"}};
        bool timed_out;
        ifw::ccf::mptk::Message message;
        if (MsgBus().ReceiveMessage(GetName(), 1, timed_out, message)) {
            std::string data = fmt::format("{}/{}. Data: {}", GetName().c_str(),
                                           ++m_msg_count, message.Data().c_str());
            ifw::ccf::mptk::Message new_message("TestCmd", ifw::ccf::mptk::MsgPrio::HIGH, GetName(),
                                           receiver_threads[GetName()], data);
            MsgBus().SendMessage(new_message);
        }
    };
 
private:
    int16_t m_msg_count;
};