forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-24 21:56:43 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

repair the ancient in read-write mode

Browse source
This commit is contained in:
N 2025-08-15 01:57:13 +08:00
parent 2dbb580f51
commit e2243e47e4
1 changed files with 40 additions and 5 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

43
cmd/utils/flags.go
View file

@ -2075,6 +2075,15 @@ func SplitTagsFlag(tagsFlag string) map[string]string {
// MakeChainDatabase opens a database using the flags passed to the client and will hard crash if it fails.
func MakeChainDatabase(ctx *cli.Context, stack *node.Node, readonly bool) ethdb.Database {
chainDb, err := tryMakeChainDatabase(ctx, stack, readonly)
if err != nil {
Fatalf("Could not open database: %v", err)
}
return chainDb
}
// tryMakeChainDatabase tries to open the chain database with the given context and stack.
func tryMakeChainDatabase(ctx *cli.Context, stack *node.Node, readonly bool) (ethdb.Database, error) {
var (
cache = ctx.Int(CacheFlag.Name) * ctx.Int(CacheDatabaseFlag.Name) / 100
handles = MakeDatabaseHandles(ctx.Int(FDLimitFlag.Name))
@ -2086,7 +2095,7 @@ func MakeChainDatabase(ctx *cli.Context, stack *node.Node, readonly bool) ethdb.
log.Info("Using remote db", "url", ctx.String(RemoteDBFlag.Name), "headers", len(ctx.StringSlice(HttpHeaderFlag.Name)))
client, err := DialRPCWithHeaders(ctx.String(RemoteDBFlag.Name), ctx.StringSlice(HttpHeaderFlag.Name))
if err != nil {
break
return nil, err
}
chainDb = remotedb.New(client)
default:
@ -2099,11 +2108,11 @@ func MakeChainDatabase(ctx *cli.Context, stack *node.Node, readonly bool) ethdb.
EraDirectory: ctx.String(EraFlag.Name),
}
chainDb, err = stack.OpenDatabaseWithOptions("chaindata", options)
}
if err != nil {
Fatalf("Could not open database: %v", err)
return nil, err
}
return chainDb
}
return chainDb, nil
}
// tryMakeReadOnlyDatabase try to open the chain database in read-only mode,
@ -2115,6 +2124,32 @@ func tryMakeReadOnlyDatabase(ctx *cli.Context, stack *node.Node) ethdb.Database
if rawdb.PreexistingDatabase(stack.ResolvePath("chaindata")) == "" {
readonly = false
}
// First attempt to open in readonly mode
if readonly {
chainDb, err := tryMakeChainDatabase(ctx, stack, true)
if err == nil {
return chainDb
}
// If opening in readonly mode failed (possibly due to corruption),
// try opening in read-write mode to allow repair, then close and reopen readonly
log.Warn("Failed to open database in readonly mode, attempting repair...", "err", err)
repairDb, repairErr := tryMakeChainDatabase(ctx, stack, false)
if repairErr != nil {
// If repair also failed, fallback to the original error
Fatalf("Could not open database even after repair attempt: readonly error: %v, repair error: %v", err, repairErr)
}
repairDb.Close()
log.Info("Database repair completed, reopening in readonly mode")
chainDb, err = tryMakeChainDatabase(ctx, stack, true)
if err == nil {
return chainDb
}
Fatalf("Could not reopen database in readonly mode after repair: %v", err)
}
return MakeChainDatabase(ctx, stack, readonly)
}