File 0001_create_a_thread_to_reap_death_process.patch of Package python-Werkzeug

Overview Repositories Revisions Requests Users Attributes Meta

File 0001_create_a_thread_to_reap_death_process.patch of Package python-Werkzeug (Revision 33531bf0b09395e4c6c8b0a8be272470)

Currently displaying revision 33531bf0b09395e4c6c8b0a8be272470 , Show latest

From 676bc5fa4b6aa9d153c9805cdbad0ff0450bade6 Mon Sep 17 00:00:00 2001
From: Alberto Planas <aplanas@gmail.com>
Date: Wed, 3 Feb 2016 11:56:23 +0100
Subject: [PATCH] Create a thread to reap death process

ForkingWSGIServer use `SocketServer.ForkingMixIn` to implement a
multiprocess server.  This class provides a workflow that collect
death process (process in Zombie status) before the
`process_request`.  This means that this process itself will be
in Zombie status at the end of the request, that will be eventually
collected during the next `process_request`.

To minimize transient Zombie process, `ForkingWSGIServer` is
creating a daemon thread (via `threading.Timer`) to call the
collector every (by default) 5 seconds.

Fixes #810
---
 werkzeug/serving.py | 21 ++++++++++++++++++++-
 1 file changed, 20 insertions(+), 1 deletion(-)

diff --git a/werkzeug/serving.py b/werkzeug/serving.py
index 15b6cd7..778df2d 100644
--- a/werkzeug/serving.py
+++ b/werkzeug/serving.py
@@ -41,6 +41,7 @@
 import socket
 import sys
 import signal
+import threading
 
 try:
     import ssl

@@ -524,11 +525,29 @@
     multiprocess = True
 
     def __init__(self, host, port, app, processes=40, handler=None,
-                 passthrough_errors=False, ssl_context=None, fd=None):
+                 passthrough_errors=False, ssl_context=None, fd=None,
+                 frequency=5):
         BaseWSGIServer.__init__(self, host, port, app, handler,
                                passthrough_errors, ssl_context, fd)
         self.max_children = processes
 
+        if frequency:
+            self.frequency = frequency
+            self.setup_reap_children()
+
+    def setup_reap_children(self):
+        """Create a thread to collect death children."""
+        t = threading.Timer(self.frequency, self.reap_children)
+        # Set daemon mode to provide a clean termination of the thread
+        # when the system ends
+        t.daemon = True
+        t.start()
+
+    def reap_children(self):
+        """Reap or collect death children."""
+        self.collect_children()
+        self.setup_reap_children()
+
 
 def make_server(host=None, port=None, app=None, threaded=False, processes=1,
                 request_handler=None, passthrough_errors=False,

Places

File 0001_create_a_thread_to_reap_death_process.patch of Package python-Werkzeug (Revision 33531bf0b09395e4c6c8b0a8be272470)

Places