Function decodeShardMapping

fdbserver/KeyValueStoreShardedRocksDB.actor.cpp:167–185

}

std::vector<std::pair<KeyRange, std::string>> decodeShardMapping(const RangeResult& result, StringRef prefix) {
	std::vector<std::pair<KeyRange, std::string>> shards;
	KeyRef endKey;
	std::string name;

	for (const auto& kv : result) {
		auto keyWithoutPrefix = kv.key.removePrefix(prefix);
		if (name.size() > 0) {
			shards.push_back({ KeyRange(KeyRangeRef(endKey, keyWithoutPrefix)), name });
			TraceEvent(SevDebug, "DecodeShardMapping")
			    .detail("BeginKey", endKey)
			    .detail("EndKey", keyWithoutPrefix)
			    .detail("Name", name);
		}
		endKey = keyWithoutPrefix;
		name = kv.value.toString();
	}
	return shards;
}

void logRocksDBError(const rocksdb::Status& status, const std::string& method) {
	auto level = status.IsTimedOut() ? SevWarn : SevError;