make sure we really set the socket to blocking

This commit is contained in:
benoitc 2013-04-22 18:02:08 +02:00
parent 44de346202
commit 4894a1941a

View File

@ -23,7 +23,8 @@ class SyncWorker(base.Worker):
def run(self):
# self.socket appears to lose its blocking status after
# we fork in the arbiter. Reset it here.
[s.setblocking(0) for s in self.sockets]
for s in self.sockets:
s.setblocking(0)
ready = self.sockets
while self.alive: