From 0dd8eeaca7cf92e62d61bba1d457bbdfe95240a7 Mon Sep 17 00:00:00 2001 From: hujiebin Date: Thu, 3 Aug 2023 16:40:00 +0800 Subject: [PATCH] =?UTF-8?q?feat:=E4=BC=98=E5=8C=96socket=E6=89=93=E7=82=B9?= MIME-Version: 1.0 Content-Type: text/plain; charset=UTF-8 Content-Transfer-Encoding: 8bit --- rpc/user_center_func.go | 7 +++---- 1 file changed, 3 insertions(+), 4 deletions(-) diff --git a/rpc/user_center_func.go b/rpc/user_center_func.go index 47f7732..6098a98 100644 --- a/rpc/user_center_func.go +++ b/rpc/user_center_func.go @@ -414,17 +414,16 @@ func SendSocketMicChange(seqId string, userId uint64, micUserExternalId, txGroup Timestamp: time.Now().UnixNano(), User: micUserData, } + n := 0 if buffer, err := proto.Marshal(msg); err == nil { userIds := []uint64{userId} var rspUids []uint64 - n := 0 for { n++ rspUids, err = multicast(userIds, MsgTypeGroupMicChange, buffer, time.Duration(10)) if n >= 3 || len(rspUids) <= 0 { break } - mylogrus.MyLog.Infof("grpc SendSocketMicChange send fail,seqId:%v,retry:%v,data:%v", seqId, n, *msg) time.Sleep(time.Millisecond * 200) } @@ -435,10 +434,10 @@ func SendSocketMicChange(seqId string, userId uint64, micUserExternalId, txGroup }(userId, msg, rspUids, err) if err != nil { - mylogrus.MyLog.Errorf("grpc SendSocketMicChange send fail") + mylogrus.MyLog.Errorf("grpc SendSocketMicChange send fail,seqId:%v,retry:%v,data:%v,err:%v", seqId, n, *msg, err) return err } else { - mylogrus.MyLog.Info("grpc SendSocketMicChange send success") + mylogrus.MyLog.Infof("grpc SendSocketMicChange send success,seqId:%v,retry:%v,data:%v", seqId, n, *msg) } } else { return err -- 2.22.0