Revert to the old code.

Signed-off-by: Johannes Kalmbach <[email protected]>
ad-freiburg · Dec 4, 2024 · 6e35c8e · 6e35c8e
1 parent 018e228
commit 6e35c8e
Showing 1 changed file with 3 additions and 3 deletions.
diff --git a/src/engine/IndexScan.cpp b/src/engine/IndexScan.cpp
@@ -594,14 +594,14 @@ Result::Generator IndexScan::createPrefilteredJoinSide(
   }
   auto& prefetchedValues = innerState->prefetchedValues_;
   while (true) {
-    while (prefetchedValues.empty()) {
+    if (prefetchedValues.empty()) {
       if (innerState->doneFetching_) {
         co_return;
       }
       innerState->fetch();
+      AD_CORRECTNESS_CHECK(!prefetchedValues.empty() ||
+                           innerState->doneFetching_);
     }
-    AD_CORRECTNESS_CHECK(!prefetchedValues.empty() ||
-                         innerState->doneFetching_);
     // Make a defensive copy of the values to avoid modification during
     // iteration when yielding.
     auto copy = std::move(prefetchedValues);