blackteay/open-im-server
1
0
Fork 0
mirror of https://github.com/openimsdk/open-im-server.git synced 2025-05-01 07:03:15 +08:00
Code Issues Packages Projects Releases Wiki Activity

log change

Browse Source
This commit is contained in:
Gordon 2022-05-21 14:19:45 +08:00
parent f1e2704407
commit 7d1843f485
1 changed files with 9 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

12
internal/msg_transfer/logic/online_history_msg_handler.go
View File

@ -129,9 +129,15 @@ func (och *OnlineHistoryConsumerHandler) Run(channelID int) {
singleMsgSuccessCountMutex.Lock() singleMsgSuccessCountMutex.Lock()
singleMsgSuccessCount += uint64(len(storageMsgList)) singleMsgSuccessCount += uint64(len(storageMsgList))
singleMsgSuccessCountMutex.Unlock() singleMsgSuccessCountMutex.Unlock()
for _, v := range pushMsgList { //go func(push,storage []*pbMsg.MsgDataToMQ) {
sendMessageToPush(v, msgChannelValue.userID) // for _, v := range storage {
} // sendMessageToPush(v, msgChannelValue.userID)
// }
// for _, x := range utils.DifferenceString() {
// sendMessageToPush(v, msgChannelValue.userID)
// }
//
//}(pushMsgList,storageMsgList)
} }
} }