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

Merge pull request #2993 from ikonst/fix-access-log

Browse Source 
Log access even when connection is closed
This commit is contained in:
Benoit Chesneau 2023-05-13 21:10:20 +02:00 committed by GitHub
commit 6998d1247c
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
3 changed files with 3 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
gunicorn/workers/base_async.py
View File

@ -115,9 +115,9 @@ class AsyncWorker(base.Worker):
for item in respiter: for item in respiter:
resp.write(item) resp.write(item)
resp.close() resp.close()
finally:
request_time = datetime.now() - request_start request_time = datetime.now() - request_start
self.log.access(resp, req, environ, request_time) self.log.access(resp, req, environ, request_time)
finally:
if hasattr(respiter, "close"): if hasattr(respiter, "close"):
respiter.close() respiter.close()
if resp.should_close(): if resp.should_close():

2
gunicorn/workers/gthread.py
View File

@ -340,9 +340,9 @@ class ThreadWorker(base.Worker):
resp.write(item) resp.write(item)
resp.close() resp.close()
finally:
request_time = datetime.now() - request_start request_time = datetime.now() - request_start
self.log.access(resp, req, environ, request_time) self.log.access(resp, req, environ, request_time)
finally:
if hasattr(respiter, "close"): if hasattr(respiter, "close"):
respiter.close() respiter.close()

2
gunicorn/workers/sync.py
View File

@ -183,9 +183,9 @@ class SyncWorker(base.Worker):
for item in respiter: for item in respiter:
resp.write(item) resp.write(item)
resp.close() resp.close()
finally:
request_time = datetime.now() - request_start request_time = datetime.now() - request_start
self.log.access(resp, req, environ, request_time) self.log.access(resp, req, environ, request_time)
finally:
if hasattr(respiter, "close"): if hasattr(respiter, "close"):
respiter.close() respiter.close()
except EnvironmentError: except EnvironmentError: