The websocket must be closed only when it is alive
This commit is contained in:
+5
-2
@@ -204,11 +204,14 @@ func onMessage(conn *websocket.Conn, w http.ResponseWriter, r *http.Request, ses
|
|||||||
// Websocket GET /app/{key}
|
// Websocket GET /app/{key}
|
||||||
func Websocket(w http.ResponseWriter, r *http.Request) {
|
func Websocket(w http.ResponseWriter, r *http.Request) {
|
||||||
conn, err := upgrader.Upgrade(w, r, nil)
|
conn, err := upgrader.Upgrade(w, r, nil)
|
||||||
defer conn.Close()
|
defer func() {
|
||||||
|
if conn != nil {
|
||||||
|
conn.Close()
|
||||||
|
}
|
||||||
|
}()
|
||||||
|
|
||||||
if err != nil {
|
if err != nil {
|
||||||
log.Error(err)
|
log.Error(err)
|
||||||
emitWSError(NewGenericReconnectImmediatelyError(), conn)
|
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Reference in New Issue
Block a user