Skip to content

Commit 556cfef

Browse files
committed
core/rawdb: replace method with Open
1 parent 651b0f8 commit 556cfef

File tree

4 files changed

+36
-27
lines changed

4 files changed

+36
-27
lines changed

core/blockchain_repair_test.go

Lines changed: 18 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -1756,7 +1756,10 @@ func testRepair(t *testing.T, tt *rewindTest, snapshots bool) {
17561756
// Create a temporary persistent database
17571757
datadir := t.TempDir()
17581758

1759-
db, err := rawdb.NewLevelDBDatabaseWithFreezer(datadir, 0, 0, datadir, "", false)
1759+
db, err := rawdb.Open(rawdb.OpenOptions{
1760+
Directory: datadir,
1761+
AncientsDirectory: datadir,
1762+
})
17601763
if err != nil {
17611764
t.Fatalf("Failed to create persistent database: %v", err)
17621765
}
@@ -1829,7 +1832,11 @@ func testRepair(t *testing.T, tt *rewindTest, snapshots bool) {
18291832
chain.stopWithoutSaving()
18301833

18311834
// Start a new blockchain back up and see where the repair leads us
1832-
db, err = rawdb.NewLevelDBDatabaseWithFreezer(datadir, 0, 0, datadir, "", false)
1835+
db, err = rawdb.Open(rawdb.OpenOptions{
1836+
Directory: datadir,
1837+
AncientsDirectory: datadir,
1838+
})
1839+
18331840
if err != nil {
18341841
t.Fatalf("Failed to reopen persistent database: %v", err)
18351842
}
@@ -1884,7 +1891,11 @@ func TestIssue23496(t *testing.T) {
18841891
// Create a temporary persistent database
18851892
datadir := t.TempDir()
18861893

1887-
db, err := rawdb.NewLevelDBDatabaseWithFreezer(datadir, 0, 0, datadir, "", false)
1894+
db, err := rawdb.Open(rawdb.OpenOptions{
1895+
Directory: datadir,
1896+
AncientsDirectory: datadir,
1897+
})
1898+
18881899
if err != nil {
18891900
t.Fatalf("Failed to create persistent database: %v", err)
18901901
}
@@ -1944,7 +1955,10 @@ func TestIssue23496(t *testing.T) {
19441955
chain.stopWithoutSaving()
19451956

19461957
// Start a new blockchain back up and see where the repair leads us
1947-
db, err = rawdb.NewLevelDBDatabaseWithFreezer(datadir, 0, 0, datadir, "", false)
1958+
db, err = rawdb.Open(rawdb.OpenOptions{
1959+
Directory: datadir,
1960+
AncientsDirectory: datadir,
1961+
})
19481962
if err != nil {
19491963
t.Fatalf("Failed to reopen persistent database: %v", err)
19501964
}

core/blockchain_sethead_test.go

Lines changed: 4 additions & 1 deletion
Original file line numberDiff line numberDiff line change
@@ -1956,7 +1956,10 @@ func testSetHead(t *testing.T, tt *rewindTest, snapshots bool) {
19561956
// Create a temporary persistent database
19571957
datadir := t.TempDir()
19581958

1959-
db, err := rawdb.NewLevelDBDatabaseWithFreezer(datadir, 0, 0, datadir, "", false)
1959+
db, err := rawdb.Open(rawdb.OpenOptions{
1960+
Directory: datadir,
1961+
AncientsDirectory: datadir,
1962+
})
19601963
if err != nil {
19611964
t.Fatalf("Failed to create persistent database: %v", err)
19621965
}

core/blockchain_snapshot_test.go

Lines changed: 9 additions & 2 deletions
Original file line numberDiff line numberDiff line change
@@ -61,7 +61,10 @@ func (basic *snapshotTestBasic) prepare(t *testing.T) (*BlockChain, []*types.Blo
6161
// Create a temporary persistent database
6262
datadir := t.TempDir()
6363

64-
db, err := rawdb.NewLevelDBDatabaseWithFreezer(datadir, 0, 0, datadir, "", false)
64+
db, err := rawdb.Open(rawdb.OpenOptions{
65+
Directory: datadir,
66+
AncientsDirectory: datadir,
67+
})
6568
if err != nil {
6669
t.Fatalf("Failed to create persistent database: %v", err)
6770
}
@@ -250,7 +253,11 @@ func (snaptest *crashSnapshotTest) test(t *testing.T) {
250253
chain.stopWithoutSaving()
251254

252255
// Start a new blockchain back up and see where the repair leads us
253-
newdb, err := rawdb.NewLevelDBDatabaseWithFreezer(snaptest.datadir, 0, 0, snaptest.datadir, "", false)
256+
newdb, err := rawdb.Open(rawdb.OpenOptions{
257+
Directory: snaptest.datadir,
258+
AncientsDirectory: snaptest.datadir,
259+
})
260+
254261
if err != nil {
255262
t.Fatalf("Failed to reopen persistent database: %v", err)
256263
}

core/rawdb/database.go

Lines changed: 5 additions & 20 deletions
Original file line numberDiff line numberDiff line change
@@ -328,12 +328,14 @@ func hasPreexistingDb(path string) string {
328328
return dbLeveldb
329329
}
330330

331+
// OpenOptions contains the options to apply when opening a database.
332+
// OBS: If AncientsDirectory is empty, it indicates that no freezer is to be used.
331333
type OpenOptions struct {
332334
Type string // "leveldb" | "pebble"
333-
Directory string
334-
AncientsDirectory string
335+
Directory string // the datadir
336+
AncientsDirectory string // the ancients-dir
335337
Namespace string
336-
Cache int
338+
Cache int // Cache size in MiB
337339
Handles int
338340
ReadOnly bool
339341
}
@@ -379,23 +381,6 @@ func Open(o OpenOptions) (ethdb.Database, error) {
379381
return frdb, nil
380382
}
381383

382-
// NewLevelDBDatabaseWithFreezer creates a persistent key-value database with a
383-
// freezer moving immutable chain segments into cold storage. The passed ancient
384-
// indicates the path of root ancient directory where the chain freezer can be
385-
// opened.
386-
// @deprecated: use Open instead
387-
func NewLevelDBDatabaseWithFreezer(file string, cache int, handles int, ancient string, namespace string, readonly bool) (ethdb.Database, error) {
388-
return Open(OpenOptions{
389-
Type: "leveldb",
390-
Directory: file,
391-
AncientsDirectory: ancient,
392-
Namespace: namespace,
393-
Cache: cache,
394-
Handles: handles,
395-
ReadOnly: readonly,
396-
})
397-
}
398-
399384
type counter uint64
400385

401386
func (c counter) String() string {

0 commit comments

Comments
 (0)