diff --git a/trie/database.go b/trie/database.go index 913770327e..c14ecb3852 100644 --- a/trie/database.go +++ b/trie/database.go @@ -677,8 +677,9 @@ func (db *Database) Commit(node common.Hash, report bool) error { // Uncache any leftovers in the last batch db.lock.Lock() defer db.lock.Unlock() - - batch.Replay(uncacher) + if err := batch.Replay(uncacher); err != nil { + return err + } batch.Reset() // Reset the storage counters and bumped metrics @@ -723,9 +724,12 @@ func (db *Database) commit(hash common.Hash, batch ethdb.Batch, uncacher *cleane return err } db.lock.Lock() - batch.Replay(uncacher) + err := batch.Replay(uncacher) batch.Reset() db.lock.Unlock() + if err != nil { + return err + } } return nil }