From 09713314c7c9121433c5fad06d9c8b866beb7e22 Mon Sep 17 00:00:00 2001 From: Anton Evangelatov Date: Sun, 22 Apr 2018 13:10:08 +0200 Subject: [PATCH] swarm/storage: more error logging for Read and ReadAt --- swarm/storage/chunker.go | 8 +++++++- 1 file changed, 7 insertions(+), 1 deletion(-) diff --git a/swarm/storage/chunker.go b/swarm/storage/chunker.go index c2bac98593..7e2b3be646 100644 --- a/swarm/storage/chunker.go +++ b/swarm/storage/chunker.go @@ -393,7 +393,7 @@ type LazyChunkReader struct { } // implements the Joiner interface -func (self *TreeChunker) Join() LazySectionReader { +func (self *TreeChunker) Join() *LazyChunkReader { return &LazyChunkReader{ key: self.key, chunkSize: self.chunkSize, @@ -436,6 +436,7 @@ func (self *LazyChunkReader) ReadAt(b []byte, off int64) (read int, err error) { quitC := make(chan bool) size, err := self.Size(quitC) if err != nil { + log.Error("lazychunkreader.readat.size", "size", size, "err", err) return 0, err } @@ -464,6 +465,7 @@ func (self *LazyChunkReader) ReadAt(b []byte, off int64) (read int, err error) { err = <-errC if err != nil { + log.Error("lazychunkreader.readat.errc", "err", err) close(quitC) return 0, err } @@ -517,6 +519,7 @@ func (self *LazyChunkReader) join(b []byte, off int64, eoff int64, depth int, tr childKey := chunkData[8+j*self.hashSize : 8+(j+1)*self.hashSize] chunkData, err := self.getter.Get(Reference(childKey)) if err != nil { + log.Error("lazychunkreader.join", "key", childKey, "err", err) select { case errC <- fmt.Errorf("chunk %v-%v not found", off, off+treeSize): case <-quitC: @@ -535,6 +538,9 @@ func (self *LazyChunkReader) join(b []byte, off int64, eoff int64, depth int, tr func (self *LazyChunkReader) Read(b []byte) (read int, err error) { log.Debug("lazychunkreader.read", "key", self.key) read, err = self.ReadAt(b, self.off) + if err != nil { + log.Error("lazychunkreader.readat", "read", read, "err", err) + } self.off += int64(read) return