jingrow/gunicorn
1
0
Fork 0
mirror of https://github.com/frappe/gunicorn.git synced 2026-01-14 11:09:11 +08:00
Code Issues Packages Projects Releases Wiki Activity

gthread: improve accepting connections loop

Browse Source 
make sure we stop accepting immediately when max connections is achieved.
This commit is contained in:
benoitc 2014-10-19 10:04:36 +02:00
parent 048dcf410c
commit cfc6dc778e
1 changed files with 4 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
gunicorn/workers/gthread.py
View File

@ -102,6 +102,9 @@ class ThreadWorker(base.Worker):
super(ThreadWorker, self).init_process() super(ThreadWorker, self).init_process()
def accept(self, listener): def accept(self, listener):
if not self.alive:
return
try: try:
client, addr = listener.accept() client, addr = listener.accept()
conn = TConn(self.cfg, listener, client, addr) conn = TConn(self.cfg, listener, client, addr)
@ -174,6 +177,7 @@ class ThreadWorker(base.Worker):
if len(self.futures) >= self.worker_connections: if len(self.futures) >= self.worker_connections:
res = futures.wait(self.futures, timeout=timeout) res = futures.wait(self.futures, timeout=timeout)
if not res: if not res:
self.alive = False
self.log.info("max requests achieved") self.log.info("max requests achieved")
break break