WatchCallMessageProcessor.hpp

Go to the documentation of this file.

 
 
#ifndef IV_SRC_COMMS_CAN_WATCHCALLMESSAGEPROCESSOR_HPP_
#define IV_SRC_COMMS_CAN_WATCHCALLMESSAGEPROCESSOR_HPP_
 
#include "alarms/WatchcallManager.hpp"
#include "comms/can/AbstractMessageProcessor.hpp"
#include "comms/can/LomCommunicationController.hpp"
 
namespace iv::comms::can
{
 
class WatchCallMessageProcessor final : public iv::comms::can::AbstractMessageProcessor,
                                        public std::enable_shared_from_this<WatchCallMessageProcessor>
{
public:
    WatchCallMessageProcessor(const std::shared_ptr<iv::comms::can::LomCommunicationController> &controller,
                              iv::comms::eLomLine line,
                              const std::shared_ptr<iv::alarms::WatchcallManager> &repeaterManager);
    ~WatchCallMessageProcessor() override;
    bool frameProcess() const;
 
    void initialize() override;
 
private:
    bool sendFrame() const;
    bool receiveFrame() const;
    std::shared_ptr<iv::comms::can::LomCommunicationController> m_controller;
    std::shared_ptr<iv::alarms::WatchcallManager> m_repeaterManager;
    std::unique_ptr<iv::threads::Thread> m_thread;
    void updateSlimStatus(const std::shared_ptr<CMessageCan> &message) const;
    void processCommand(const std::shared_ptr<CMessageCan> &message) const;
    void processHeartbeat(const std::shared_ptr<CMessageCan> &message) const;
 
    iv::comms::eLomLine m_line;
    iv::types::unitId stationUnitId;
    iv::model::eShipArea stationArea;
 
    iv::types::timestamp startTime {0};
};
 
}// namespace iv::comms::can
 
#endif//IV_SRC_COMMS_CAN_WATCHCALLMESSAGEPROCESSOR_HPP_