diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go index 10158eed..d43ddb1c 100644 --- a/src/server/game/message_mgr.go +++ b/src/server/game/message_mgr.go @@ -198,7 +198,8 @@ func ClusterSyncHandler(data *msg.Msg) (interface{}, error) { messageMgrData.mu.Lock() TempMessageList := messageMgrData.MessageList messageMgrData.MessageList = make(map[int64]*MessageList) - messageMgrData.mu.Unlock() + defer messageMgrData.mu.Unlock() + log.Debug("[Middleware] Cluster sync send temp message len: %d", len(TempMessageList)) for _, Message := range TempMessageList { for _, msgItem := range Message.Messages { SendMsgToCenterAsync(msgItem)