ModbusCommunicationRtuProtocol.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_MODBUS_MODBUSCOMMUNICATIONRTUPROTOCOL_HPP_
#define IV_SRC_COMMS_MODBUS_MODBUSCOMMUNICATIONRTUPROTOCOL_HPP_
 
#include "comms/modbus/AbstractModbusCommunicationProtocol.hpp"
 
namespace iv::comms::modbus
{
 
class ModbusCommunicationRtuProtocol final : public iv::comms::modbus::AbstractModbusCommunicationProtocol
{
public:
    ModbusCommunicationRtuProtocol() = delete;
    explicit ModbusCommunicationRtuProtocol(
            const std::shared_ptr<iv::comms::ICommunicationDriver> &driver,
            const iv::model::comms::modbus::Settings &settings,
            const std::map<iv::types::comms::modbus::modbusAddressAndFunction,
                           std::vector<std::shared_ptr<iv::channels::AbstractChannel>>> &channelsOrderedByAddress,
            const iv::types::networkId &netId,
            const std::weak_ptr<iv::diamar::AppFailuresLoggerManager> &appFailuresLoggerManager,
            std::weak_ptr<iv::channels::AbstractChannel> &heartbeatChannel);
    ModbusCommunicationRtuProtocol(const ModbusCommunicationRtuProtocol &other) = delete;
    ModbusCommunicationRtuProtocol(ModbusCommunicationRtuProtocol &&other) = delete;
    ~ModbusCommunicationRtuProtocol() override = default;
 
    ModbusCommunicationRtuProtocol &operator=(const ModbusCommunicationRtuProtocol &other) = delete;
    ModbusCommunicationRtuProtocol &operator=(ModbusCommunicationRtuProtocol &&other) = delete;
 
    bool writeQueries() override;
    bool readQueries() override;
 
private:
    void processModbusResponse(const iv::comms::modbus::ModbusQueryMessage &query,
                               iv::comms::modbus::ModbusResponseMessage response);
 
    bool prvProcessQueries(const std::vector<iv::comms::modbus::ModbusQueryMessage> &queries);
};
 
}// namespace iv::comms::modbus
 
#endif//IV_SRC_COMMS_MODBUS_MODBUSCOMMUNICATIONRTUPROTOCOL_HPP_