fix select timeout in sync worker with multiple connections

fix #983
This commit is contained in:
Benoit Chesneau 2015-03-06 08:35:17 +01:00
parent 5b3535bf64
commit 803a2d71b0

View File

@ -91,13 +91,14 @@ class SyncWorker(base.Worker):
except StopWaiting:
return
for listener in ready:
try:
self.accept(listener)
except socket.error as e:
if e.args[0] not in (errno.EAGAIN, errno.ECONNABORTED,
errno.EWOULDBLOCK):
raise
if ready is not None:
for listener in ready:
try:
self.accept(listener)
except socket.error as e:
if e.args[0] not in (errno.EAGAIN, errno.ECONNABORTED,
errno.EWOULDBLOCK):
raise
if not self.is_parent_alive():
return