From 0f655e9292045002579e22a17ae78f1321793c64 Mon Sep 17 00:00:00 2001 From: wangchuxiao Date: Thu, 4 Aug 2022 17:23:21 +0800 Subject: [PATCH] callback fix --- pkg/common/db/rocks_cache/rocks_cache.go | 5 +++-- 1 file changed, 3 insertions(+), 2 deletions(-) diff --git a/pkg/common/db/rocks_cache/rocks_cache.go b/pkg/common/db/rocks_cache/rocks_cache.go index 2300d051d..6f8cfe562 100644 --- a/pkg/common/db/rocks_cache/rocks_cache.go +++ b/pkg/common/db/rocks_cache/rocks_cache.go @@ -214,17 +214,18 @@ func DelGroupMemberInfoFromCache(groupID, userID string) error { func GetGroupMembersInfoFromCache(count, offset int32, groupID string) ([]*db.GroupMember, error) { var cursor uint64 var err error - var keys []string + var keys, currentKeys []string key := groupMemberInfoCache + groupID + "-" if count != 0 { keys, cursor, err = db.DB.RDB.Scan(context.Background(), uint64(offset), key, int64(count)).Result() if err != nil { return nil, err } + keys = append(keys, currentKeys...) } else { for { 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 { return nil, err }