ModbusTCPMaster.h

#ifndef ModbusTCPMaster_H_
#define ModbusTCPMaster_H_
// -------------------------------------------------------------------------
#include <memory>
#include <string>
#include <queue>
#include <Poco/Net/SocketStream.h>
#include "UTCPStream.h"
#include "ModbusTypes.h"
#include "ModbusClient.h"
// -------------------------------------------------------------------------
namespace uniset
{
// -------------------------------------------------------------------------
class ModbusTCPMaster:
    public ModbusClient
{
    public:

        ModbusTCPMaster();
        virtual ~ModbusTCPMaster();

        bool connect( const std::string& addr, int port, bool closeOldConnection = true ) noexcept;
        bool connect( const Poco::Net::SocketAddress& addr, int _port, bool closeOldConnection = true ) noexcept;

        void disconnect();
        void forceDisconnect();
        bool isConnection() const;

        static bool checkConnection( const std::string& ip, int port, int timeout_msec = 100 );

        inline void setForceDisconnect( bool s )
        {
            force_disconnect = s;
        }

        bool reconnect();
        void cleanInputStream();

        virtual void cleanupChannel() override
        {
            cleanInputStream();
        }

        inline std::string getAddress() const
        {
            return iaddr;
        }
        inline int getPort() const
        {
            return port;
        }

        void setReadTimeout( timeout_t msec );
        timeout_t getReadTimeout() const;

    protected:

        virtual size_t getNextData(unsigned char* buf, size_t len ) override;
        virtual void setChannelTimeout( timeout_t msec ) override;
        virtual ModbusRTU::mbErrCode sendData( unsigned char* buf, size_t len ) override;
        virtual ModbusRTU::mbErrCode query( ModbusRTU::ModbusAddr addr, ModbusRTU::ModbusMessage& msg,
                                            ModbusRTU::ModbusMessage& reply, timeout_t timeout ) override;

    private:
        //ost::TCPStream* tcp;
        std::shared_ptr<UTCPStream> tcp;
        ModbusRTU::ModbusData nTransaction;
        std::queue<unsigned char> qrecv;
        PassiveTimer ptTimeout;
        std::string iaddr = { "" };
        int port = { 0 };
        bool force_disconnect = { false };
        int keepAliveTimeout = { 1000 };

        timeout_t readTimeout = { 50 }; // timeout на чтение очередной порции данных
};
// -------------------------------------------------------------------------
} // end of namespace uniset
// -------------------------------------------------------------------------
#endif // ModbusTCPMaster_H_
// -------------------------------------------------------------------------