MBTCPTestServer.h

#ifndef MBTCPTestServer_H_
#define MBTCPTestServer_H_
// -------------------------------------------------------------------------
#include <string>
#include <atomic>
#include <ostream>
#include <unordered_set>
#include "ThreadCreator.h"
#include "modbus/ModbusTCPServerSlot.h"
// -------------------------------------------------------------------------
class MBTCPTestServer
{
    public:
        MBTCPTestServer( const std::unordered_set<ModbusRTU::ModbusAddr>& vaddr, const std::string& inetaddr, int port = 502, bool verbose = false );
        ~MBTCPTestServer();

        inline void setVerbose( bool state )
        {
            verbose = state;
        }

        inline void setReply( long val )
        {
            replyVal = val;
        }

        inline void setIgnoreAddrMode( bool state )
        {
            if( sslot )
                sslot->setIgnoreAddrMode(state);
        }

        void runThread(); 
        void execute();    
        void setLog( std::shared_ptr<DebugStream> dlog );

        inline bool isRunning()
        {
            return isrunning;
        }

        inline void disableExchange( bool set = true )
        {
            disabled = set;
        }

        inline bool getForceSingleCoilCmd()
        {
            return forceSingleCoilCmd;
        }
        inline int getLastWriteOutputSingleRegister()
        {
            return lastWriteOutputSingleRegister;
        }
        inline ModbusRTU::ForceCoilsMessage getLastForceCoilsQ()
        {
            return lastForceCoilsQ;
        }
        inline ModbusRTU::WriteOutputMessage getLastWriteOutput()
        {
            return lastWriteOutputQ;
        }

        friend std::ostream& operator<<(std::ostream& os, const MBTCPTestServer* m );

        inline float getF2TestValue()
        {
            return f2_test_value;
        }

    protected:
        // действия при завершении работы
        void sigterm( int signo );

        ModbusRTU::mbErrCode readCoilStatus( ModbusRTU::ReadCoilMessage& query,
                                             ModbusRTU::ReadCoilRetMessage& reply );
        ModbusRTU::mbErrCode readInputStatus( ModbusRTU::ReadInputStatusMessage& query,
                                              ModbusRTU::ReadInputStatusRetMessage& reply );

        ModbusRTU::mbErrCode readOutputRegisters( ModbusRTU::ReadOutputMessage& query,
                ModbusRTU::ReadOutputRetMessage& reply );

        ModbusRTU::mbErrCode readInputRegisters( ModbusRTU::ReadInputMessage& query,
                ModbusRTU::ReadInputRetMessage& reply );

        ModbusRTU::mbErrCode forceSingleCoil( ModbusRTU::ForceSingleCoilMessage& query,
                                              ModbusRTU::ForceSingleCoilRetMessage& reply );

        ModbusRTU::mbErrCode forceMultipleCoils( ModbusRTU::ForceCoilsMessage& query,
                ModbusRTU::ForceCoilsRetMessage& reply );


        ModbusRTU::mbErrCode writeOutputRegisters( ModbusRTU::WriteOutputMessage& query,
                ModbusRTU::WriteOutputRetMessage& reply );

        ModbusRTU::mbErrCode writeOutputSingleRegister( ModbusRTU::WriteSingleOutputMessage& query,
                ModbusRTU::WriteSingleOutputRetMessage& reply );


        ModbusRTU::mbErrCode diagnostics( ModbusRTU::DiagnosticMessage& query,
                                          ModbusRTU::DiagnosticRetMessage& reply );

        ModbusRTU::mbErrCode read4314( ModbusRTU::MEIMessageRDI& query,
                                       ModbusRTU::MEIMessageRetRDI& reply );

        ModbusRTU::mbErrCode journalCommand( ModbusRTU::JournalCommandMessage& query,
                                             ModbusRTU::JournalCommandRetMessage& reply );

        ModbusRTU::mbErrCode setDateTime( ModbusRTU::SetDateTimeMessage& query,
                                          ModbusRTU::SetDateTimeRetMessage& reply );

        ModbusRTU::mbErrCode remoteService( ModbusRTU::RemoteServiceMessage& query,
                                            ModbusRTU::RemoteServiceRetMessage& reply );

        ModbusRTU::mbErrCode fileTransfer( ModbusRTU::FileTransferMessage& query,
                                           ModbusRTU::FileTransferRetMessage& reply );


        ModbusTCPServerSlot* sslot;
        std::unordered_set<ModbusRTU::ModbusAddr> vaddr; 
        bool verbose;
        long replyVal;
        bool forceSingleCoilCmd;
        int lastWriteOutputSingleRegister;
        ModbusRTU::ForceCoilsMessage lastForceCoilsQ;
        ModbusRTU::WriteOutputMessage lastWriteOutputQ;
        float f2_test_value = {0.0};

#if 0
        typedef std::map<ModbusRTU::mbErrCode, unsigned int> ExchangeErrorMap;
        ExchangeErrorMap errmap;     
        ModbusRTU::mbErrCode prev;


        // можно было бы сделать unsigned, но аналоговые датчики у нас имеют
        // тип long. А это число передаётся в графику в виде аналогового датчика
        long askCount;    
        typedef std::map<int, std::string> FileList;
        FileList flist;
#endif

    private:
        ThreadCreator<MBTCPTestServer>* thr;
        std::atomic_bool isrunning;
        bool disabled;
        std::string myname;
};
// -------------------------------------------------------------------------
#endif // MBTCPTestServer_H_
// -------------------------------------------------------------------------