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

we want to retry on first EPIPE on write

Browse Source
This commit is contained in:
Benoit Chesneau 2010-01-21 15:18:18 +01:00
parent 7d83418b60
commit 834c080b7a
2 changed files with 2 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
gunicorn/util.py
View File

@ -62,7 +62,6 @@ def write(sock, data):
if e[0] in (errno.EWOULDBLOCK, errno.EAGAIN): if e[0] in (errno.EWOULDBLOCK, errno.EAGAIN):
break break
elif e[0] in (errno.EPIPE,): elif e[0] in (errno.EPIPE,):
break
if i == 0: if i == 0:
continue continue
raise raise

8
gunicorn/worker.py
View File

@ -37,11 +37,9 @@ class Worker(object):
self.socket = socket self.socket = socket
util.close_on_exec(self.socket) util.close_on_exec(self.socket)
self.socket.setblocking(0) self.socket.setblocking(0)
util.close_on_exec(fd) util.close_on_exec(fd)
self.address = self.socket.getsockname() self.address = self.socket.getsockname()
self.app = app self.app = app
@ -101,7 +99,7 @@ class Worker(object):
allocate more fs or ENOMEM when there is not enough allocate more fs or ENOMEM when there is not enough
memory to allocate. BSD return ENOBUFS. memory to allocate. BSD return ENOBUFS.
""" """
log.info("Could not accept new connection (%s)" % str(e)) log.warning("Could not accept new connection (%s)" % str(e))
raise raise
if nr == 0: break if nr == 0: break
@ -116,8 +114,6 @@ class Worker(object):
except select.error, e: except select.error, e:
if e[0] == errno.EINTR: if e[0] == errno.EINTR:
break break
elif e[0] == errno.EBADF:
return
raise raise
spinner = (spinner+1) % 2 spinner = (spinner+1) % 2