forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-17 09:23:48 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/storage: Store chunk size

Browse source
This commit is contained in:
Balint Gabor 2018-01-15 18:25:59 +01:00
parent 61f5aa4e01
commit 91b6a66f03
2 changed files with 3 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

2
swarm/storage/dpa.go
View file

@ -17,6 +17,7 @@
package storage package storage
import ( import (
"encoding/binary"
"errors" "errors"
"fmt" "fmt"
"io" "io"
@ -211,6 +212,7 @@ func (self *dpaChunkStore) Get(key Key) (chunk *Chunk, err error) {
return nil, notFound return nil, notFound
case <-chunk.ReqC: case <-chunk.ReqC:
} }
chunk.Size = int64(binary.LittleEndian.Uint64(chunk.SData[0:8]))
return chunk, nil return chunk, nil
} }

1
swarm/storage/localstore.go
View file

@ -59,6 +59,7 @@ func NewTestLocalStore(path string) (*LocalStore, error) {
// LocalStore is itself a chunk store // LocalStore is itself a chunk store
// unsafe, in that the data is not integrity checked // unsafe, in that the data is not integrity checked
func (self *LocalStore) Put(chunk *Chunk) { func (self *LocalStore) Put(chunk *Chunk) {
chunk.Size = int64(binary.LittleEndian.Uint64(chunk.SData[0:8]))
self.memStore.Put(chunk) self.memStore.Put(chunk)
go func() { go func() {
self.DbStore.Put(chunk) self.DbStore.Put(chunk)