diff --git a/src/server/game/message_mgr.go b/src/server/game/message_mgr.go index ad73ea41..e9e94b60 100644 --- a/src/server/game/message_mgr.go +++ b/src/server/game/message_mgr.go @@ -103,32 +103,32 @@ func (m *MessageMgr) MessageMgrInit() { } func FixBug() { - messageMgrData := getMessageData() - // 先更新 PlayerList(需要加锁) - messageMgrData.mu.Lock() - defer messageMgrData.mu.Unlock() - now := GoUtil.Now() - for k, v := range messageMgrData.MessageList { - if k < 100000 { - delete(messageMgrData.MessageList, k) - continue - } - isLose := CheckPlayerLose(int(k)) - // 反向遍历以安全删除元素 - for i := len(v.Messages) - 1; i >= 0; i-- { - if v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_NOTIFY || (v.Messages[i].End != 0 && v.Messages[i].End < now) { - // 删除消息 - v.Messages = append(v.Messages[:i], v.Messages[i+1:]...) - } - if isLose && v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_RESULT { - // 删除消息 - v.Messages = append(v.Messages[:i], v.Messages[i+1:]...) - } - } - if len(v.Messages) == 0 { - delete(messageMgrData.MessageList, k) - } - } + // messageMgrData := getMessageData() + // // 先更新 PlayerList(需要加锁) + // messageMgrData.mu.Lock() + // defer messageMgrData.mu.Unlock() + // now := GoUtil.Now() + // for k, v := range messageMgrData.MessageList { + // if k < 100000 { + // delete(messageMgrData.MessageList, k) + // continue + // } + // isLose := CheckPlayerLose(int(k)) + // // 反向遍历以安全删除元素 + // for i := len(v.Messages) - 1; i >= 0; i-- { + // if v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_NOTIFY || (v.Messages[i].End != 0 && v.Messages[i].End < now) { + // // 删除消息 + // v.Messages = append(v.Messages[:i], v.Messages[i+1:]...) + // } + // if isLose && v.Messages[i].Type == msg.HANDLE_TYPE_CHAMPSHIP_RESULT { + // // 删除消息 + // v.Messages = append(v.Messages[:i], v.Messages[i+1:]...) + // } + // } + // if len(v.Messages) == 0 { + // delete(messageMgrData.MessageList, k) + // } + // } } // 注册处理器