ModbusCommunicationTcpProtocol.hpp

Go to the documentation of this file.

#ifndef IV_SRC_COMMS_MODBUS_MODBUSCOMMUNICATIONTCPPROTOCOL_HPP_
#define IV_SRC_COMMS_MODBUS_MODBUSCOMMUNICATIONTCPPROTOCOL_HPP_
 
#include "comms/modbus/AbstractModbusCommunicationProtocol.hpp"
 
namespace iv::comms::modbus
{
 
class ModbusCommunicationTcpProtocol final : public iv::comms::modbus::AbstractModbusCommunicationProtocol
{
public:
    ModbusCommunicationTcpProtocol() = delete;
    ModbusCommunicationTcpProtocol(
            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 std::weak_ptr<iv::diamar::AppFailuresLoggerManager> &appFailuresLoggerManager,
            const iv::types::networkId &netId, std::weak_ptr<iv::channels::AbstractChannel> &heartbeatChannel);
    ModbusCommunicationTcpProtocol(const ModbusCommunicationTcpProtocol &other) = delete;
    ModbusCommunicationTcpProtocol(ModbusCommunicationTcpProtocol &&other) = delete;
    ~ModbusCommunicationTcpProtocol() override = default;
 
    ModbusCommunicationTcpProtocol &operator=(const ModbusCommunicationTcpProtocol &other) = delete;
    ModbusCommunicationTcpProtocol &operator=(ModbusCommunicationTcpProtocol &&other) = delete;
 
    bool writeQueries() override;
    bool readQueries() override;
 
private:
    std::map<iv::types::comms::tcpPacketId, std::vector<iv::types::comms::modbus::modbusAddress>>
            m_transactionIdToAddress;
    void processModbusResponse(iv::comms::modbus::ModbusResponseMessage response);
 
    bool prvProcessQueries(const std::vector<iv::comms::modbus::ModbusQueryMessage> &queries);
};
 
}// namespace iv::comms::modbus
 
#endif//IV_SRC_COMMS_MODBUS_MODBUSCOMMUNICATIONTCPPROTOCOL_HPP_