Initialize journal writer after loading transactions

This commit is contained in:
Kyrin 2025-10-16 16:00:21 +08:00 committed by GitHub
parent 77de963b5b
commit 33dc3a0ad6
No known key found for this signature in database
GPG key ID: B5690EEEBB952194

View file

@ -181,14 +181,14 @@ func (tracker *TxTracker) loop() {
defer tracker.wg.Done() defer tracker.wg.Done()
if tracker.journal != nil { 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.journal.load(func(transactions []*types.Transaction) []error {
tracker.TrackAll(transactions) tracker.TrackAll(transactions)
return nil 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() defer tracker.journal.close()
} }
var ( var (