Vasanko/sanic
2
0
Fork 0
Code Issues Pull Requests 1 Actions Packages Projects Releases Wiki Activity

Refactor keep_alive

Browse Source
This commit is contained in:
38elements 2017-04-12 17:55:22 +09:00
parent e5fdc7fdd0
commit 7fe418d1b7
1 changed files with 6 additions and 6 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
sanic/server.py
View File

@ -89,6 +89,10 @@ class HttpProtocol(asyncio.Protocol):
self._last_request_time = None self._last_request_time = None
self._request_handler_task = None self._request_handler_task = None
@property
def keep_alive(self):
return self.parser.should_keep_alive() and not self.signal.stopped
# -------------------------------------------- # # -------------------------------------------- #
# Connection # Connection
# -------------------------------------------- # # -------------------------------------------- #
@ -182,9 +186,7 @@ class HttpProtocol(asyncio.Protocol):
Writes response content synchronously to the transport. Writes response content synchronously to the transport.
""" """
try: try:
keep_alive = ( keep_alive = self.keep_alive
self.parser.should_keep_alive() and not self.signal.stopped)
self.transport.write( self.transport.write(
response.output( response.output(
self.request.version, keep_alive, self.request.version, keep_alive,
@ -218,9 +220,7 @@ class HttpProtocol(asyncio.Protocol):
""" """
try: try:
keep_alive = ( keep_alive = self.keep_alive
self.parser.should_keep_alive() and not self.signal.stopped)
response.transport = self.transport response.transport = self.transport
await response.stream( await response.stream(
self.request.version, keep_alive, self.request_timeout) self.request.version, keep_alive, self.request_timeout)