Krakatoa-Earth
/
Backend
3
0
Fork 0
Code Issues Pull Requests Projects Releases Wiki Activity

better error handling for SendBinaryMessage

master
Alex 2022-03-15 19:24:21 +01:00
parent 7afb928123
commit 6606c1fbde
1 changed files with 16 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
modules/structs/WebClient.go
View File

@ -41,14 +41,28 @@ type WebClient struct {
} }
func (webClient *WebClient) SendBinaryMessage(conn *websocket.Conn, msg []byte) error { func (webClient *WebClient) SendBinaryMessage(conn *websocket.Conn, msg []byte) error {
var err error
if conn == webClient.MobileConn { if conn == webClient.MobileConn {
webClient.mobileConnMu.Lock() webClient.mobileConnMu.Lock()
defer webClient.mobileConnMu.Unlock() defer webClient.mobileConnMu.Unlock()
return conn.WriteMessage(websocket.BinaryMessage, msg) err = conn.WriteMessage(websocket.BinaryMessage, msg)
if err != nil {
logger.WebMobile.Warnln("err SendBinaryMessage to mobile client")
}
return err
} }
webClient.voiceConnMu.Lock() webClient.voiceConnMu.Lock()
defer webClient.voiceConnMu.Unlock() defer webClient.voiceConnMu.Unlock()
return conn.WriteMessage(websocket.BinaryMessage, msg)
err = conn.WriteMessage(websocket.BinaryMessage, msg)
if err != nil {
logger.WebVoice.Warnln("err SendBinaryMessage to voice client")
}
return err
} }
func (webClient *WebClient) RemoveVoiceCmdID(cmdID int) { func (webClient *WebClient) RemoveVoiceCmdID(cmdID int) {