fix snapshot reading to handle absent records;

for project-tsurugi/tsurugi-issues#849
project-tsurugi · Aug 9, 2024 · 15f1b2c · 15f1b2c
1 parent e1a9fd6
commit 15f1b2c
Show file tree

Hide file tree

Showing 2 changed files with 4 additions and 1 deletion.
diff --git a/src/concurrency_control/interface/long_tx/search.cpp b/src/concurrency_control/interface/long_tx/search.cpp
@@ -90,7 +90,7 @@ extern Status version_traverse_and_read(session* const ti,
     if (read_epoch > ti->get_read_version_max_epoch()) {
         set_read_version_max_epoch_if_need(ti, read_epoch);
     }
-    return Status::OK;
+    return ver->get_tid().get_absent() ? Status::WARN_NOT_FOUND : Status::OK;
 }
 
 static void create_read_set_for_read_info(session* const ti,

diff --git a/src/concurrency_control/interface/scan/open_scan.cpp b/src/concurrency_control/interface/scan/open_scan.cpp
@@ -99,6 +99,7 @@ Status check_not_found(
                     ver = ver->get_next();
                     if (ver == nullptr) { break; }
                     if (ver->get_tid().get_epoch() < ti->get_valid_epoch()) {
+                        if (ver->get_tid().get_absent()) { break; }
                         return Status::OK;
                     }
                 }
@@ -132,6 +133,7 @@ Status check_not_found(
                 ver = ver->get_next();
                 if (ver == nullptr) { break; }
                 if (ver->get_tid().get_epoch() < ti->get_valid_epoch()) {
+                    if (ver->get_tid().get_absent()) { break; }
                     return Status::OK;
                 }
             }
@@ -156,6 +158,7 @@ Status check_not_found(
                         if (ver == nullptr) { break; }
                         if (ver->get_tid().get_epoch() <
                             ti->get_valid_epoch()) {
+                            if (ver->get_tid().get_absent()) { break; }
                             return Status::OK;
                         }
                     }