fix issue #24.

This commit is contained in:
benoitc 2010-03-01 16:12:09 +01:00
parent 6170d5a503
commit 368257a733

View File

@ -352,9 +352,13 @@ class Arbiter(object):
Kill unused/idle workers Kill unused/idle workers
""" """
for (pid, worker) in list(self.WORKERS.items()): for (pid, worker) in list(self.WORKERS.items()):
diff = time.time() - os.fstat(worker.tmp.fileno()).st_ctime try:
if diff <= self.timeout: diff = time.time() - os.fstat(worker.tmp.fileno()).st_ctime
if diff <= self.timeout:
continue
except ValueError:
continue continue
self.log.error("Worker timed out: %s (pid:%s)" % (worker, pid)) self.log.error("Worker timed out: %s (pid:%s)" % (worker, pid))
self.kill_worker(pid, signal.SIGKILL) self.kill_worker(pid, signal.SIGKILL)