testThreadHelper.cpp

Go to the documentation of this file.

 
#include <ifw/ccf/mptk/thread.hpp>
 
 
class TestThread1: public ifw::ccf::mptk::Thread {
public:
    TestThread1(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;
    };
 
    ~TestThread1() {};
 
    void UserLogic() {
        bool timed_out;
        ifw::ccf::mptk::Message message;
        if (MsgBus().ReceiveMessage(GetName(), 1, timed_out, message)) {
            ifw::ccf::mptk::Response
                    response(message, "OK", fmt::format("{} received msg# {}. Data: {}",
                                                        GetName().c_str(), ++m_msg_count,
                                                        message.Data().c_str()));
            MsgBus().SendResponse(response);
        }
    };
 
private:
    int8_t m_msg_count;
};