forks/go-ethereum
1
0
Fork 1
mirror of https://github.com/ethereum/go-ethereum.git synced 2026-08-18 01:43:47 +00:00
Code Issues Projects Releases Packages Wiki Activity Actions 1

swarm/storage: tracing for chunks

Browse source
This commit is contained in:
Anton Evangelatov 2018-03-15 18:18:56 +01:00
parent 290ff49e1e
commit b72cd7eb70
1 changed files with 8 additions and 0 deletions
Show stats Download patch file Download diff file Expand all files Collapse all files

8
swarm/storage/chunker.go
View file

@ -23,6 +23,7 @@ import (
"sync" "sync"
"time" "time"
"github.com/ethereum/go-ethereum/log"
"github.com/ethereum/go-ethereum/metrics" "github.com/ethereum/go-ethereum/metrics"
) )
@ -332,6 +333,7 @@ func (self *TreeChunker) Join(key Key, chunkC chan *Chunk, depth int) LazySectio
// Size is meant to be called on the LazySectionReader // Size is meant to be called on the LazySectionReader
func (self *LazyChunkReader) Size(quitC chan bool) (n int64, err error) { func (self *LazyChunkReader) Size(quitC chan bool) (n int64, err error) {
log.Debug("lazychunkreader.size", "key", self.key)
if self.chunk != nil { if self.chunk != nil {
return self.chunk.Size, nil return self.chunk.Size, nil
} }
@ -459,15 +461,18 @@ func (self *LazyChunkReader) join(b []byte, off int64, eoff int64, depth int, tr
// block until they time out or arrive // block until they time out or arrive
// abort if quitC is readable // abort if quitC is readable
func retrieve(key Key, chunkC chan *Chunk, quitC chan bool) *Chunk { func retrieve(key Key, chunkC chan *Chunk, quitC chan bool) *Chunk {
log.Debug("retrieve", "key", key)
chunk := NewChunk(key, nil) chunk := NewChunk(key, nil)
chunk.C = make(chan bool) chunk.C = make(chan bool)
// submit chunk for retrieval // submit chunk for retrieval
log.Debug("submit chunk for retrieval", "key", key)
select { select {
case chunkC <- chunk: // submit retrieval request, someone should be listening on the other side (or we will time out globally) case chunkC <- chunk: // submit retrieval request, someone should be listening on the other side (or we will time out globally)
case <-quitC: case <-quitC:
return nil return nil
} }
// waiting for the chunk retrieval // waiting for the chunk retrieval
log.Debug("waiting for the chunk retrieval", "key", key)
select { // chunk.Size = int64(binary.LittleEndian.Uint64(chunk.SData[0:8])) select { // chunk.Size = int64(binary.LittleEndian.Uint64(chunk.SData[0:8]))
case <-quitC: case <-quitC:
@ -478,11 +483,13 @@ func retrieve(key Key, chunkC chan *Chunk, quitC chan bool) *Chunk {
if len(chunk.SData) == 0 { if len(chunk.SData) == 0 {
return nil return nil
} }
log.Debug("chunk retrieved", "key", key)
return chunk return chunk
} }
// Read keeps a cursor so cannot be called simulateously, see ReadAt // Read keeps a cursor so cannot be called simulateously, see ReadAt
func (self *LazyChunkReader) Read(b []byte) (read int, err error) { func (self *LazyChunkReader) Read(b []byte) (read int, err error) {
log.Debug("lazychunkreader.read", "key", self.key)
read, err = self.ReadAt(b, self.off) read, err = self.ReadAt(b, self.off)
self.off += int64(read) self.off += int64(read)
@ -494,6 +501,7 @@ var errWhence = errors.New("Seek: invalid whence")
var errOffset = errors.New("Seek: invalid offset") var errOffset = errors.New("Seek: invalid offset")
func (s *LazyChunkReader) Seek(offset int64, whence int) (int64, error) { func (s *LazyChunkReader) Seek(offset int64, whence int) (int64, error) {
log.Debug("lazychunkreader.seek", "key", s.key, "offset", offset)
switch whence { switch whence {
default: default:
return 0, errWhence return 0, errWhence