From bc299677ada8ed630d64f3b6b6e5698892c1d21c Mon Sep 17 00:00:00 2001 From: suyl <770236076@qq.com> Date: Thu, 29 Jul 2021 14:53:07 +0800 Subject: [PATCH] aa --- business/jxstore/event/event.go | 10 +++++----- 1 file changed, 5 insertions(+), 5 deletions(-) diff --git a/business/jxstore/event/event.go b/business/jxstore/event/event.go index 886945f4d..f47a6f85d 100644 --- a/business/jxstore/event/event.go +++ b/business/jxstore/event/event.go @@ -45,7 +45,7 @@ func init() { clientsHeart := make(map[string]*websocket.Conn) wsClient.Clients = clients wsClient.ClientsHeart = clientsHeart - wsClient = new(sync.RWMutex) + wsClient.s = new(sync.RWMutex) go handleMessages() } @@ -100,7 +100,7 @@ func ImMessage(userID string, ws *websocket.Conn) (err error) { if len(messageGroups) == 0 { return } - wsClient.Lock() + wsClient.s.Lock() clientUser[userID] = ws wsClient.ClientsHeart[userID] = ws for _, v := range messageGroups { @@ -110,7 +110,7 @@ func ImMessage(userID string, ws *websocket.Conn) (err error) { wsClient.Clients[v.GroupID] = clientUser } } - wsClient.Unlock() + wsClient.s.Unlock() globals.SugarLogger.Debugf("userID :%v ,clients :%v", userID, utils.Format4Output(wsClient.Clients, false)) var s *model.ImMessageRecord @@ -173,9 +173,9 @@ func ImMessage(userID string, ws *websocket.Conn) (err error) { } func GetOnlineUserCount() (count int) { - wsClient.RLock() + wsClient.s.RLock() count = len(wsClient.ClientsHeart) - wsClient.RUnlock() + wsClient.s.RUnlock() return count }