Wait index checkpoint phase should behave similarly to wait flush - p…

…erform create-new-record during a checkpoint if record is not in the new version (during the snapshot). (#724)
microsoft · Jul 18, 2022 · 65e379f · 65e379f
1 parent 61b7ec8
commit 65e379f
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/cs/src/core/Index/FASTER/FASTERImpl.cs b/cs/src/core/Index/FASTER/FASTERImpl.cs
@@ -688,6 +688,7 @@ private LatchDestination AcquireLatchUpsert<Input, Output, Context>(FasterExecut
                         }
                         break; // Normal Processing
                     }
+                case Phase.WAIT_INDEX_CHECKPOINT:
                 case Phase.WAIT_FLUSH:
                     {
                         if (!CheckEntryVersionNew(logicalAddress))
@@ -1233,6 +1234,7 @@ private LatchDestination AcquireLatchRMW<Input, Output, Context>(PendingContext<
                         }
                         break; // Normal Processing
                     }
+                case Phase.WAIT_INDEX_CHECKPOINT:
                 case Phase.WAIT_FLUSH:
                     {
                         if (!CheckEntryVersionNew(logicalAddress))
@@ -1638,6 +1640,7 @@ internal OperationStatus InternalDelete<Input, Output, Context, FasterSession>(
                             }
                             break; // Normal Processing
                         }
+                    case Phase.WAIT_INDEX_CHECKPOINT:
                     case Phase.WAIT_FLUSH:
                         {
                             if (!CheckEntryVersionNew(logicalAddress))