mirror/go-pulse
1
0
Fork 0
mirror of https://gitlab.com/pulsechaincom/go-pulse.git synced 2024-12-24 12:27:17 +00:00
Code Issues Actions Packages Projects Releases Wiki Activity

cmd/geth: don't flush databases after import

Browse Source
This commit is contained in:
Felix Lange 2015-05-28 01:20:03 +02:00
parent e1fe75e3b6
commit e84bbcce3c
1 changed files with 4 additions and 5 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
cmd/geth/chaincmd.go
View File

@ -55,7 +55,7 @@ func importChain(ctx *cli.Context) {
chain, blockDB, stateDB, extraDB := utils.MakeChain(ctx) chain, blockDB, stateDB, extraDB := utils.MakeChain(ctx)
start := time.Now() start := time.Now()
err := utils.ImportChain(chain, ctx.Args().First()) err := utils.ImportChain(chain, ctx.Args().First())
flushAll(blockDB, stateDB, extraDB) closeAll(blockDB, stateDB, extraDB)
if err != nil { if err != nil {
utils.Fatalf("Import error: %v", err) utils.Fatalf("Import error: %v", err)
} }
@ -109,7 +109,7 @@ func upgradeDB(ctx *cli.Context) {
if err := utils.ExportChain(chain, exportFile); err != nil { if err := utils.ExportChain(chain, exportFile); err != nil {
utils.Fatalf("Unable to export chain for reimport %s", err) utils.Fatalf("Unable to export chain for reimport %s", err)
} }
flushAll(blockDB, stateDB, extraDB) closeAll(blockDB, stateDB, extraDB)
os.RemoveAll(filepath.Join(ctx.GlobalString(utils.DataDirFlag.Name), "blockchain")) os.RemoveAll(filepath.Join(ctx.GlobalString(utils.DataDirFlag.Name), "blockchain"))
os.RemoveAll(filepath.Join(ctx.GlobalString(utils.DataDirFlag.Name), "state")) os.RemoveAll(filepath.Join(ctx.GlobalString(utils.DataDirFlag.Name), "state"))
@ -117,7 +117,7 @@ func upgradeDB(ctx *cli.Context) {
chain, blockDB, stateDB, extraDB = utils.MakeChain(ctx) chain, blockDB, stateDB, extraDB = utils.MakeChain(ctx)
blockDB.Put([]byte("BlockchainVersion"), common.NewValue(core.BlockChainVersion).Bytes()) blockDB.Put([]byte("BlockchainVersion"), common.NewValue(core.BlockChainVersion).Bytes())
err := utils.ImportChain(chain, exportFile) err := utils.ImportChain(chain, exportFile)
flushAll(blockDB, stateDB, extraDB) closeAll(blockDB, stateDB, extraDB)
if err != nil { if err != nil {
utils.Fatalf("Import error %v (a backup is made in %s, use the import command to import it)", err, exportFile) utils.Fatalf("Import error %v (a backup is made in %s, use the import command to import it)", err, exportFile)
} else { } else {
@ -152,9 +152,8 @@ func hashish(x string) bool {
return err != nil return err != nil
} }
func flushAll(dbs ...common.Database) { func closeAll(dbs ...common.Database) {
for _, db := range dbs { for _, db := range dbs {
db.Flush()
db.Close() db.Close()
} }
} }