Finish checkRangeRightSide conversion

This commit is contained in:
2024-09-04 12:36:43 -07:00
parent 5c39c1d64f
commit ce853680f2

View File

@@ -2594,11 +2594,8 @@ downLeftSpine:
// Return true if the max version among all keys that start with key[:prefixLen] // Return true if the max version among all keys that start with key[:prefixLen]
// that are < key is <= readVersion // that are < key is <= readVersion
struct CheckRangeRightSide { bool checkRangeRightSide(Node *n, std::span<const uint8_t> key, int prefixLen,
bool step(Node *n, std::span<const uint8_t> key, int prefixLen,
InternalVersionT readVersion, ReadContext *tls) { InternalVersionT readVersion, ReadContext *tls) {
bool ok;
auto remaining = key; auto remaining = key;
int searchPathLen = 0; int searchPathLen = 0;
@@ -2610,20 +2607,17 @@ struct CheckRangeRightSide {
if (searchPathLen >= prefixLen) { if (searchPathLen >= prefixLen) {
if (n->entryPresent && n->entry.pointVersion > readVersion) { if (n->entryPresent && n->entry.pointVersion > readVersion) {
ok = false; return false;
return ok;
} }
if (!checkMaxBetweenExclusive(n, -1, remaining[0], readVersion, tls)) { if (!checkMaxBetweenExclusive(n, -1, remaining[0], readVersion, tls)) {
ok = false; return false;
return ok;
} }
} }
if (searchPathLen > prefixLen && n->entryPresent && if (searchPathLen > prefixLen && n->entryPresent &&
n->entry.rangeVersion > readVersion) { n->entry.rangeVersion > readVersion) {
ok = false; return false;
return ok;
} }
auto *child = getChild(n, remaining[0]); auto *child = getChild(n, remaining[0]);
@@ -2643,8 +2637,7 @@ struct CheckRangeRightSide {
if (n->partialKeyLen > 0) { if (n->partialKeyLen > 0) {
int commonLen = std::min<int>(n->partialKeyLen, remaining.size()); int commonLen = std::min<int>(n->partialKeyLen, remaining.size());
int i = int i = longestCommonPrefix(n->partialKey(), remaining.data(), commonLen);
longestCommonPrefix(n->partialKey(), remaining.data(), commonLen);
searchPathLen += i; searchPathLen += i;
if (i < commonLen) { if (i < commonLen) {
++searchPathLen; ++searchPathLen;
@@ -2654,31 +2647,27 @@ struct CheckRangeRightSide {
} else { } else {
if (searchPathLen > prefixLen && n->entryPresent && if (searchPathLen > prefixLen && n->entryPresent &&
n->entry.rangeVersion > readVersion) { n->entry.rangeVersion > readVersion) {
ok = false; return false;
return ok;
} }
goto backtrack; goto backtrack;
} }
} }
if (commonLen == n->partialKeyLen) { if (commonLen == n->partialKeyLen) {
// partial key matches // partial key matches
remaining = remaining = remaining.subspan(commonLen, remaining.size() - commonLen);
remaining.subspan(commonLen, remaining.size() - commonLen);
} else if (n->partialKeyLen > int(remaining.size())) { } else if (n->partialKeyLen > int(remaining.size())) {
goto downLeftSpine; goto downLeftSpine;
} }
} }
} }
backtrack: backtrack:
for (;;) { for (;;) {
// searchPathLen > prefixLen implies n is not the root // searchPathLen > prefixLen implies n is not the root
if (searchPathLen > prefixLen && maxVersion(n) > readVersion) { if (searchPathLen > prefixLen && maxVersion(n) > readVersion) {
ok = false; return false;
return ok;
} }
if (n->parent == nullptr) { if (n->parent == nullptr) {
ok = true; return true;
return ok;
} }
auto next = getChildGeq(n->parent, n->parentsIndex + 1); auto next = getChildGeq(n->parent, n->parentsIndex + 1);
if (next == nullptr) { if (next == nullptr) {
@@ -2691,13 +2680,11 @@ struct CheckRangeRightSide {
goto downLeftSpine; goto downLeftSpine;
} }
} }
downLeftSpine: downLeftSpine:
for (; !n->entryPresent; n = getFirstChildExists(n)) { for (; !n->entryPresent; n = getFirstChildExists(n)) {
} }
ok = n->entry.rangeVersion <= readVersion; return n->entry.rangeVersion <= readVersion;
return ok; }
}
};
} // namespace } // namespace
bool checkRangeRead(Node *n, std::span<const uint8_t> begin, bool checkRangeRead(Node *n, std::span<const uint8_t> begin,
@@ -2760,21 +2747,17 @@ bool checkRangeRead(Node *n, std::span<const uint8_t> begin,
lcp -= consumed; lcp -= consumed;
if (lcp == int(begin.size())) { if (lcp == int(begin.size())) {
CheckRangeRightSide checkRangeRightSide{}; return checkRangeRightSide(n, end, lcp, readVersion, tls);
return checkRangeRightSide.step(n, end, lcp, readVersion, tls);
}
if (!checkRangeStartsWith(n, begin.subspan(0, lcp), begin[lcp], end[lcp],
readVersion, tls)) {
return false;
} }
// This makes it safe to check maxVersion within CheckRangeLeftSide. If this // This makes it safe to check maxVersion within CheckRangeLeftSide. If this
// were false, then we would have returned above since lcp == begin.size(). // were false, then we would have returned above since lcp == begin.size().
assert(!(n->parent == nullptr && begin.size() == 0)); assert(!(n->parent == nullptr && begin.size() == 0));
CheckRangeRightSide checkRangeRightSide{};
return checkRangeLeftSide(n, begin, lcp + 1, readVersion, tls) && return checkRangeStartsWith(n, begin.subspan(0, lcp), begin[lcp], end[lcp],
checkRangeRightSide.step(n, end, lcp + 1, readVersion, tls); readVersion, tls) &&
checkRangeLeftSide(n, begin, lcp + 1, readVersion, tls) &&
checkRangeRightSide(n, end, lcp + 1, readVersion, tls);
} }
#ifdef __x86_64__ #ifdef __x86_64__