jingrow/gunicorn
1
0
Fork 0
mirror of https://github.com/frappe/gunicorn.git synced 2026-01-14 11:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix run loop in sync worker

Browse Source
This commit is contained in:
benoitc 2014-12-19 08:59:22 +01:00
parent d1a0973225
commit fd95f66f2d
1 changed files with 9 additions and 4 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
gunicorn/workers/sync.py
View File

@ -18,6 +18,8 @@ import gunicorn.util as util
import gunicorn.workers.base as base import gunicorn.workers.base as base
from gunicorn import six from gunicorn import six
class StopWaiting(Exception):
""" exception raised to stop waiting for a connnection """
class SyncWorker(base.Worker): class SyncWorker(base.Worker):
@ -41,7 +43,7 @@ class SyncWorker(base.Worker):
if self.nr < 0: if self.nr < 0:
return self.sockets return self.sockets
else: else:
return False raise StopWaiting
raise raise
def is_parent_alive(self): def is_parent_alive(self):
@ -75,15 +77,18 @@ class SyncWorker(base.Worker):
if not self.is_parent_alive(): if not self.is_parent_alive():
return return
if not self.wait(timeout): try:
self.wait(timeout)
except StopWaiting:
return return
def run_for_multiple(self, timeout): def run_for_multiple(self, timeout):
while self.alive: while self.alive:
self.notify() self.notify()
ready = self.wait(timeout) try:
if not ready: ready = self.wait(timeout)
except StopWaiting:
return return
for listener in ready: for listener in ready: