[C#] Fix commit record pointer offset calculation (#912)

Co-authored-by: Alexander Solodov <asolodov@b2broker.com>
microsoft · Apr 16, 2024 · dc4bc1d · dc4bc1d
1 parent 281bdff
commit dc4bc1d
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/cs/src/core/FasterLog/FasterLogIterator.cs b/cs/src/core/FasterLog/FasterLogIterator.cs
@@ -379,7 +379,7 @@ public unsafe bool GetNext(MemoryPool<byte> pool, out IMemoryOwner<byte> entry,
                 if (isCommitRecord)
                 {
                     FasterLogRecoveryInfo info = new();
-                    info.Initialize(new BinaryReader(new UnmanagedMemoryStream((byte *)physicalAddress, entryLength)));
+                    info.Initialize(new BinaryReader(new UnmanagedMemoryStream((byte*) (headerSize + physicalAddress), entryLength)));
                     if (info.CommitNum != long.MaxValue) continue;
 
                     // Otherwise, no more entries
@@ -442,7 +442,7 @@ public unsafe bool TryConsumeNext<T>(T consumer) where T : ILogEntryConsumer
                 if (isCommitRecord)
                 {
                     FasterLogRecoveryInfo info = new();
-                    info.Initialize(new BinaryReader(new UnmanagedMemoryStream((byte *)physicalAddress, entryLength)));
+                    info.Initialize(new BinaryReader(new UnmanagedMemoryStream((byte*) (headerSize + physicalAddress), entryLength)));
                     if (info.CommitNum != long.MaxValue) continue;
 
                     // Otherwise, no more entries