diff --git a/db/db_properties_test.cc b/db/db_properties_test.cc index 2c843a974..074f4e9a8 100644 --- a/db/db_properties_test.cc +++ b/db/db_properties_test.cc @@ -2109,25 +2109,26 @@ TEST_F(DBPropertiesTest, GetMapPropertyBlockCacheEntryStats) { TEST_F(DBPropertiesTest, WriteStallStatsSanityCheck) { for (uint32_t i = 0; i < static_cast(WriteStallCause::kNone); ++i) { - std::string str = kWriteStallCauseToHyphenString[i]; + WriteStallCause cause = static_cast(i); + const std::string& str = WriteStallCauseToHyphenString(cause); ASSERT_TRUE(!str.empty()) << "Please ensure mapping from `WriteStallCause` to " - "`kWriteStallCauseToHyphenString` is complete"; - WriteStallCause cause = static_cast(i); + "`WriteStallCauseToHyphenString` is complete"; if (cause == WriteStallCause::kCFScopeWriteStallCauseEnumMax || cause == WriteStallCause::kDBScopeWriteStallCauseEnumMax) { - ASSERT_EQ(str, kInvalidWriteStallCauseHyphenString) - << "Please ensure order in `kWriteStallCauseToHyphenString` is " + ASSERT_EQ(str, InvalidWriteStallHyphenString()) + << "Please ensure order in `WriteStallCauseToHyphenString` is " "consistent with `WriteStallCause`"; } } for (uint32_t i = 0; i < static_cast(WriteStallCondition::kNormal); ++i) { - std::string str = kWriteStallConditionToHyphenString[i]; + WriteStallCondition condition = static_cast(i); + const std::string& str = WriteStallConditionToHyphenString(condition); ASSERT_TRUE(!str.empty()) << "Please ensure mapping from `WriteStallCondition` to " - "`kWriteStallConditionToHyphenString` is complete"; + "`WriteStallConditionToHyphenString` is complete"; } for (uint32_t i = 0; i < static_cast(WriteStallCause::kNone); ++i) { diff --git a/db/write_stall_stats.cc b/db/write_stall_stats.cc index 3143531e7..3973df768 100644 --- a/db/write_stall_stats.cc +++ b/db/write_stall_stats.cc @@ -6,26 +6,46 @@ #include "db/write_stall_stats.h" namespace ROCKSDB_NAMESPACE { -const std::string kInvalidWriteStallCauseHyphenString = "invalid"; - -const std::array(WriteStallCause::kNone)> - kWriteStallCauseToHyphenString{{ - "memtable-limit", - "l0-file-count-limit", - "pending-compaction-bytes", - // WriteStallCause::kCFScopeWriteStallCauseEnumMax - kInvalidWriteStallCauseHyphenString, - "write-buffer-manager-limit", - // WriteStallCause::kDBScopeWriteStallCauseEnumMax - kInvalidWriteStallCauseHyphenString, - }}; - -const std::array(WriteStallCondition::kNormal)> - kWriteStallConditionToHyphenString{{ - "delays", - "stops", - }}; +const std::string& InvalidWriteStallHyphenString() { + static const std::string kInvalidWriteStallHyphenString = "invalid"; + return kInvalidWriteStallHyphenString; +} + +const std::string& WriteStallCauseToHyphenString(WriteStallCause cause) { + static const std::string kMemtableLimit = "memtable-limit"; + static const std::string kL0FileCountLimit = "l0-file-count-limit"; + static const std::string kPendingCompactionBytes = "pending-compaction-bytes"; + static const std::string kWriteBufferManagerLimit = + "write-buffer-manager-limit"; + switch (cause) { + case WriteStallCause::kMemtableLimit: + return kMemtableLimit; + case WriteStallCause::kL0FileCountLimit: + return kL0FileCountLimit; + case WriteStallCause::kPendingCompactionBytes: + return kPendingCompactionBytes; + case WriteStallCause::kWriteBufferManagerLimit: + return kWriteBufferManagerLimit; + default: + break; + } + return InvalidWriteStallHyphenString(); +} + +const std::string& WriteStallConditionToHyphenString( + WriteStallCondition condition) { + static const std::string kDelayed = "delays"; + static const std::string kStopped = "stops"; + switch (condition) { + case WriteStallCondition::kDelayed: + return kDelayed; + case WriteStallCondition::kStopped: + return kStopped; + default: + break; + } + return InvalidWriteStallHyphenString(); +} InternalStats::InternalCFStatsType InternalCFStat( WriteStallCause cause, WriteStallCondition condition) { @@ -139,14 +159,14 @@ std::string WriteStallStatsMapKeys::CauseConditionCount( std::string cause_name; if (isCFScopeWriteStallCause(cause) || isDBScopeWriteStallCause(cause)) { - cause_name = kWriteStallCauseToHyphenString[static_cast(cause)]; + cause_name = WriteStallCauseToHyphenString(cause); } else { assert(false); return ""; } const std::string& condition_name = - kWriteStallConditionToHyphenString[static_cast(condition)]; + WriteStallConditionToHyphenString(condition); cause_condition_count_name.reserve(cause_name.size() + 1 + condition_name.size()); diff --git a/db/write_stall_stats.h b/db/write_stall_stats.h index 9ae518a07..6394abb0a 100644 --- a/db/write_stall_stats.h +++ b/db/write_stall_stats.h @@ -11,15 +11,12 @@ #include "rocksdb/types.h" namespace ROCKSDB_NAMESPACE { -extern const std::string kInvalidWriteStallCauseHyphenString; +extern const std::string& InvalidWriteStallHyphenString(); -extern const std::array(WriteStallCause::kNone)> - kWriteStallCauseToHyphenString; +extern const std::string& WriteStallCauseToHyphenString(WriteStallCause cause); -extern const std::array(WriteStallCondition::kNormal)> - kWriteStallConditionToHyphenString; +extern const std::string& WriteStallConditionToHyphenString( + WriteStallCondition condition); // REQUIRES: // cause` is CF-scope `WriteStallCause`, see `WriteStallCause` for more