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 );
 
            void setForceDisconnect( bool s );
 
            bool reconnect();
            void cleanInputStream();
 
            virtual void cleanupChannel() override;
 
            std::string getAddress() const;
            int getPort() const;
 
            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_
// -------------------------------------------------------------------------