mirror of https://gitlab.com/litecord/litecord.git
Handle connection closed when sending RECONNECT
This commit is contained in:
parent
24ff453c6b
commit
1cbc4541a8
|
|
@ -190,14 +190,14 @@ class StateManager:
|
||||||
"""Send OP Reconnect to a single connection."""
|
"""Send OP Reconnect to a single connection."""
|
||||||
websocket = state.ws
|
websocket = state.ws
|
||||||
|
|
||||||
await websocket.send({"op": OP.RECONNECT})
|
|
||||||
|
|
||||||
# wait 200ms
|
|
||||||
# so that the client has time to process
|
|
||||||
# our payload then close the connection
|
|
||||||
await asyncio.sleep(0.2)
|
|
||||||
|
|
||||||
try:
|
try:
|
||||||
|
await websocket.send({"op": OP.RECONNECT})
|
||||||
|
|
||||||
|
# wait 200ms
|
||||||
|
# so that the client has time to process
|
||||||
|
# our payload then close the connection
|
||||||
|
await asyncio.sleep(0.2)
|
||||||
|
|
||||||
# try to close the connection ourselves
|
# try to close the connection ourselves
|
||||||
await websocket.ws.close(code=4000, reason="litecord shutting down")
|
await websocket.ws.close(code=4000, reason="litecord shutting down")
|
||||||
except ConnectionClosed:
|
except ConnectionClosed:
|
||||||
|
|
|
||||||
Loading…
Reference in New Issue