django/daphne
1
1
Fork 0
mirror of https://github.com/django/daphne.git synced 2025-07-14 18:02:17 +03:00
Code Issues Packages Projects Releases Wiki Activity

Use lower-level autobahn API so it likes us

Browse Source
This commit is contained in:
Andrew Godwin 2016-07-06 12:08:44 -07:00
parent 4c2c2d0fff
commit 45e67d8e60
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
daphne/ws_protocol.py
View File

@ -102,7 +102,7 @@ class WebSocketProtocol(WebSocketServerProtocol):
self.muted = True self.muted = True
logger.warn("WebSocket force closed for %s due to connect backpressure", self.reply_channel) logger.warn("WebSocket force closed for %s due to connect backpressure", self.reply_channel)
# Send code 1013 "try again later" with close. # Send code 1013 "try again later" with close.
self.sendClose(code=1013) self.sendCloseFrame(code=1013, isReply=False)
else: else:
self.factory.log_action("websocket", "connected", { self.factory.log_action("websocket", "connected", {
"path": self.request.path, "path": self.request.path,
@ -137,7 +137,7 @@ class WebSocketProtocol(WebSocketServerProtocol):
self.muted = True self.muted = True
logger.warn("WebSocket force closed for %s due to receive backpressure", self.reply_channel) logger.warn("WebSocket force closed for %s due to receive backpressure", self.reply_channel)
# Send code 1013 "try again later" with close. # Send code 1013 "try again later" with close.
self.sendClose(code=1013) self.sendCloseFrame(code=1013, isReply=False)
def serverSend(self, content, binary=False): def serverSend(self, content, binary=False):
""" """