Merge pull request #820 from youknowone/worker-protocol
Protocol configurable gunicorn worker
This commit is contained in:
commit
f721f90add
|
@ -23,6 +23,9 @@ from sanic.websocket import WebSocketProtocol
|
||||||
|
|
||||||
class GunicornWorker(base.Worker):
|
class GunicornWorker(base.Worker):
|
||||||
|
|
||||||
|
http_protocol = HttpProtocol
|
||||||
|
websocket_protocol = WebSocketProtocol
|
||||||
|
|
||||||
def __init__(self, *args, **kw): # pragma: no cover
|
def __init__(self, *args, **kw): # pragma: no cover
|
||||||
super().__init__(*args, **kw)
|
super().__init__(*args, **kw)
|
||||||
cfg = self.cfg
|
cfg = self.cfg
|
||||||
|
@ -46,8 +49,9 @@ class GunicornWorker(base.Worker):
|
||||||
|
|
||||||
def run(self):
|
def run(self):
|
||||||
is_debug = self.log.loglevel == logging.DEBUG
|
is_debug = self.log.loglevel == logging.DEBUG
|
||||||
protocol = (WebSocketProtocol if self.app.callable.websocket_enabled
|
protocol = (
|
||||||
else HttpProtocol)
|
self.websocket_protocol if self.app.callable.websocket_enabled
|
||||||
|
else self.http_protocol)
|
||||||
self._server_settings = self.app.callable._helper(
|
self._server_settings = self.app.callable._helper(
|
||||||
loop=self.loop,
|
loop=self.loop,
|
||||||
debug=is_debug,
|
debug=is_debug,
|
||||||
|
|
Loading…
Reference in New Issue
Block a user