add support for eventlets _AlreadyHandled object

gunicorn/workers/async.py

@@ -27,6 +27,10 @@ def __init__(self, *args, **kwargs):
     def timeout_ctx(self):
         raise NotImplementedError()
 
+    def is_already_handled(self, respiter):
+        # some workers will need to overload this function to raise a StopIteration
+        return respiter == ALREADY_HANDLED
+
     def handle(self, listener, client, addr):
         req = None
         try:
@@ -101,7 +105,7 @@ def handle_request(self, listener_name, req, sock, addr):
                 resp.force_close()
 
             respiter = self.wsgi(environ, resp.start_response)
-            if respiter == ALREADY_HANDLED:
+            if self.is_already_handled(respiter):
                 return False
             try:
                 if isinstance(respiter, environ['wsgi.file_wrapper']):

gunicorn/workers/geventlet.py

@@ -20,6 +20,7 @@
 from eventlet import hubs, greenthread
 from eventlet.greenio import GreenSocket
 from eventlet.hubs import trampoline
+from eventlet.wsgi import ALREADY_HANDLED as EVENTLET_ALREADY_HANDLED
 import greenlet
 
 from gunicorn.http.wsgi import sendfile as o_sendfile
@@ -91,6 +92,12 @@ def patch(self):
         eventlet.monkey_patch(os=False)
         patch_sendfile()
 
+    def is_already_handled(self, respiter):
+        if respiter == EVENTLET_ALREADY_HANDLED:
+            raise StopIteration()
+        else:
+            return super(EventletWorker, self).is_already_handled(respiter)
+
     def init_process(self):
         self.patch()
         super(EventletWorker, self).init_process()