ModbusClient.h

// -------------------------------------------------------------------------
#ifndef ModbusClient_H_
#define ModbusClient_H_
// -------------------------------------------------------------------------
#include <string>
#include <memory>
#include "Mutex.h"
#include "Debug.h"
#include "Configuration.h"
#include "PassiveTimer.h"
#include "ModbusTypes.h"
// -------------------------------------------------------------------------
namespace uniset
{
    // -------------------------------------------------------------------------
    class ModbusClient
    {
        public:
 
            ModbusClient();
            virtual ~ModbusClient();
 
            // ------------- Modbus-функции ----------------------------------------
            ModbusRTU::ReadCoilRetMessage read01( ModbusRTU::ModbusAddr addr,
                                                  ModbusRTU::ModbusData start, ModbusRTU::ModbusData count );
 
            ModbusRTU::ReadInputStatusRetMessage read02( ModbusRTU::ModbusAddr addr,
                    ModbusRTU::ModbusData start, ModbusRTU::ModbusData count );
 
 
            ModbusRTU::ReadOutputRetMessage read03( ModbusRTU::ModbusAddr addr,
                                                    ModbusRTU::ModbusData start, ModbusRTU::ModbusData count );
 
            ModbusRTU::ReadInputRetMessage read04( ModbusRTU::ModbusAddr addr,
                                                   ModbusRTU::ModbusData start, ModbusRTU::ModbusData count );
 
            ModbusRTU::ForceSingleCoilRetMessage write05( ModbusRTU::ModbusAddr addr,
                    ModbusRTU::ModbusData reg, bool cmd );
 
            ModbusRTU::WriteSingleOutputRetMessage write06( ModbusRTU::ModbusAddr addr,
                    ModbusRTU::ModbusData reg, ModbusRTU::ModbusData data );
 
            ModbusRTU::ForceCoilsRetMessage write0F( ModbusRTU::ForceCoilsMessage& msg );
 
            ModbusRTU::WriteOutputRetMessage write10( ModbusRTU::WriteOutputMessage& msg );
 
            ModbusRTU::DiagnosticRetMessage diag08( ModbusRTU::ModbusAddr addr,
                                                    ModbusRTU::DiagnosticsSubFunction subfunc,
                                                    ModbusRTU::ModbusData dat = 0 );
 
            ModbusRTU::MEIMessageRetRDI read4314( ModbusRTU::ModbusAddr addr,
                                                  ModbusRTU::ModbusByte devID,
                                                  ModbusRTU::ModbusByte objID );
 
            ModbusRTU::SetDateTimeRetMessage setDateTime( ModbusRTU::ModbusAddr addr,
                    ModbusRTU::ModbusByte hour, ModbusRTU::ModbusByte min, ModbusRTU::ModbusByte sec,
                    ModbusRTU::ModbusByte day, ModbusRTU::ModbusByte mon, ModbusRTU::ModbusByte year,
                    ModbusRTU::ModbusByte century );
 
 
            ModbusRTU::FileTransferRetMessage partOfFileTransfer( ModbusRTU::ModbusAddr addr, ModbusRTU::ModbusData idFile,
                    ModbusRTU::ModbusData numpack, timeout_t part_timeout_msec = 2000 );
 
            void fileTransfer( ModbusRTU::ModbusAddr addr, ModbusRTU::ModbusData idFile,
                               const std::string& save2filename, timeout_t part_timeout_msec = 2000 );
 
            // ---------------------------------------------------------------------
            void setTimeout( timeout_t msec );
 
            int setAfterSendPause( timeout_t msec );
 
            inline void setSleepPause( timeout_t usec )
            {
                sleepPause_usec = usec;
            }
 
            void initLog( std::shared_ptr<uniset::Configuration> conf, const std::string& name, const std::string& logfile = "" );
            void setLog( std::shared_ptr<DebugStream> dlog );
 
            inline void setCRCNoCheckit( bool set )
            {
                crcNoCheckit = set;
            }
            inline bool isCRCNoCheckit() const
            {
                return crcNoCheckit;
            }
 
            virtual void cleanupChannel() {}
 
        protected:
 
            virtual size_t getNextData( unsigned char* buf, size_t len ) = 0;
 
            virtual void setChannelTimeout( timeout_t msec ) = 0;
 
            virtual ModbusRTU::mbErrCode sendData( unsigned char* buf, size_t len ) = 0;
 
            virtual ModbusRTU::mbErrCode query( ModbusRTU::ModbusAddr addr, ModbusRTU::ModbusMessage& msg,
                                                ModbusRTU::ModbusMessage& qreply, timeout_t timeout ) = 0;
 
            // -------------------------------------
            virtual ModbusRTU::mbErrCode send( ModbusRTU::ModbusMessage& msg );
 
            virtual ModbusRTU::mbErrCode recv( ModbusRTU::ModbusAddr addr, ModbusRTU::ModbusByte qfunc,
                                               ModbusRTU::ModbusMessage& rbuf, timeout_t timeout );
 
            virtual ModbusRTU::mbErrCode recv_pdu( ModbusRTU::ModbusByte qfunc,
                                                   ModbusRTU::ModbusMessage& rbuf, timeout_t timeout );
 
            timeout_t replyTimeOut_ms;    
            timeout_t aftersend_msec;    
            timeout_t sleepPause_usec;     
            bool crcNoCheckit;
 
            uniset::uniset_rwmutex sendMutex;
            std::shared_ptr<DebugStream> dlog;
 
            void printProcessingTime();
            PassiveTimer tmProcessing;
 
        private:
 
            ModbusRTU::ModbusMessage qreply;   
            ModbusRTU::ModbusMessage qbuf;     
    };
    // -------------------------------------------------------------------------
} // end of namespace uniset
// -------------------------------------------------------------------------
#endif // ModbusClient_H_
// -------------------------------------------------------------------------