Skip to content

Commit 293c717

Browse files
committed
node, core/rawdb: fix ancients, era resolve
1 parent 35b0db2 commit 293c717

File tree

3 files changed

+6
-12
lines changed

3 files changed

+6
-12
lines changed

core/rawdb/chain_freezer.go

Lines changed: 4 additions & 7 deletions
Original file line numberDiff line numberDiff line change
@@ -60,7 +60,7 @@ type chainFreezer struct {
6060
// state freezer (e.g. dev mode).
6161
// - if non-empty directory is given, initializes the regular file-based
6262
// state freezer.
63-
func newChainFreezer(datadir string, namespace string, readonly bool, eraDir string) (*chainFreezer, error) {
63+
func newChainFreezer(datadir string, eraDir string, namespace string, readonly bool) (*chainFreezer, error) {
6464
if datadir == "" {
6565
return &chainFreezer{
6666
ancients: NewMemoryFreezer(readonly, chainFreezerTableConfigs),
@@ -72,12 +72,9 @@ func newChainFreezer(datadir string, namespace string, readonly bool, eraDir str
7272
if err != nil {
7373
return nil, err
7474
}
75-
var edb *eradb.Store
76-
if eraDir != "" {
77-
edb, err = eradb.New(eraDir)
78-
if err != nil {
79-
return nil, err
80-
}
75+
edb, err := eradb.New(resolveChainEraDir(datadir, eraDir))
76+
if err != nil {
77+
return nil, err
8178
}
8279
return &chainFreezer{
8380
ancients: freezer,

core/rawdb/database.go

Lines changed: 1 addition & 5 deletions
Original file line numberDiff line numberDiff line change
@@ -223,11 +223,7 @@ func Open(db ethdb.KeyValueStore, opts OpenOptions) (ethdb.Database, error) {
223223
if chainFreezerDir != "" {
224224
chainFreezerDir = resolveChainFreezerDir(chainFreezerDir)
225225
}
226-
var eraDir string
227-
if chainFreezerDir != "" {
228-
eraDir = resolveChainEraDir(chainFreezerDir, opts.Era)
229-
}
230-
frdb, err := newChainFreezer(chainFreezerDir, opts.MetricsNamespace, opts.ReadOnly, eraDir)
226+
frdb, err := newChainFreezer(chainFreezerDir, opts.Era, opts.MetricsNamespace, opts.ReadOnly)
231227
if err != nil {
232228
printChainMetadata(db)
233229
return nil, err

node/node.go

Lines changed: 1 addition & 0 deletions
Original file line numberDiff line numberDiff line change
@@ -713,6 +713,7 @@ func (n *Node) OpenDatabaseWithOptions(name string, opt DatabaseOptions) (ethdb.
713713
ReadOnly: opt.ReadOnly,
714714
})
715715
} else {
716+
opt.AncientsDirectory = n.ResolveAncient(name, opt.AncientsDirectory)
716717
db, err = openDatabase(internalOpenOptions{
717718
directory: n.ResolvePath(name),
718719
dbEngine: n.config.DBEngine,

0 commit comments

Comments
 (0)