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

callback fix

Browse Source
This commit is contained in:
wangchuxiao 2022-08-04 18:55:38 +08:00
parent db547d60df
commit 576348b1f2
1 changed files with 18 additions and 11 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

29
pkg/common/db/rocks_cache/rocks_cache.go
View File

@ -217,23 +217,30 @@ func GetGroupMembersInfoFromCache(count, offset int32, groupID string) ([]*db.Gr
return nil, nil return nil, nil
} }
var groupMemberList []*db.GroupMember var groupMemberList []*db.GroupMember
var start, stop int32
start = offset
stop = offset + count
l := int32(len(groupMemberIDList))
if start > stop {
return nil, nil
}
if start >= l {
return nil, nil
}
if count != 0 { if count != 0 {
l := int32(len(groupMemberIDList))
var start, stop int32
start = offset
stop = offset + count
if start > stop {
return nil, nil
}
if start >= l {
return nil, nil
}
if stop >= l { if stop >= l {
stop = l stop = l
} }
groupMemberIDList = groupMemberIDList[start:stop] groupMemberIDList = groupMemberIDList[start:stop]
} else {
if l < 1000 {
stop = l
} else {
stop = 1000
}
groupMemberIDList = groupMemberIDList[start:stop]
} }
log.NewDebug("", utils.GetSelfFuncName(), "ID list: ", groupMemberIDList) //log.NewDebug("", utils.GetSelfFuncName(), "ID list: ", groupMemberIDList)
for _, userID := range groupMemberIDList { for _, userID := range groupMemberIDList {
groupMembers, err := GetGroupMemberInfoFromCache(groupID, userID) groupMembers, err := GetGroupMemberInfoFromCache(groupID, userID)
if err != nil { if err != nil {