libp2p/go-libp2p-peerstore
1
0
Fork 0
mirror of https://github.com/libp2p/go-libp2p-peerstore.git synced 2025-02-05 06:10:09 +08:00
Code Issues Projects Releases Wiki Activity

test: use leveldb instead of badger

Browse Source 
Badger has issues on 32bit operating systems.
This commit is contained in:
Steven Allen 2021-07-16 10:58:29 -07:00
parent 8fdf7888b2
commit 99836f05e7
2 changed files with 10 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
pstoreds/addr_book_gc_test.go
View File

@ -43,7 +43,7 @@ func TestGCLookahead(t *testing.T) {
opts.GCLookaheadInterval = 10 * time.Second opts.GCLookaheadInterval = 10 * time.Second
opts.GCPurgeInterval = 1 * time.Second opts.GCPurgeInterval = 1 * time.Second
factory := addressBookFactory(t, badgerStore, opts) factory := addressBookFactory(t, leveldbStore, opts)
ab, closeFn := factory() ab, closeFn := factory()
gc := ab.(*dsAddrBook).gc gc := ab.(*dsAddrBook).gc
defer closeFn() defer closeFn()
@ -90,7 +90,7 @@ func TestGCPurging(t *testing.T) {
opts.GCLookaheadInterval = 20 * time.Second opts.GCLookaheadInterval = 20 * time.Second
opts.GCPurgeInterval = 1 * time.Second opts.GCPurgeInterval = 1 * time.Second
factory := addressBookFactory(t, badgerStore, opts) factory := addressBookFactory(t, leveldbStore, opts)
ab, closeFn := factory() ab, closeFn := factory()
gc := ab.(*dsAddrBook).gc gc := ab.(*dsAddrBook).gc
defer closeFn() defer closeFn()
@ -157,7 +157,7 @@ func TestGCDelay(t *testing.T) {
opts.GCLookaheadInterval = 1 * time.Minute opts.GCLookaheadInterval = 1 * time.Minute
opts.GCPurgeInterval = 30 * time.Second opts.GCPurgeInterval = 30 * time.Second
factory := addressBookFactory(t, badgerStore, opts) factory := addressBookFactory(t, leveldbStore, opts)
ab, closeFn := factory() ab, closeFn := factory()
defer closeFn() defer closeFn()
@ -188,7 +188,7 @@ func TestGCLookaheadDisabled(t *testing.T) {
opts.GCLookaheadInterval = 0 // disable lookahead opts.GCLookaheadInterval = 0 // disable lookahead
opts.GCPurgeInterval = 9 * time.Hour opts.GCPurgeInterval = 9 * time.Hour
factory := addressBookFactory(t, badgerStore, opts) factory := addressBookFactory(t, leveldbStore, opts)
ab, closeFn := factory() ab, closeFn := factory()
defer closeFn() defer closeFn()
@ -232,7 +232,7 @@ func BenchmarkLookaheadCycle(b *testing.B) {
opts.GCLookaheadInterval = 2 * time.Hour opts.GCLookaheadInterval = 2 * time.Hour
opts.GCPurgeInterval = 6 * time.Hour opts.GCPurgeInterval = 6 * time.Hour
factory := addressBookFactory(b, badgerStore, opts) factory := addressBookFactory(b, leveldbStore, opts)
ab, closeFn := factory() ab, closeFn := factory()
defer closeFn() defer closeFn()

9
pstoreds/ds_test.go
View File

@ -18,8 +18,8 @@ import (
type datastoreFactory func(tb testing.TB) (ds.Batching, func()) type datastoreFactory func(tb testing.TB) (ds.Batching, func())
var dstores = map[string]datastoreFactory{ var dstores = map[string]datastoreFactory{
"Badger": badgerStore, //"Badger": badgerStore,
// "Leveldb": leveldbStore, "Leveldb": leveldbStore,
} }
func TestDsPeerstore(t *testing.T) { func TestDsPeerstore(t *testing.T) {
@ -87,6 +87,8 @@ func BenchmarkDsPeerstore(b *testing.B) {
} }
} }
// Doesn't work on 32bit because badger.
//lint:ignore U1000 disabled for now
func badgerStore(tb testing.TB) (ds.Batching, func()) { func badgerStore(tb testing.TB) (ds.Batching, func()) {
dataPath, err := ioutil.TempDir(os.TempDir(), "badger") dataPath, err := ioutil.TempDir(os.TempDir(), "badger")
if err != nil { if err != nil {
@ -103,8 +105,7 @@ func badgerStore(tb testing.TB) (ds.Batching, func()) {
return store, closer return store, closer
} }
//lint:ignore U1000 disabled for now func leveldbStore(tb testing.TB) (ds.Batching, func()) {
func leveldbStore(tb testing.TB) (ds.TxnDatastore, func()) {
dataPath, err := ioutil.TempDir(os.TempDir(), "leveldb") dataPath, err := ioutil.TempDir(os.TempDir(), "leveldb")
if err != nil { if err != nil {
tb.Fatal(err) tb.Fatal(err)