diff --git a/main.go b/main.go index 9ec20c9b80bb7e85b829f90bf3b3b273c3622f54..e38683e28173066985b9bb174024542751b8732d 100644 --- a/main.go +++ b/main.go @@ -9,7 +9,6 @@ import ( "net/url" "os" "strconv" - "strings" "time" "github.com/go-redis/redis/v8" @@ -216,10 +215,10 @@ func (s *server) Broadcast(ctx context.Context, in *userCenter.BroadcastMessage) } for addr, users := range m { //addr = strings.Replace(addr, "47.91.121.73", "172.26.95.24", -1) - mylogrus.MyLog.Infof("Broadcasting: Addr %s: %d users", addr, len(users)) - if !strings.Contains(addr, "172.26.95.48:50050") && !strings.Contains(addr, "172.26.95.24:50050") { - mylogrus.MyLog.Errorf("Broadcasting: Addr error %s: %d users", addr, len(users)) - } + //mylogrus.MyLog.Infof("Broadcasting: Addr %s: %d users", addr, len(users)) + //if !strings.Contains(addr, "172.26.95.48:50050") && !strings.Contains(addr, "172.26.95.24:50050") { + // mylogrus.MyLog.Errorf("Broadcasting: Addr error %s: %d users", addr, len(users)) + //} const sendBatchSize = 5 for i := 0; i < len(users); i += sendBatchSize { @@ -296,7 +295,7 @@ func (s *server) GetLastRoomHeartbeat(ctx context.Context, in *userCenter.GetLas } func realBroadcast(addr string, uids []uint64, msg *userCenter.BroadcastMessage) { - mylogrus.MyLog.Infof("Broadcasting: Addr %s: users: %v", addr, uids) + //mylogrus.MyLog.Infof("Broadcasting: Addr %s: users: %v", addr, uids) for _, uid := range uids { client := manager.UserProxyMgr.MakeClient(addr)