mirror of
https://github.com/frappe/gunicorn.git
synced 2026-01-14 11:09:11 +08:00
fix support for current but old stable gevent release
This commit is contained in:
parent
e9416b1177
commit
4ae65eeabf
@ -68,7 +68,12 @@ class GeventWorker(AsyncWorker):
|
|||||||
def patch(self):
|
def patch(self):
|
||||||
from gevent import monkey
|
from gevent import monkey
|
||||||
monkey.noisy = False
|
monkey.noisy = False
|
||||||
monkey.patch_all(subprocess=True)
|
|
||||||
|
# if the new version is used make sure to patch subprocess
|
||||||
|
if gevent.version_info[0] == 0:
|
||||||
|
monkey.patch_all()
|
||||||
|
else:
|
||||||
|
monkey.patch_all(subprocess=True)
|
||||||
|
|
||||||
# monkey patch sendfile to make it none blocking
|
# monkey patch sendfile to make it none blocking
|
||||||
patch_sendfile()
|
patch_sendfile()
|
||||||
@ -181,6 +186,11 @@ class GeventWorker(AsyncWorker):
|
|||||||
def init_process(self):
|
def init_process(self):
|
||||||
# monkey patch here
|
# monkey patch here
|
||||||
self.patch()
|
self.patch()
|
||||||
|
|
||||||
|
# reinit the hub
|
||||||
|
from gevent.hub import reinit
|
||||||
|
hub.reinit()
|
||||||
|
|
||||||
# then initialize the process
|
# then initialize the process
|
||||||
super(GeventWorker, self).init_process()
|
super(GeventWorker, self).init_process()
|
||||||
|
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user