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

During initialization, keyRangePhysicalShardIDMap may not contain full range. Adjust assertion in checkKeyRangePhysicalShardMapping

This commit is contained in:
Zhe Wu 2022-12-07 00:25:01 -08:00
parent a6cd33134a
commit 75b2c14d0f
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
fdbserver/DDShardTracker.actor.cpp
View File

@ -1629,6 +1629,9 @@ void PhysicalShardCollection::updatekeyRangePhysicalShardIDMap(KeyRange keyRange
std::set<uint64_t> physicalShardIDSet;
for (auto it = ranges.begin(); it != ranges.end(); ++it) {
uint64_t shardID = it->value();
if (shardID == UID().first()) {
continue;
}
ASSERT(physicalShardInstances.find(shardID) != physicalShardInstances.end());
physicalShardInstances[shardID].removeRange(keyRange);
}
@ -1647,8 +1650,11 @@ void PhysicalShardCollection::checkKeyRangePhysicalShardMapping() {
KeyRangeMap<uint64_t>::iterator it = keyRangePhysicalShardIDRanges.begin();
for (; it != keyRangePhysicalShardIDRanges.end(); ++it) {
uint64_t shardID = it->value();
ASSERT(physicalShardInstances.find(shardID) != physicalShardInstances.end());
if (shardID == UID().first()) {
continue;
}
auto keyRangePiece = KeyRangeRef(it->range().begin, it->range().end);
ASSERT(physicalShardInstances.find(shardID) != physicalShardInstances.end());
bool exist = false;
for (const auto& [range, data] : physicalShardInstances[shardID].rangeData) {
if (range == keyRangePiece) {