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

minor change in dpa and dpa test (fails)

Browse source
This commit is contained in:
zelig 2015-02-06 19:54:27 +01:00
parent effe37d282
commit 3f328c20b2
2 changed files with 57 additions and 57 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

12
bzz/dpa.go
View file

@ -175,15 +175,15 @@ func (self *DPA) storeLoop() {
fmt.Printf("StoreLoop started.\n")
STORE:
for {
chunk := <-self.storeC
fmt.Printf("StoreLoop reader size %d\n", chunk.Reader.Size())
chunk.Data = make([]byte, chunk.Reader.Size())
chunk.Reader.ReadAt(chunk.Data, 0)
self.ChunkStore.Put(chunk)
select {
case chunk := <-self.storeC:
fmt.Printf("StoreLoop reader size %d\n", chunk.Reader.Size())
chunk.Data = make([]byte, chunk.Reader.Size())
chunk.Reader.ReadAt(chunk.Data, 0)
self.ChunkStore.Put(chunk)
case <-self.quitC:
break STORE
default:
// default:
}
}
}()

102
bzz/dpa_test.go
View file

@ -1,51 +1,51 @@
package bzz
import (
//"bytes"
"fmt"
"github.com/ethereum/go-ethereum/bzz/test"
"os"
"testing"
"time"
)
func TestDPA(t *testing.T) {
test.LogInit()
os.RemoveAll("/tmp/bzz")
dbStore, err := newDbStore("/tmp/bzz")
if err != nil {
t.Errorf("DB error: %v", err)
}
// memStore := newMemStore(dbStore)
// localStore := &localStore{
// memStore,
// dbStore,
// }
chunker := &TreeChunker{}
chunker.Init()
dpa := &DPA{
Chunker: chunker,
ChunkStore: dbStore,
}
dpa.Start()
reader, slice := testDataReader(0x100)
fmt.Printf("Chunk size: %d.", len(slice))
//key, err := dpa.Store(reader)
_, err = dpa.Store(reader)
if err != nil {
t.Errorf("Store error: %v", err)
}
// resultReader := dpa.Retrieve(key)
// resultSlice := make([]byte, len(slice))
// n, err := resultReader.Read(resultSlice)
// if err != nil {
// t.Errorf("Retrieve error: %v", err)
// }
// if n != len(slice) {
// t.Errorf("Slice size error got %d, expected %d.", n, len(slice))
// }
// if !bytes.Equal(slice, resultSlice) {
// t.Errorf("Comparison error.")
// }
time.Sleep(time.Second)
}
package bzz
import (
"bytes"
"fmt"
"github.com/ethereum/go-ethereum/bzz/test"
"os"
"testing"
"time"
)
func TestDPA(t *testing.T) {
test.LogInit()
os.RemoveAll("/tmp/bzz")
dbStore, err := newDbStore("/tmp/bzz")
if err != nil {
t.Errorf("DB error: %v", err)
}
// memStore := newMemStore(dbStore)
// localStore := &localStore{
// memStore,
// dbStore,
// }
chunker := &TreeChunker{}
chunker.Init()
dpa := &DPA{
Chunker: chunker,
ChunkStore: dbStore,
}
dpa.Start()
reader, slice := testDataReader(0x100)
fmt.Printf("Chunk size: %d.", len(slice))
key, err := dpa.Store(reader)
// _, err = dpa.Store(reader)
if err != nil {
t.Errorf("Store error: %v", err)
}
resultReader := dpa.Retrieve(key)
resultSlice := make([]byte, len(slice))
n, err := resultReader.Read(resultSlice)
if err != nil {
t.Errorf("Retrieve error: %v", err)
}
if n != len(slice) {
t.Errorf("Slice size error got %d, expected %d.", n, len(slice))
}
if !bytes.Equal(slice, resultSlice) {
t.Errorf("Comparison error.")
}
time.Sleep(time.Second)
}