From 33dc3a0ad6ab5b9059b72606b76ba3a36d6bd1c4 Mon Sep 17 00:00:00 2001 From: Kyrin Date: Thu, 16 Oct 2025 16:00:21 +0800 Subject: [PATCH] Initialize journal writer after loading transactions --- core/txpool/locals/tx_tracker.go | 8 ++++---- 1 file changed, 4 insertions(+), 4 deletions(-) diff --git a/core/txpool/locals/tx_tracker.go b/core/txpool/locals/tx_tracker.go index 8ea7d4d157..72e3688ba3 100644 --- a/core/txpool/locals/tx_tracker.go +++ b/core/txpool/locals/tx_tracker.go @@ -181,14 +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.setWriter(); err != nil { + log.Warn("Failed to initialize journal writer", "err", err) + } defer tracker.journal.close() } var (