wbtiger
/
foundationdb
mirror of https://github.com/apple/foundationdb.git
1
0
Fork 0
Code Issues Packages Projects Releases Wiki Activity

Use sizeof() to replace constant numbers

This commit is contained in:
Jingyu Zhou 2019-11-22 11:47:25 -08:00
parent dbfa3dc217
commit 9927a9013f
1 changed files with 10 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
fdbserver/RestoreLoader.actor.cpp
View File

@ -363,13 +363,14 @@ bool concatenateBackupMutationForLogFile(std::map<Standalone<StringRef>, Standal
std::string prefix = "||\t";
std::stringstream ss;
StringRef val = val_input.contents();
const int key_suffix_len = sizeof(uint8_t) + sizeof(Version) + sizeof(uint32_t);
StringRefReaderMX reader(val, restore_corrupted_data());
StringRefReaderMX readerKey(key_input, restore_corrupted_data()); // read key_input!
int logRangeMutationFirstLength = key_input.size() - 1 - 8 - 4;
int logRangeMutationFirstLength = key_input.size() - key_suffix_len;
bool concatenated = false;
ASSERT_WE_THINK(key_input.size() >= 1 + 8 + 4);
ASSERT_WE_THINK(key_input.size() >= key_suffix_len);
if (logRangeMutationFirstLength > 0) {
// Strip out the [logRangeMutation.first]; otherwise, the following readerKey.consume will produce wrong value
@ -377,10 +378,10 @@ bool concatenateBackupMutationForLogFile(std::map<Standalone<StringRef>, Standal
}
readerKey.consume<uint8_t>(); // uint8_t hashValue = readerKey.consume<uint8_t>()
uint64_t commitVersion = readerKey.consumeNetworkUInt64();
Version commitVersion = readerKey.consumeNetworkUInt64();
uint32_t part = readerKey.consumeNetworkUInt32();
// Use commitVersion as id
Standalone<StringRef> id = StringRef((uint8_t*)&commitVersion, 8);
Standalone<StringRef> id = StringRef((uint8_t*)&commitVersion, sizeof(Version));
if (mutationMap.find(id) == mutationMap.end()) {
mutationMap.insert(std::make_pair(id, val_input));
@ -442,10 +443,11 @@ void _parseSerializedMutation(VersionedMutationsMap* pkvOps, SerializedMutationL
StringRefReaderMX vReader(val, restore_corrupted_data());
vReader.consume<uint64_t>(); // Consume the includeVersion
uint32_t val_length_decoded =
vReader.consume<uint32_t>(); // Parse little endian value, confirmed it is correct!
ASSERT(val_length_decoded ==
val.size() - 12); // 12 is the length of [includeVersion:uint64_t][val_length:uint32_t]
// TODO(xumengpanda): verify the protocol version is compatible and raise error if needed
// Parse little endian value, confirmed it is correct!
uint32_t val_length_decoded = vReader.consume<uint32_t>();
ASSERT(val_length_decoded == val.size() - sizeof(uint64_t) - sizeof(uint32_t));
while (1) {
// stop when reach the end of the string