Signal handlers to stop in shutdown().

ccatterina · May 3, 2015 · 15a0286 · 15a0286
1 parent fec7ac3
commit 15a0286
Showing 1 changed file with 9 additions and 0 deletions.
diff --git a/pymodbus/server/sync.py b/pymodbus/server/sync.py
@@ -258,6 +258,15 @@ def process_request(self, request, client):
         _logger.debug("Started thread to serve client at " + str(client))
         SocketServer.ThreadingTCPServer.process_request(self, request, client)
 
+    def shutdown(self):
+        ''' Stops the serve_forever loop.
+
+        Overridden to signal handlers to stop.
+        '''
+        for thread in self.threads:
+            thread.running = False
+        SocketServer.ThreadingTCPServer.shutdown(self)
+
     def server_close(self):
         ''' Callback for stopping the running server
         '''