update modbusrtuframer.

Author: janiversen

pymodbus/framer/rtu_framer.py

@@ -2,6 +2,7 @@
 # pylint: disable=missing-type-doc
 import struct
 import time
+from typing import List
 
 from pymodbus.exceptions import (
     InvalidMessageReceivedException,
@@ -191,6 +192,15 @@ def populateResult(self, result):
         result.slave_id = self._header["uid"]
         result.transaction_id = self._header["uid"]
 
+    def isFrameIntendedForUs(self, _slaves: List[int]):
+        """Check if slave is one we want."""
+        # slave = self._buffer[0]
+        # if slaves and slave not in slaves:
+        #    return False
+
+        # have a look at _validate_slave_id it does the same
+        return True
+
     # ----------------------------------------------------------------------- #
     # Public Member Functions
     # ----------------------------------------------------------------------- #
@@ -217,22 +227,24 @@ def processIncomingPacket(self, data, callback, slave, **kwargs):
         self.addToFrame(data)
         single = kwargs.get("single", False)
         while True:
-            if self.isFrameReady():
-                if self.checkFrame():
-                    if self._validate_slave_id(slave, single):
-                        self._process(callback)
-                    else:
-                        header_txt = self._header["uid"]
-                        Log.debug("Not a valid slave id - {}, ignoring!!", header_txt)
-                        self.resetFrame()
-                        break
-                else:
-                    Log.debug("Frame check failed, ignoring!!")
-                    self.resetFrame()
-                    break
-            else:
+            if not self.isFrameIntendedForUs(slave):
+                self.resetFrame()
+                Log.debug(f"Frame not intended for us, ignoring!! - [{data}]")
+                break
+            if not self.isFrameReady():
                 Log.debug("Frame - [{}] not ready", data)
                 break
+            if not self.checkFrame():
+                Log.debug("Frame check failed, ignoring!!")
+                self.resetFrame()
+                break
+            if not self._validate_slave_id(slave, single):
+                header_txt = self._header["uid"]
+                Log.debug("Not a valid slave id - {}, ignoring!!", header_txt)
+                self.resetFrame()
+                break
+            self._process(callback)
+            Log.debug(f"Frame responded to!! - [{data}]")
 
     def buildPacket(self, message):
         """Create a ready to send modbus packet.