UniSet  2.24.2
ModbusTCPSession.h
1 // -------------------------------------------------------------------------
2 #ifndef ModbusTCPSession_H_
3 #define ModbusTCPSession_H_
4 // -------------------------------------------------------------------------
5 #include <string>
6 #include <queue>
7 #include <unordered_map>
8 #include <ev++.h>
9 #include "ModbusServerSlot.h"
10 #include "ModbusServer.h"
11 #include "PassiveTimer.h"
12 #include "UTCPCore.h"
13 #include "UTCPStream.h"
14 // -------------------------------------------------------------------------
15 namespace uniset
16 {
17  // -------------------------------------------------------------------------
34  public ModbusServerSlot,
35  public ModbusServer
36  {
37  public:
38 
39  ModbusTCPSession( const Poco::Net::StreamSocket& s, const std::unordered_set<ModbusRTU::ModbusAddr>& vmbaddr, timeout_t timeout );
40  virtual ~ModbusTCPSession();
41 
42  void cleanInputStream();
43 
44  virtual void cleanupChannel() override;
45  virtual void terminate() override;
46 
47  typedef sigc::slot<void, const ModbusTCPSession*> FinalSlot;
48 
49  void connectFinalSession( FinalSlot sl );
50 
51  std::string getClientAddress() const;
52 
53  void setSessionTimeout( double t );
54 
55  // запуск обработки входящих запросов
56  void run( ev::loop_ref& loop );
57 
58  virtual bool isActive() const override;
59 
60  protected:
61 
62  virtual void iowait( timeout_t msec ) override;
63 
64  virtual ModbusRTU::mbErrCode realReceive( const std::unordered_set<ModbusRTU::ModbusAddr>& vmbaddr, timeout_t msecTimeout ) override;
65 
66  void callback( ev::io& watcher, int revents );
67  void onTimeout( ev::timer& watcher, int revents );
68  virtual void readEvent( ev::io& watcher );
69  virtual void writeEvent( ev::io& watcher );
70  virtual void final();
71 
72  virtual size_t getNextData( unsigned char* buf, int len ) override;
73  virtual void setChannelTimeout( timeout_t msec ) override;
74  virtual ModbusRTU::mbErrCode sendData( unsigned char* buf, int len ) override;
75  virtual ModbusRTU::mbErrCode tcp_processing( ModbusRTU::MBAPHeader& mhead );
76  virtual ModbusRTU::mbErrCode make_adu_header( ModbusRTU::ModbusMessage& request ) override;
77  virtual ModbusRTU::mbErrCode post_send_request(ModbusRTU::ModbusMessage& request ) override;
78 
79  virtual ModbusRTU::mbErrCode readCoilStatus( ModbusRTU::ReadCoilMessage& query,
80  ModbusRTU::ReadCoilRetMessage& reply ) override;
81 
82  virtual ModbusRTU::mbErrCode readInputStatus( ModbusRTU::ReadInputStatusMessage& query,
83  ModbusRTU::ReadInputStatusRetMessage& reply ) override;
84 
85  virtual ModbusRTU::mbErrCode readOutputRegisters( ModbusRTU::ReadOutputMessage& query,
86  ModbusRTU::ReadOutputRetMessage& reply ) override;
87 
88  virtual ModbusRTU::mbErrCode readInputRegisters( ModbusRTU::ReadInputMessage& query,
89  ModbusRTU::ReadInputRetMessage& reply ) override;
90 
91  virtual ModbusRTU::mbErrCode forceSingleCoil( ModbusRTU::ForceSingleCoilMessage& query,
92  ModbusRTU::ForceSingleCoilRetMessage& reply ) override;
93 
94  virtual ModbusRTU::mbErrCode writeOutputSingleRegister( ModbusRTU::WriteSingleOutputMessage& query,
96 
97  virtual ModbusRTU::mbErrCode forceMultipleCoils( ModbusRTU::ForceCoilsMessage& query,
98  ModbusRTU::ForceCoilsRetMessage& reply ) override;
99 
100  virtual ModbusRTU::mbErrCode writeOutputRegisters( ModbusRTU::WriteOutputMessage& query,
101  ModbusRTU::WriteOutputRetMessage& reply ) override;
102 
103  virtual ModbusRTU::mbErrCode diagnostics( ModbusRTU::DiagnosticMessage& query,
104  ModbusRTU::DiagnosticRetMessage& reply ) override;
105 
106  virtual ModbusRTU::mbErrCode read4314( ModbusRTU::MEIMessageRDI& query,
107  ModbusRTU::MEIMessageRetRDI& reply ) override;
108 
109  virtual ModbusRTU::mbErrCode journalCommand( ModbusRTU::JournalCommandMessage& query,
110  ModbusRTU::JournalCommandRetMessage& reply ) override;
111 
112  virtual ModbusRTU::mbErrCode setDateTime( ModbusRTU::SetDateTimeMessage& query,
113  ModbusRTU::SetDateTimeRetMessage& reply ) override;
114 
115  virtual ModbusRTU::mbErrCode remoteService( ModbusRTU::RemoteServiceMessage& query,
116  ModbusRTU::RemoteServiceRetMessage& reply ) override;
117 
118  virtual ModbusRTU::mbErrCode fileTransfer( ModbusRTU::FileTransferMessage& query,
119  ModbusRTU::FileTransferRetMessage& reply ) override;
120 
121  private:
122  std::queue<unsigned char> qrecv;
123  std::unordered_set<ModbusRTU::ModbusAddr> vaddr;
124  ModbusRTU::MBAPHeader curQueryHeader;
125  PassiveTimer ptTimeout;
126  timeout_t timeout = { 0 };
128 
129  ev::io io;
130  ev::timer ioTimeout;
131 
132  std::shared_ptr<UTCPStream> sock;
133  std::queue<UTCPCore::Buffer*> qsend;
134  double sessTimeout = { 10.0 };
135 
136  bool ignoreAddr = { false };
137  std::string peername = { "" };
138 
139  std::string caddr = { "" };
140 
141  FinalSlot slFin;
142 
143  std::atomic_bool cancelled = { false };
144  PassiveTimer pt;
145  PassiveTimer ptWait;
146  };
147  // ---------------------------------------------------------------------
148 } // end of namespace uniset
149 // -------------------------------------------------------------------------
150 #endif // ModbusTCPSession_H_
151 // -------------------------------------------------------------------------
Definition: ModbusServer.h:33
Definition: ModbusServerSlot.h:14
The ModbusTCPSession class Класс рассчитан на совместную работу с ModbusTCPServer,...
Definition: ModbusTCPSession.h:36
virtual ModbusRTU::mbErrCode writeOutputSingleRegister(ModbusRTU::WriteSingleOutputMessage &query, ModbusRTU::WriteSingleOutputRetMessage &reply) override
Definition: ModbusTCPSession.cc:534
virtual ModbusRTU::mbErrCode fileTransfer(ModbusRTU::FileTransferMessage &query, ModbusRTU::FileTransferRetMessage &reply) override
Definition: ModbusTCPSession.cc:571
virtual ModbusRTU::mbErrCode readInputRegisters(ModbusRTU::ReadInputMessage &query, ModbusRTU::ReadInputRetMessage &reply) override
Definition: ModbusTCPSession.cc:475
virtual ModbusRTU::mbErrCode writeOutputRegisters(ModbusRTU::WriteOutputMessage &query, ModbusRTU::WriteOutputRetMessage &reply) override
Definition: ModbusTCPSession.cc:496
virtual ModbusRTU::mbErrCode realReceive(const std::unordered_set< ModbusRTU::ModbusAddr > &vmbaddr, timeout_t msecTimeout) override
Definition: ModbusTCPSession.cc:211
virtual ModbusRTU::mbErrCode journalCommand(ModbusRTU::JournalCommandMessage &query, ModbusRTU::JournalCommandRetMessage &reply) override
Definition: ModbusTCPSession.cc:544
virtual ModbusRTU::mbErrCode read4314(ModbusRTU::MEIMessageRDI &query, ModbusRTU::MEIMessageRetRDI &reply) override
Definition: ModbusTCPSession.cc:515
virtual ModbusRTU::mbErrCode readCoilStatus(ModbusRTU::ReadCoilMessage &query, ModbusRTU::ReadCoilRetMessage &reply) override
Definition: ModbusTCPSession.cc:444
virtual ModbusRTU::mbErrCode diagnostics(ModbusRTU::DiagnosticMessage &query, ModbusRTU::DiagnosticRetMessage &reply) override
Definition: ModbusTCPSession.cc:506
virtual size_t getNextData(unsigned char *buf, int len) override
Definition: ModbusTCPSession.cc:299
virtual ModbusRTU::mbErrCode forceMultipleCoils(ModbusRTU::ForceCoilsMessage &query, ModbusRTU::ForceCoilsRetMessage &reply) override
Definition: ModbusTCPSession.cc:485
virtual ModbusRTU::mbErrCode readOutputRegisters(ModbusRTU::ReadOutputMessage &query, ModbusRTU::ReadOutputRetMessage &reply) override
Definition: ModbusTCPSession.cc:465
virtual void setChannelTimeout(timeout_t msec) override
Definition: ModbusTCPSession.cc:580
virtual ModbusRTU::mbErrCode readInputStatus(ModbusRTU::ReadInputStatusMessage &query, ModbusRTU::ReadInputStatusRetMessage &reply) override
Definition: ModbusTCPSession.cc:454
virtual ModbusRTU::mbErrCode remoteService(ModbusRTU::RemoteServiceMessage &query, ModbusRTU::RemoteServiceRetMessage &reply) override
Definition: ModbusTCPSession.cc:562
virtual ModbusRTU::mbErrCode setDateTime(ModbusRTU::SetDateTimeMessage &query, ModbusRTU::SetDateTimeRetMessage &reply) override
Definition: ModbusTCPSession.cc:553
virtual ModbusRTU::mbErrCode forceSingleCoil(ModbusRTU::ForceSingleCoilMessage &query, ModbusRTU::ForceSingleCoilRetMessage &reply) override
Definition: ModbusTCPSession.cc:524
Пассивный таймер
Definition: PassiveTimer.h:94
Definition: CommonEventLoop.h:15
Definition: ModbusTypes.h:1118
Definition: ModbusTypes.h:1176
Definition: ModbusTypes.h:1575
Definition: ModbusTypes.h:1603
Definition: ModbusTypes.h:727
Definition: ModbusTypes.h:804
Definition: ModbusTypes.h:937
Definition: ModbusTypes.h:1310
Definition: ModbusTypes.h:1333
Definition: ModbusTypes.h:193
Definition: ModbusTypes.h:1188
Definition: ModbusTypes.h:1243
Definition: ModbusTypes.h:211
Definition: ModbusTypes.h:347
Definition: ModbusTypes.h:378
Definition: ModbusTypes.h:636
Definition: ModbusTypes.h:666
Definition: ModbusTypes.h:447
Definition: ModbusTypes.h:548
Definition: ModbusTypes.h:577
Definition: ModbusTypes.h:1456
Definition: ModbusTypes.h:1489
Definition: ModbusTypes.h:1398
Definition: ModbusTypes.h:1436
Definition: ModbusTypes.h:844
Definition: ModbusTypes.h:898
Definition: ModbusTypes.h:1033