Converting CheckRangeRightSide WIP

This commit is contained in:
2024-09-04 12:19:53 -07:00
parent c4c4531bd3
commit b9503f8258

View File

@@ -2627,72 +2627,73 @@ struct CheckRangeRightSide {
assert(searchPathLen <= int(key.size())); assert(searchPathLen <= int(key.size()));
if (remaining.size() == 0) { for (;; ++tls->range_read_iterations_accum) {
return downLeftSpine(); if (remaining.size() == 0) {
} goto downLeftSpine;
if (searchPathLen >= prefixLen) {
if (n->entryPresent && n->entry.pointVersion > readVersion) {
ok = false;
return true;
} }
if (!checkMaxBetweenExclusive(n, -1, remaining[0], readVersion, tls)) { if (searchPathLen >= prefixLen) {
ok = false; if (n->entryPresent && n->entry.pointVersion > readVersion) {
return true; ok = false;
} return true;
} }
if (searchPathLen > prefixLen && n->entryPresent && if (!checkMaxBetweenExclusive(n, -1, remaining[0], readVersion, tls)) {
n->entry.rangeVersion > readVersion) { ok = false;
ok = false; return true;
return true;
}
auto *child = getChild(n, remaining[0]);
if (child == nullptr) {
auto c = getChildGeq(n, remaining[0]);
if (c != nullptr) {
n = c;
return downLeftSpine();
} else {
return backtrack();
}
}
n = child;
remaining = remaining.subspan(1, remaining.size() - 1);
++searchPathLen;
if (n->partialKeyLen > 0) {
int commonLen = std::min<int>(n->partialKeyLen, remaining.size());
int i = longestCommonPrefix(n->partialKey(), remaining.data(), commonLen);
searchPathLen += i;
if (i < commonLen) {
++searchPathLen;
auto c = n->partialKey()[i] <=> remaining[i];
if (c > 0) {
return downLeftSpine();
} else {
if (searchPathLen > prefixLen && n->entryPresent &&
n->entry.rangeVersion > readVersion) {
ok = false;
return true;
}
return backtrack();
} }
} }
if (commonLen == n->partialKeyLen) {
// partial key matches if (searchPathLen > prefixLen && n->entryPresent &&
remaining = remaining.subspan(commonLen, remaining.size() - commonLen); n->entry.rangeVersion > readVersion) {
} else if (n->partialKeyLen > int(remaining.size())) { ok = false;
return downLeftSpine(); return true;
}
auto *child = getChild(n, remaining[0]);
if (child == nullptr) {
auto c = getChildGeq(n, remaining[0]);
if (c != nullptr) {
n = c;
goto downLeftSpine;
} else {
goto backtrack;
}
}
n = child;
remaining = remaining.subspan(1, remaining.size() - 1);
++searchPathLen;
if (n->partialKeyLen > 0) {
int commonLen = std::min<int>(n->partialKeyLen, remaining.size());
int i =
longestCommonPrefix(n->partialKey(), remaining.data(), commonLen);
searchPathLen += i;
if (i < commonLen) {
++searchPathLen;
auto c = n->partialKey()[i] <=> remaining[i];
if (c > 0) {
goto downLeftSpine;
} else {
if (searchPathLen > prefixLen && n->entryPresent &&
n->entry.rangeVersion > readVersion) {
ok = false;
return true;
}
goto backtrack;
}
}
if (commonLen == n->partialKeyLen) {
// partial key matches
remaining =
remaining.subspan(commonLen, remaining.size() - commonLen);
} else if (n->partialKeyLen > int(remaining.size())) {
goto downLeftSpine;
}
} }
} }
return false; backtrack:
}
bool 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) {
@@ -2711,12 +2712,10 @@ struct CheckRangeRightSide {
searchPathLen -= n->partialKeyLen; searchPathLen -= n->partialKeyLen;
n = next; n = next;
searchPathLen += n->partialKeyLen; searchPathLen += n->partialKeyLen;
return downLeftSpine(); goto downLeftSpine;
} }
} }
} downLeftSpine:
bool downLeftSpine() {
for (; !n->entryPresent; n = getFirstChildExists(n)) { for (; !n->entryPresent; n = getFirstChildExists(n)) {
} }
ok = n->entry.rangeVersion <= readVersion; ok = n->entry.rangeVersion <= readVersion;
@@ -2786,7 +2785,7 @@ bool checkRangeRead(Node *n, std::span<const uint8_t> begin,
if (lcp == int(begin.size())) { if (lcp == int(begin.size())) {
CheckRangeRightSide checkRangeRightSide{n, end, lcp, readVersion, tls}; CheckRangeRightSide checkRangeRightSide{n, end, lcp, readVersion, tls};
for (; !checkRangeRightSide.step(); ++tls->range_read_iterations_accum) for (; !checkRangeRightSide.step();)
; ;
return checkRangeRightSide.ok; return checkRangeRightSide.ok;
} }
@@ -2801,7 +2800,7 @@ bool checkRangeRead(Node *n, std::span<const uint8_t> begin,
assert(!(n->parent == nullptr && begin.size() == 0)); assert(!(n->parent == nullptr && begin.size() == 0));
bool lhsOk = checkRangeLeftSide(n, begin, lcp + 1, readVersion, tls); bool lhsOk = checkRangeLeftSide(n, begin, lcp + 1, readVersion, tls);
CheckRangeRightSide checkRangeRightSide{n, end, lcp + 1, readVersion, tls}; CheckRangeRightSide checkRangeRightSide{n, end, lcp + 1, readVersion, tls};
for (; !checkRangeRightSide.step(); ++tls->range_read_iterations_accum) for (; !checkRangeRightSide.step();)
; ;
return lhsOk && checkRangeRightSide.ok; return lhsOk && checkRangeRightSide.ok;