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 17:23:21 +08:00
parent 3d0827a6da
commit 0f655e9292
1 changed files with 3 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -214,17 +214,18 @@ func DelGroupMemberInfoFromCache(groupID, userID string) error {
func GetGroupMembersInfoFromCache(count, offset int32, groupID string) ([]*db.GroupMember, error) { func GetGroupMembersInfoFromCache(count, offset int32, groupID string) ([]*db.GroupMember, error) {
var cursor uint64 var cursor uint64
var err error var err error
var keys []string var keys, currentKeys []string
key := groupMemberInfoCache + groupID + "-" key := groupMemberInfoCache + groupID + "-"
if count != 0 { if count != 0 {
keys, cursor, err = db.DB.RDB.Scan(context.Background(), uint64(offset), key, int64(count)).Result() keys, cursor, err = db.DB.RDB.Scan(context.Background(), uint64(offset), key, int64(count)).Result()
if err != nil { if err != nil {
return nil, err return nil, err
} }
keys = append(keys, currentKeys...)
} else { } else {
for { for {
var currentKeys []string var currentKeys []string
currentKeys, cursor, err = db.DB.RDB.Scan(context.Background(), cursor, key, 3000).Result() currentKeys, cursor, err = db.DB.RDB.Scan(context.Background(), cursor, key, int64(count)).Result()
if err != nil { if err != nil {
return nil, err return nil, err
} }