Skip to content

Commit 8d2bf9b

Browse files
Merge branch 'unstable' into unstable
2 parents e03180e + a205194 commit 8d2bf9b

File tree

6 files changed

+8
-3
lines changed

6 files changed

+8
-3
lines changed

src/cluster/slot_migrate.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -790,7 +790,7 @@ Status SlotMigrator::migrateComplexKey(const rocksdb::Slice &key, const Metadata
790790
if (metadata.Type() > RedisTypeNames.size()) {
791791
return {Status::NotOK, "unknown key type: " + std::to_string(metadata.Type())};
792792
}
793-
return {Status::NotOK, "unsupported complex key type: " + RedisTypeNames[metadata.Type()]};
793+
return {Status::NotOK, "unsupported complex key type: " + metadata.TypeName()};
794794
}
795795
}
796796

src/commands/cmd_search.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -436,7 +436,7 @@ class CommandFTInfo : public Commander {
436436
output->append(redis::SimpleString("index_definition"));
437437
output->append(redis::MultiLen(4));
438438
output->append(redis::SimpleString("key_type"));
439-
output->append(redis::BulkString(RedisTypeNames[(size_t)info->metadata.on_data_type]));
439+
output->append(redis::BulkString(info->metadata.OnDataTypeName()));
440440
output->append(redis::SimpleString("prefixes"));
441441
output->append(redis::ArrayOfBulkStrings(info->prefixes.prefixes));
442442

src/search/search_encoding.h

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -40,6 +40,8 @@ class IndexMetadata {
4040
uint8_t flag = 0; // all reserved
4141
IndexOnDataType on_data_type;
4242

43+
const std::string &OnDataTypeName() const { return RedisTypeNames[(size_t)on_data_type]; }
44+
4345
void Encode(std::string *dst) const {
4446
PutFixed8(dst, flag);
4547
PutFixed8(dst, uint8_t(on_data_type));

src/storage/redis_db.cc

Lines changed: 1 addition & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -477,7 +477,7 @@ rocksdb::Status Database::Dump(engine::Context &ctx, const Slice &user_key, std:
477477
infos->emplace_back("namespace");
478478
infos->emplace_back(namespace_);
479479
infos->emplace_back("type");
480-
infos->emplace_back(RedisTypeNames[metadata.Type()]);
480+
infos->emplace_back(metadata.TypeName());
481481
infos->emplace_back("version");
482482
infos->emplace_back(std::to_string(metadata.version));
483483
infos->emplace_back("expire");

src/storage/redis_metadata.cc

Lines changed: 2 additions & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -222,6 +222,8 @@ bool Metadata::operator==(const Metadata &that) const {
222222

223223
RedisType Metadata::Type() const { return static_cast<RedisType>(flags & METADATA_TYPE_MASK); }
224224

225+
const std::string &Metadata::TypeName() const { return RedisTypeNames[Type()]; }
226+
225227
size_t Metadata::GetOffsetAfterExpire(uint8_t flags) {
226228
if (flags & METADATA_64BIT_ENCODING_MASK) {
227229
return 1 + 8;

src/storage/redis_metadata.h

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -176,6 +176,7 @@ class Metadata {
176176
void PutExpire(std::string *dst) const;
177177

178178
RedisType Type() const;
179+
const std::string &TypeName() const;
179180
size_t CommonEncodedSize() const;
180181
int64_t TTL() const;
181182
timeval Time() const;

0 commit comments

Comments
 (0)