[MM-61776] Fix errcheck issues in server/channels/app/platform/web_conn.go (#29515)
Этот коммит содержится в:
@@ -101,7 +101,6 @@ issues:
|
|||||||
channels/app/platform/session.go|\
|
channels/app/platform/session.go|\
|
||||||
channels/app/platform/status.go|\
|
channels/app/platform/status.go|\
|
||||||
channels/app/platform/web_broadcast_hook.go|\
|
channels/app/platform/web_broadcast_hook.go|\
|
||||||
channels/app/platform/web_conn.go|\
|
|
||||||
channels/app/platform/web_hub.go|\
|
channels/app/platform/web_hub.go|\
|
||||||
channels/app/platform/web_hub_test.go|\
|
channels/app/platform/web_hub_test.go|\
|
||||||
channels/app/plugin_test.go|\
|
channels/app/plugin_test.go|\
|
||||||
|
|||||||
@@ -437,7 +437,11 @@ func (wc *WebConn) readPump() {
|
|||||||
}
|
}
|
||||||
|
|
||||||
wc.WebSocket.SetReadLimit(model.SocketMaxMessageSizeKb)
|
wc.WebSocket.SetReadLimit(model.SocketMaxMessageSizeKb)
|
||||||
wc.WebSocket.SetReadDeadline(time.Now().Add(pongWaitTime))
|
err := wc.WebSocket.SetReadDeadline(time.Now().Add(pongWaitTime))
|
||||||
|
if err != nil {
|
||||||
|
wc.logSocketErr("websocket.SetReadDeadline", err)
|
||||||
|
return
|
||||||
|
}
|
||||||
wc.WebSocket.SetPongHandler(func(string) error {
|
wc.WebSocket.SetPongHandler(func(string) error {
|
||||||
if err := wc.WebSocket.SetReadDeadline(time.Now().Add(pongWaitTime)); err != nil {
|
if err := wc.WebSocket.SetReadDeadline(time.Now().Add(pongWaitTime)); err != nil {
|
||||||
return err
|
return err
|
||||||
@@ -551,7 +555,9 @@ func (wc *WebConn) writePump() {
|
|||||||
select {
|
select {
|
||||||
case msg, ok := <-wc.send:
|
case msg, ok := <-wc.send:
|
||||||
if !ok {
|
if !ok {
|
||||||
wc.writeMessageBuf(websocket.CloseMessage, []byte{})
|
if err := wc.writeMessageBuf(websocket.CloseMessage, []byte{}); err != nil {
|
||||||
|
wc.logSocketErr("websocket.send", err)
|
||||||
|
}
|
||||||
return
|
return
|
||||||
}
|
}
|
||||||
|
|
||||||
@@ -620,7 +626,9 @@ func (wc *WebConn) writePump() {
|
|||||||
// writeMessageBuf is a helper utility that wraps the write to the socket
|
// writeMessageBuf is a helper utility that wraps the write to the socket
|
||||||
// along with setting the write deadline.
|
// along with setting the write deadline.
|
||||||
func (wc *WebConn) writeMessageBuf(msgType int, data []byte) error {
|
func (wc *WebConn) writeMessageBuf(msgType int, data []byte) error {
|
||||||
wc.WebSocket.SetWriteDeadline(time.Now().Add(writeWaitTime))
|
if err := wc.WebSocket.SetWriteDeadline(time.Now().Add(writeWaitTime)); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
return wc.WebSocket.WriteMessage(msgType, data)
|
return wc.WebSocket.WriteMessage(msgType, data)
|
||||||
}
|
}
|
||||||
|
|
||||||
|
|||||||
Ссылка в новой задаче
Block a user