#60 Check for slave unit id before processing the request for serial servers

Author: dhoomakethu

pymodbus/server/async.py

@@ -58,7 +58,9 @@ def dataReceived(self, data):
         if _logger.isEnabledFor(logging.DEBUG):
             _logger.debug(' '.join([hex(byte2int(x)) for x in data]))
         if not self.factory.control.ListenOnly:
-            self.framer.processIncomingPacket(data, self._execute)
+            unit_address = byte2int(data[0])
+            if unit_address in self.factory.store:
+                self.framer.processIncomingPacket(data, self._execute)
 
     def _execute(self, request):
         ''' Executes the request and returns the result

pymodbus/server/sync.py

@@ -102,7 +102,9 @@ def handle(self):
                 if data:
                     if _logger.isEnabledFor(logging.DEBUG):
                         _logger.debug(" ".join([hex(byte2int(x)) for x in data]))
-                    self.framer.processIncomingPacket(data, self.execute)
+                    unit_address = byte2int(data[0])
+                    if unit_address in self.server.context:
+                        self.framer.processIncomingPacket(data, self.execute)
             except Exception as msg:
                 # since we only have a single socket, we cannot exit
                 # Clear frame buffer
@@ -198,14 +200,15 @@ class ModbusDisconnectedRequestHandler(ModbusBaseRequestHandler):
     only difference is that we have to specify who to send the
     resulting packet data to.
     '''
+    socket = None
 
     def handle(self):
         ''' Callback when we receive any data
         '''
         reset_frame = False
         while self.running:
             try:
-                data, self.request = self.request
+                data, self.socket = self.request
                 if not data:
                     self.running = False
                 if _logger.isEnabledFor(logging.DEBUG):
@@ -236,7 +239,7 @@ def send(self, message):
             pdu = self.framer.buildPacket(message)
             if _logger.isEnabledFor(logging.DEBUG):
                 _logger.debug('send: %s' % b2a_hex(pdu))
-            return self.request.sendto(pdu, self.client_address)
+            return self.socket.sendto(pdu, self.client_address)
 
 
 #---------------------------------------------------------------------------#