Fix CommitRecord physicalAddress offset (#285)

Co-authored-by: Tal Zaccai <talzacc@microsoft.com>
microsoft · Apr 18, 2024 · 23e13f0 · 23e13f0
1 parent 8f86b49
commit 23e13f0
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/libs/storage/Tsavorite/cs/src/core/TsavoriteLog/TsavoriteLogIterator.cs b/libs/storage/Tsavorite/cs/src/core/TsavoriteLog/TsavoriteLogIterator.cs
@@ -378,7 +378,7 @@ public unsafe bool GetNext(MemoryPool<byte> pool, out IMemoryOwner<byte> entry,
                 if (isCommitRecord)
                 {
                     TsavoriteLogRecoveryInfo info = new();
-                    info.Initialize(new ReadOnlySpan<byte>((byte*)physicalAddress, entryLength));
+                    info.Initialize(new ReadOnlySpan<byte>((byte*)(headerSize + physicalAddress), entryLength));
                     if (info.CommitNum != long.MaxValue) continue;
 
                     // Otherwise, no more entries
@@ -441,7 +441,7 @@ public unsafe bool GetNext(MemoryPool<byte> pool, out IMemoryOwner<byte> entry,
                 if (isCommitRecord)
                 {
                     TsavoriteLogRecoveryInfo info = new();
-                    info.Initialize(new ReadOnlySpan<byte>((byte*)physicalAddress, entryLength));
+                    info.Initialize(new ReadOnlySpan<byte>((byte*)(headerSize + physicalAddress), entryLength));
                     if (info.CommitNum != long.MaxValue) continue;
 
                     // Otherwise, no more entries