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

PEP8

Browse Source
This commit is contained in:
Randall Leeds 2014-11-18 15:03:43 -08:00
parent 415956da23
commit 2aabf48317
1 changed files with 4 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
gunicorn/workers/geventlet.py
View File

@ -25,6 +25,7 @@ import greenlet
from gunicorn.http.wsgi import sendfile as o_sendfile from gunicorn.http.wsgi import sendfile as o_sendfile
from gunicorn.workers.async import AsyncWorker from gunicorn.workers.async import AsyncWorker
def _eventlet_sendfile(fdout, fdin, offset, nbytes): def _eventlet_sendfile(fdout, fdin, offset, nbytes):
while True: while True:
try: try:
@ -82,6 +83,7 @@ def patch_sendfile():
if o_sendfile is not None: if o_sendfile is not None:
setattr(wsgi, "sendfile", _eventlet_sendfile) setattr(wsgi, "sendfile", _eventlet_sendfile)
class EventletWorker(AsyncWorker): class EventletWorker(AsyncWorker):
def patch(self): def patch(self):
@ -99,7 +101,7 @@ class EventletWorker(AsyncWorker):
def handle(self, listener, client, addr): def handle(self, listener, client, addr):
if self.cfg.is_ssl: if self.cfg.is_ssl:
client = eventlet.wrap_ssl(client, server_side=True, client = eventlet.wrap_ssl(client, server_side=True,
**self.cfg.ssl_options) **self.cfg.ssl_options)
super(EventletWorker, self).handle(listener, client, addr) super(EventletWorker, self).handle(listener, client, addr)
@ -110,7 +112,7 @@ class EventletWorker(AsyncWorker):
gsock.setblocking(1) gsock.setblocking(1)
hfun = partial(self.handle, gsock) hfun = partial(self.handle, gsock)
acceptor = eventlet.spawn(_eventlet_serve, gsock, hfun, acceptor = eventlet.spawn(_eventlet_serve, gsock, hfun,
self.worker_connections) self.worker_connections)
acceptors.append(acceptor) acceptors.append(acceptor)
eventlet.sleep(0.0) eventlet.sleep(0.0)