More log on sync pointers

NethermindEth · Dec 11, 2024 · 744691b · 744691b
1 parent 6569082
commit 744691b
Show file tree

Hide file tree

Showing 2 changed files with 8 additions and 4 deletions.
diff --git a/src/Nethermind/Nethermind.Synchronization.Test/SyncPointersTests.cs b/src/Nethermind/Nethermind.Synchronization.Test/SyncPointersTests.cs
@@ -5,6 +5,7 @@
 using Nethermind.Blockchain.Receipts;
 using Nethermind.Core.Test;
 using Nethermind.Db;
+using Nethermind.Logging;
 using NUnit.Framework;
 
 namespace Nethermind.Synchronization.Test;
@@ -17,7 +18,7 @@ public void WhenReceiptNotStore_SetLowestInsertedReceiptTo0()
         SyncPointers pointers = new SyncPointers(new TestMemDb(), new TestMemColumnsDb<ReceiptsColumns>(), new ReceiptConfig()
         {
             StoreReceipts = false
-        });
+        }, LimboLogs.Instance);
 
         pointers.LowestInsertedReceiptBlockNumber.Should().Be(0);
     }

diff --git a/src/Nethermind/Nethermind.Synchronization/SyncPointers.cs b/src/Nethermind/Nethermind.Synchronization/SyncPointers.cs
@@ -7,6 +7,7 @@
 using Nethermind.Core.Crypto;
 using Nethermind.Core.Extensions;
 using Nethermind.Db;
+using Nethermind.Logging;
 using Nethermind.Serialization.Rlp;
 
 namespace Nethermind.Synchronization;
@@ -46,15 +47,17 @@ public long? LowestInsertedReceiptBlockNumber
     }
 
 
-    public SyncPointers([KeyFilter(DbNames.Blocks)] IDb blocksDb, IColumnsDb<ReceiptsColumns> receiptsDb, IReceiptConfig receiptConfig)
+    public SyncPointers([KeyFilter(DbNames.Blocks)] IDb blocksDb, IColumnsDb<ReceiptsColumns> receiptsDb, IReceiptConfig receiptConfig, ILogManager logManager)
     {
         _blocksDb = blocksDb;
         _defaultReceiptDbColumn = receiptsDb.GetColumnDb(ReceiptsColumns.Default);
 
+        ILogger logger = logManager.GetClassLogger<SyncPointers>();
         LowestInsertedBodyNumber = _blocksDb[LowestInsertedBodyNumberDbEntryAddress]?.AsRlpValueContext().DecodeLong();
+        if (logger.IsDebug) logger.Debug($"Lowest inserted body number loaded to {LowestInsertedBodyNumber?.ToString() ?? "null"}");
 
-        byte[] lowestBytes = _defaultReceiptDbColumn.Get(Keccak.Zero);
-        _lowestInsertedReceiptBlock = lowestBytes is null ? (long?)null : new RlpStream(lowestBytes).DecodeLong();
+        LowestInsertedReceiptBlockNumber = _defaultReceiptDbColumn[Keccak.Zero.Bytes]?.AsRlpValueContext().DecodeLong();
+        if (logger.IsDebug) logger.Debug($"Lowest inserted receipt number loaded to {LowestInsertedReceiptBlockNumber?.ToString() ?? "null"}");
 
         // When not storing receipt, set the lowest inserted receipt to 0 so that old receipt will finish immediately
         if (!receiptConfig.StoreReceipts)