forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-15 17:30:44 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Ensure DB is close before client exit (#478)

Browse source
This commit is contained in:
Wanwiset Peerapatanapokin 2024-03-08 14:57:15 +04:00 committed by GitHub
parent b51f6963be
commit 75c8d40399
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 7 additions and 2 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

9
cmd/XDC/chaincmd.go
View file

@ -319,7 +319,8 @@ func exportChain(ctx *cli.Context) error {
utils.Fatalf("This command requires an argument.") utils.Fatalf("This command requires an argument.")
} }
stack, _ := makeFullNode(ctx) stack, _ := makeFullNode(ctx)
chain, _ := utils.MakeChain(ctx, stack) chain, db := utils.MakeChain(ctx, stack)
defer db.Close()
start := time.Now() start := time.Now()
var err error var err error
@ -353,6 +354,7 @@ func importPreimages(ctx *cli.Context) error {
} }
stack, _ := makeFullNode(ctx) stack, _ := makeFullNode(ctx)
diskdb := utils.MakeChainDatabase(ctx, stack) diskdb := utils.MakeChainDatabase(ctx, stack)
defer diskdb.Close()
start := time.Now() start := time.Now()
if err := utils.ImportPreimages(diskdb, ctx.Args().First()); err != nil { if err := utils.ImportPreimages(diskdb, ctx.Args().First()); err != nil {
@ -369,6 +371,7 @@ func exportPreimages(ctx *cli.Context) error {
} }
stack, _ := makeFullNode(ctx) stack, _ := makeFullNode(ctx)
diskdb := utils.MakeChainDatabase(ctx, stack) diskdb := utils.MakeChainDatabase(ctx, stack)
defer diskdb.Close()
start := time.Now() start := time.Now()
if err := utils.ExportPreimages(diskdb, ctx.Args().First()); err != nil { if err := utils.ExportPreimages(diskdb, ctx.Args().First()); err != nil {
@ -386,6 +389,7 @@ func copyDb(ctx *cli.Context) error {
// Initialize a new chain for the running node to sync into // Initialize a new chain for the running node to sync into
stack, _ := makeFullNode(ctx) stack, _ := makeFullNode(ctx)
chain, chainDb := utils.MakeChain(ctx, stack) chain, chainDb := utils.MakeChain(ctx, stack)
defer chainDb.Close()
syncmode := *utils.GlobalTextMarshaler(ctx, utils.SyncModeFlag.Name).(*downloader.SyncMode) syncmode := *utils.GlobalTextMarshaler(ctx, utils.SyncModeFlag.Name).(*downloader.SyncMode)
dl := downloader.New(syncmode, chainDb, new(event.TypeMux), chain, nil, nil, nil) dl := downloader.New(syncmode, chainDb, new(event.TypeMux), chain, nil, nil, nil)
@ -458,6 +462,8 @@ func removeDB(ctx *cli.Context) error {
func dump(ctx *cli.Context) error { func dump(ctx *cli.Context) error {
stack, _ := makeFullNode(ctx) stack, _ := makeFullNode(ctx)
chain, chainDb := utils.MakeChain(ctx, stack) chain, chainDb := utils.MakeChain(ctx, stack)
defer chainDb.Close()
for _, arg := range ctx.Args() { for _, arg := range ctx.Args() {
var block *types.Block var block *types.Block
if hashish(arg) { if hashish(arg) {
@ -477,7 +483,6 @@ func dump(ctx *cli.Context) error {
fmt.Printf("%s\n", state.Dump()) fmt.Printf("%s\n", state.Dump())
} }
} }
chainDb.Close()
return nil return nil
} }