|
@@ -161,6 +161,11 @@ func broadcast(pbmsg protoreflect.ProtoMessage) {
|
|
|
}
|
|
}
|
|
|
|
|
|
|
|
func writeMessageToClient(client *WebsocketClient, message []byte) {
|
|
func writeMessageToClient(client *WebsocketClient, message []byte) {
|
|
|
|
|
+ if message == nil {
|
|
|
|
|
+ log.Warnf("writeMessageToClient: message is nil")
|
|
|
|
|
+ return
|
|
|
|
|
+ }
|
|
|
|
|
+
|
|
|
sendmutex.Lock()
|
|
sendmutex.Lock()
|
|
|
if err := client.conn.WriteMessage(ws.TextMessage, message); err != nil {
|
|
if err := client.conn.WriteMessage(ws.TextMessage, message); err != nil {
|
|
|
log.WithFields(log.Fields{
|
|
log.WithFields(log.Fields{
|