forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-07-21 20:26:41 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

Test localStore in its entirety.

Browse source
This commit is contained in:
Daniel A. Nagy 2015-02-09 16:36:11 +01:00
parent 351910d101
commit 5ed5a5cbc2
1 changed files with 7 additions and 11 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

18
bzz/dpa_test.go
View file

@ -2,7 +2,6 @@ package bzz
import ( import (
"bytes" "bytes"
"fmt"
"github.com/ethereum/go-ethereum/bzz/test" "github.com/ethereum/go-ethereum/bzz/test"
"os" "os"
"testing" "testing"
@ -16,25 +15,23 @@ func TestDPA(t *testing.T) {
if err != nil { if err != nil {
t.Errorf("DB error: %v", err) t.Errorf("DB error: %v", err)
} }
// memStore := newMemStore(dbStore) memStore := newMemStore(dbStore)
// localStore := &localStore{ localStore := &localStore{
// memStore, memStore,
// dbStore, dbStore,
// } }
chunker := &TreeChunker{} chunker := &TreeChunker{}
chunker.Init() chunker.Init()
dpa := &DPA{ dpa := &DPA{
Chunker: chunker, Chunker: chunker,
ChunkStore: dbStore, ChunkStore: localStore,
} }
dpa.Start() dpa.Start()
reader, slice := testDataReader(0x100) reader, slice := testDataReader(0x1000000)
fmt.Printf("Chunk size: %d.", len(slice))
key, err := dpa.Store(reader) key, err := dpa.Store(reader)
if err != nil { if err != nil {
t.Errorf("Store error: %v", err) t.Errorf("Store error: %v", err)
} }
// time.Sleep(2 * time.Second)
resultReader := dpa.Retrieve(key) resultReader := dpa.Retrieve(key)
resultSlice := make([]byte, len(slice)) resultSlice := make([]byte, len(slice))
n, err := resultReader.ReadAt(resultSlice, 0) n, err := resultReader.ReadAt(resultSlice, 0)
@ -47,5 +44,4 @@ func TestDPA(t *testing.T) {
if !bytes.Equal(slice, resultSlice) { if !bytes.Equal(slice, resultSlice) {
t.Errorf("Comparison error.") t.Errorf("Comparison error.")
} }
// time.Sleep(time.Second)
} }