mirror of
https://github.com/frappe/gunicorn.git
synced 2026-01-14 11:09:11 +08:00
fix max-requests from @davisp and me, reviewed by @davisp
This commit is contained in:
parent
66cc6975d1
commit
4ed9901708
@ -29,7 +29,7 @@ class AsyncWorker(base.Worker):
|
|||||||
try:
|
try:
|
||||||
parser = http.RequestParser(client)
|
parser = http.RequestParser(client)
|
||||||
try:
|
try:
|
||||||
while self.alive:
|
while True:
|
||||||
req = None
|
req = None
|
||||||
with self.timeout_ctx():
|
with self.timeout_ctx():
|
||||||
req = parser.next()
|
req = parser.next()
|
||||||
@ -64,7 +64,7 @@ class AsyncWorker(base.Worker):
|
|||||||
self.cfg.pre_request(self, req)
|
self.cfg.pre_request(self, req)
|
||||||
resp, environ = wsgi.create(req, sock, addr, self.address, self.cfg)
|
resp, environ = wsgi.create(req, sock, addr, self.address, self.cfg)
|
||||||
self.nr += 1
|
self.nr += 1
|
||||||
if self.nr >= self.max_requests:
|
if self.alive and self.nr >= self.max_requests:
|
||||||
self.log.info("Autorestarting worker after current request.")
|
self.log.info("Autorestarting worker after current request.")
|
||||||
resp.force_close()
|
resp.force_close()
|
||||||
self.alive = False
|
self.alive = False
|
||||||
|
|||||||
Loading…
x
Reference in New Issue
Block a user