don't notify so much the arbiter. spotted by @davisp . tests are ok.

This commit is contained in:
benoitc 2010-10-28 05:44:01 +02:00
parent be1990007d
commit f92a5409f5
2 changed files with 3 additions and 3 deletions

View File

@ -41,7 +41,7 @@ class EventletWorker(AsyncWorker):
if self.ppid != os.getppid():
self.log.info("Parent changed, shutting down: %s" % self)
break
eventlet.sleep(0.1)
eventlet.sleep(self.timeout)
self.notify()
with eventlet.Timeout(self.timeout, False):

View File

@ -77,7 +77,7 @@ class GeventWorker(AsyncWorker):
if self.ppid != os.getppid():
self.log.info("Parent changed, shutting down: %s" % self)
break
gevent.sleep(0.1)
gevent.sleep(self.timeout)
except KeyboardInterrupt:
pass
@ -137,7 +137,7 @@ class GeventBaseWorker(Worker):
if self.ppid != os.getppid():
self.log.info("Parent changed, shutting down: %s" % self)
break
gevent.sleep(0.1)
gevent.sleep(self.timeout)
except KeyboardInterrupt:
pass