fix delete as well

microsoft · Mar 7, 2025 · 46c83d5 · 46c83d5
1 parent ff13e89
commit 46c83d5
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/libs/storage/Tsavorite/cs/src/core/Index/Tsavorite/Implementation/InternalDelete.cs b/libs/storage/Tsavorite/cs/src/core/Index/Tsavorite/Implementation/InternalDelete.cs
@@ -91,6 +91,8 @@ internal OperationStatus InternalDelete<TInput, TOutput, TContext, TSessionFunct
                         case LatchDestination.Retry:
                             goto LatchRelease;
                         case LatchDestination.CreateNewRecord:
+                            if (stackCtx.recSrc.HasMainLogSrc)
+                                srcRecordInfo = ref stackCtx.recSrc.GetInfo();
                             goto CreateNewRecord;
                         default:
                             Debug.Assert(latchDestination == LatchDestination.NormalProcessing, "Unknown latchDestination value; expected NormalProcessing");
@@ -176,7 +178,7 @@ internal OperationStatus InternalDelete<TInput, TOutput, TContext, TSessionFunct
                     // Could not delete in place for some reason - create new record.
                     goto CreateNewRecord;
                 }
-                else if (stackCtx.recSrc.LogicalAddress >= hlogBase.HeadAddress)
+                else if (stackCtx.recSrc.HasMainLogSrc)
                 {
                     // If we already have a deleted record, there's nothing to do.
                     srcRecordInfo = ref stackCtx.recSrc.GetInfo();