denik: acceptor = gevent.spawn(server.serve_forever) --- can just write

server.start() - it's asynchronous

go for it then.
This commit is contained in:
Benoit Chesneau 2010-07-14 23:28:36 +02:00
parent 3be6826ea1
commit 40146dfe4f

View File

@ -51,7 +51,7 @@ class GEvent2Worker(Worker):
server = WSGIServer(self.socket, application=self.wsgi, server = WSGIServer(self.socket, application=self.wsgi,
spawn=pool, handler_class=WSGIHandler) spawn=pool, handler_class=WSGIHandler)
acceptor = gevent.spawn(server.serve_forever) server.start()
try: try:
while self.alive: while self.alive:
@ -59,9 +59,9 @@ class GEvent2Worker(Worker):
if self.ppid != os.getppid(): if self.ppid != os.getppid():
self.log.info("Parent changed, shutting down: %s" % self) self.log.info("Parent changed, shutting down: %s" % self)
gevent.kill(acceptor) server.stop()
break break
gevent.sleep(0.1) gevent.sleep(0.1)
self.pool.join(timeout=self.timeout) self.pool.join(timeout=self.timeout)
except KeyboardInterrupt: except KeyboardInterrupt:
pass pass