simplify the eventlet worker.

sockets are a;lready greened. make sure we also switch to the acceptor quickly.
This commit is contained in:
benoitc 2013-08-27 23:49:18 +02:00
parent 4a2eaf202c
commit 7e40442978

View File

@ -64,20 +64,16 @@ class EventletWorker(AsyncWorker):
def run(self): def run(self):
acceptors = [] acceptors = []
for sock in self.sockets: for sock in self.sockets:
s = GreenSocket(family_or_realsock=sock) sock.setblocking(1)
s.setblocking(1) hfun = partial(self.handle, sock)
hfun = partial(self.handle, s) acceptor = eventlet.spawn(eventlet.serve, sock, hfun,
acceptor = eventlet.spawn(eventlet.serve, s, hfun,
self.worker_connections) self.worker_connections)
acceptors.append(acceptor) acceptors.append(acceptor)
eventlet.sleep(0.0)
while self.alive: while self.alive:
self.notify() self.notify()
if self.ppid != os.getppid():
self.log.info("Parent changed, shutting down: %s", self)
break
eventlet.sleep(1.0) eventlet.sleep(1.0)
self.notify() self.notify()