From 24338b8817b4679e5e0ad5778b6667242c1853a3 Mon Sep 17 00:00:00 2001 From: Kyrin Date: Thu, 16 Oct 2025 15:02:43 +0800 Subject: [PATCH] Refactor journal writer initialization in TxTracker --- core/txpool/locals/tx_tracker.go | 10 ++++------ 1 file changed, 4 insertions(+), 6 deletions(-) diff --git a/core/txpool/locals/tx_tracker.go b/core/txpool/locals/tx_tracker.go index 92148195f0..8ea7d4d157 100644 --- a/core/txpool/locals/tx_tracker.go +++ b/core/txpool/locals/tx_tracker.go @@ -181,16 +181,14 @@ func (tracker *TxTracker) loop() { defer tracker.wg.Done() if tracker.journal != nil { + log.Info("Initializing journal writer") + if err := tracker.journal.rotate(make(map[common.Address]types.Transactions)); err != nil { + log.Warn("Failed to initialize journal writer", "err", err) + } tracker.journal.load(func(transactions []*types.Transaction) []error { tracker.TrackAll(transactions) return nil }) - - log.Info("Initializing journal writer after loading transactions") - if err := tracker.journal.rotate(make(map[common.Address]types.Transactions)); err != nil { - log.Warn("Failed to initialize journal writer", "err", err) - } - defer tracker.journal.close() } var (