diff --git a/modules/api_rest/api_rest_ws.go b/modules/api_rest/api_rest_ws.go index ed7fd1e4..9874a344 100644 --- a/modules/api_rest/api_rest_ws.go +++ b/modules/api_rest/api_rest_ws.go @@ -40,6 +40,7 @@ func (mod *RestAPI) streamEvent(ws *websocket.Conn, event session.Event) error { func (mod *RestAPI) sendPing(ws *websocket.Conn) error { ws.SetWriteDeadline(time.Now().Add(writeWait)) + ws.SetReadDeadline(time.Now().Add(pongWait)) if err := ws.WriteMessage(websocket.PingMessage, []byte{}); err != nil { mod.Error("Error while writing websocket ping message: %s", err) return err