django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2024-11-21 23:46:33 +03:00
Code Issues Packages Projects Releases Wiki Activity

Fix logging and log action around chunked HTTP responses

Browse Source
This commit is contained in:
Andrew Godwin 2016-02-20 23:33:50 +00:00
parent b9412f8e82
commit 1709522162
1 changed files with 9 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
daphne/http_protocol.py
View File

@ -143,21 +143,22 @@ class WebRequest(http.Request):
# Write headers # Write headers
for header, value in message.get("headers", {}): for header, value in message.get("headers", {}):
self.setHeader(header.encode("utf8"), value) self.setHeader(header.encode("utf8"), value)
logger.debug("HTTP %s response started for %s", message['status'], self.reply_channel)
# Write out body # Write out body
if "content" in message: if "content" in message:
http.Request.write(self, message['content']) http.Request.write(self, message['content'])
# End if there's no more content # End if there's no more content
if not message.get("more_content", False): if not message.get("more_content", False):
self.finish() self.finish()
logger.debug("HTTP %s response for %s", message['status'], self.reply_channel) logger.debug("HTTP response complete for %s", self.reply_channel)
self.factory.log_action("http", "complete", {
"path": self.path.decode("ascii"),
"status": self.code,
"method": self.method.decode("ascii"),
"client": "%s:%s" % (self.client.host, self.client.port),
})
else: else:
logger.debug("HTTP %s response chunk for %s", message['status'], self.reply_channel) logger.debug("HTTP response chunk for %s", self.reply_channel)
self.factory.log_action("http", "complete", {
"path": self.path.decode("ascii"),
"status": message['status'],
"method": self.method.decode("ascii"),
"client": "%s:%s" % (self.client.host, self.client.port),
})
class HTTPProtocol(http.HTTPChannel): class HTTPProtocol(http.HTTPChannel):