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

Merge 1a60647e68 into 630caed915

Browse Source
This commit is contained in:
Olivier Martin 2025-02-07 12:27:10 +08:00 committed by GitHub
commit 4646e3867d
No known key found for this signature in database
GPG Key ID: B5690EEEBB952194
1 changed files with 7 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
daphne/ws_protocol.py
View File

@ -284,11 +284,18 @@ class WebSocketProtocol(WebSocketServerProtocol):
self.duration() > self.server.websocket_timeout self.duration() > self.server.websocket_timeout
and self.server.websocket_timeout >= 0 and self.server.websocket_timeout >= 0
): ):
logger.warning(
"WebSocket %s took too long and was killed.", self.client_addr
)
self.serverClose() self.serverClose()
# Ping check # Ping check
# If we're still connecting, deny the connection # If we're still connecting, deny the connection
if self.state == self.STATE_CONNECTING: if self.state == self.STATE_CONNECTING:
if self.duration() > self.server.websocket_connect_timeout: if self.duration() > self.server.websocket_connect_timeout:
logger.warning(
"WebSocket %s connection took too long and was killed.",
self.client_addr,
)
self.serverReject() self.serverReject()
elif self.state == self.STATE_OPEN: elif self.state == self.STATE_OPEN:
if (time.time() - self.last_ping) > self.server.ping_interval: if (time.time() - self.last_ping) > self.server.ping_interval: