Fix condition for getting srcRecordInfo (use HasMainLogSrc instead of…

… HeadAddress comparison). (#1071)

* Fix condition for getting srcRecordInfo (use HasMainLogSrc instead of HeadAddress comparison).

* fixes

* fix delete as well

* update version since this fixes a bug.

Version.props

@@ -1,6 +1,6 @@
 <Project>
 	<!-- VersionPrefix property for builds and packages -->
 	<PropertyGroup>
-		<VersionPrefix>1.0.58</VersionPrefix>
+		<VersionPrefix>1.0.59</VersionPrefix>
 	</PropertyGroup>
 </Project>

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();

libs/storage/Tsavorite/cs/src/core/Index/Tsavorite/Implementation/InternalRMW.cs

@@ -92,10 +92,10 @@ internal OperationStatus InternalRMW<TInput, TOutput, TContext, TSessionFunction
                         case LatchDestination.Retry:
                             goto LatchRelease;
                         case LatchDestination.CreateNewRecord:
-                            if (stackCtx.recSrc.LogicalAddress >= hlogBase.HeadAddress)
+                            if (stackCtx.recSrc.HasMainLogSrc)
                                 srcRecordInfo = ref stackCtx.recSrc.GetInfo();
-
                             goto CreateNewRecord;
+
                         default:
                             Debug.Assert(latchDestination == LatchDestination.NormalProcessing, "Unknown latchDestination value; expected NormalProcessing");
                             break;
@@ -163,7 +163,7 @@ internal OperationStatus InternalRMW<TInput, TOutput, TContext, TSessionFunction
                     status = OperationStatus.RETRY_LATER;
                     goto LatchRelease;
                 }
-                if (stackCtx.recSrc.LogicalAddress >= hlogBase.HeadAddress)
+                if (stackCtx.recSrc.HasMainLogSrc)
                 {
                     // Safe Read-Only Region: CopyUpdate to create a record in the mutable region.
                     srcRecordInfo = ref stackCtx.recSrc.GetInfo();
@@ -325,7 +325,7 @@ private LatchDestination CheckCPRConsistencyRMW(Phase phase, ref OperationStackC
                     if (IsRecordVersionNew(stackCtx.recSrc.LogicalAddress))
                         break;      // Normal Processing; V+1 thread encountered a record in V+1
 
-                    if (stackCtx.recSrc.LogicalAddress >= hlogBase.HeadAddress)
+                    if (stackCtx.recSrc.HasMainLogSrc)
                         return LatchDestination.CreateNewRecord;    // Record is in memory so force creation of a (V+1) record
                     break;  // Normal Processing; the record is below HeadAddress so the operation will go pending
 

libs/storage/Tsavorite/cs/src/core/Index/Tsavorite/Implementation/InternalUpsert.cs

@@ -86,10 +86,10 @@ internal OperationStatus InternalUpsert<TInput, TOutput, TContext, TSessionFunct
                         case LatchDestination.Retry:
                             goto LatchRelease;
                         case LatchDestination.CreateNewRecord:
-                            if (stackCtx.recSrc.LogicalAddress >= hlogBase.HeadAddress)
+                            if (stackCtx.recSrc.HasMainLogSrc)
                                 srcRecordInfo = ref stackCtx.recSrc.GetInfo();
-
                             goto CreateNewRecord;
+
                         default:
                             Debug.Assert(latchDestination == LatchDestination.NormalProcessing, "Unknown latchDestination value; expected NormalProcessing");
                             break;
@@ -142,11 +142,10 @@ internal OperationStatus InternalUpsert<TInput, TOutput, TContext, TSessionFunct
                     // ConcurrentWriter failed (e.g. insufficient space, another thread set Tombstone, etc). Write a new record, but track that we have to seal and unlock this one.
                     goto CreateNewRecord;
                 }
-                if (stackCtx.recSrc.LogicalAddress >= hlogBase.HeadAddress)
+                if (stackCtx.recSrc.HasMainLogSrc)
                 {
                     // Safe Read-Only Region: Create a record in the mutable region, but set srcRecordInfo in case we are eliding.
-                    if (stackCtx.recSrc.HasMainLogSrc)
-                        srcRecordInfo = ref stackCtx.recSrc.GetInfo();
+                    srcRecordInfo = ref stackCtx.recSrc.GetInfo();
                     goto CreateNewRecord;
                 }