From 98155b21aa156ad83c57b89b80b76c6b1a7d0005 Mon Sep 17 00:00:00 2001 From: Vicky Date: Wed, 11 Feb 2026 22:15:18 +0800 Subject: [PATCH] ethdb/leveldb: add logging for database corruption recovery --- ethdb/leveldb/leveldb.go | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/ethdb/leveldb/leveldb.go b/ethdb/leveldb/leveldb.go index b6c93907b1..ae0348c102 100644 --- a/ethdb/leveldb/leveldb.go +++ b/ethdb/leveldb/leveldb.go @@ -122,7 +122,12 @@ func NewCustom(file string, namespace string, customize func(options *opt.Option // Open the db and recover any potential corruptions db, err := leveldb.OpenFile(file, options) if _, corrupted := err.(*lerrors.ErrCorrupted); corrupted { + logger.Error("Database corrupted, attempting recovery", "error", err) db, err = leveldb.RecoverFile(file, nil) + if err != nil { + return nil, fmt.Errorf("database recovery failed: %w", err) + } + logger.Warn("Database recovery succeeded") } if err != nil { return nil, err