Skip to content

Commit 30f7220

Browse files
committed
review comments
1 parent 471b3da commit 30f7220

1 file changed

Lines changed: 9 additions & 7 deletions

File tree

src/storage/redis_db.cc

Lines changed: 9 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -585,13 +585,15 @@ rocksdb::Status SubKeyScanner::Scan(engine::Context &ctx, RedisType type, const
585585
break;
586586
}
587587
InternalKey ikey(iter->key(), storage_->IsSlotIdEncoded());
588-
uint64_t expire_at = NoExpireTime;
589-
s = GetSubKeyExpireTimestampMS(ctx, user_key, ikey.GetSubKey(), metadata.version, &expire_at);
590-
if (!s.ok() && !s.IsNotFound()) {
591-
return s;
592-
}
593-
if (expire_at != NoExpireTime && expire_at < util::GetTimeStampMS()) {
594-
continue;
588+
if (type == kRedisHash) {
589+
uint64_t expire_at = NoExpireTime;
590+
s = GetSubKeyExpireTimestampMS(ctx, user_key, ikey.GetSubKey(), metadata.version, &expire_at);
591+
if (!s.ok() && !s.IsNotFound()) {
592+
return s;
593+
}
594+
if (expire_at != NoExpireTime && expire_at < util::GetTimeStampMS()) {
595+
continue;
596+
}
595597
}
596598
keys->emplace_back(ikey.GetSubKey().ToString());
597599
if (values != nullptr) {

0 commit comments

Comments
 (0)