From 07993aa2eab122d5aee5cdf33ce66865bbfa36b9 Mon Sep 17 00:00:00 2001 From: "Daniel A. Nagy" Date: Wed, 11 Feb 2015 17:50:50 +0100 Subject: [PATCH] STDOUT debug messages removed, dbStore default capacity increased --- bzz/chunker.go | 3 --- bzz/dbstore.go | 2 +- 2 files changed, 1 insertion(+), 4 deletions(-) diff --git a/bzz/chunker.go b/bzz/chunker.go index 87589f2287..4bf1f9c723 100644 --- a/bzz/chunker.go +++ b/bzz/chunker.go @@ -351,14 +351,12 @@ func (self *LazyChunkReader) join(b []byte, off int64, eoff int64, depth int, tr defer parentWg.Done() dpaLogger.Debugf("depth: %v, loff: %v, eoff: %v, chunk.Size: %v, treeSize: %v", depth, off, eoff, chunk.Size, treeSize) - fmt.Printf("depth: %v, loff: %v, eoff: %v, chunk.Size: %v, treeSize: %v\n", depth, off, eoff, chunk.Size, treeSize) // find appropriate block level for chunk.Size < treeSize && depth > 0 { treeSize /= self.chunker.Branches depth-- } - fmt.Printf("-> depth: %v, loff: %v, eoff: %v, len(chunk.Data): %v, chunk.Size: %v, treeSize: %v\n", depth, off, eoff, len(chunk.Data), chunk.Size, treeSize) if depth == 0 { dpaLogger.Debugf("len(b): %v, off: %v, eoff: %v, chunk.Size: %v, treeSize: %v", depth, len(b), off, eoff, chunk.Size, treeSize) @@ -395,7 +393,6 @@ func (self *LazyChunkReader) join(b []byte, off int64, eoff int64, depth int, tr C: make(chan bool), // close channel to signal data delivery } dpaLogger.Debugf("chunk data sent for %x (key interval in chunk %v-%v)", ch.Key[:4], j*self.chunker.hashSize, (j+1)*self.chunker.hashSize) - fmt.Printf("chunk data sent for %x (key interval in chunk %v-%v)\n", ch.Key[:4], j*self.chunker.hashSize, (j+1)*self.chunker.hashSize) self.chunkC <- ch // submit retrieval request, someone should be listening on the other side (or we will time out globally) // waiting for the chunk retrieval diff --git a/bzz/dbstore.go b/bzz/dbstore.go index 510f2a59bd..f94ed80dae 100644 --- a/bzz/dbstore.go +++ b/bzz/dbstore.go @@ -382,7 +382,7 @@ func newDbStore(path string) (s *dbStore, err error) { return } - s.setCapacity(5000) + s.setCapacity(50000) // TODO define default capacity as constant s.gcStartPos = make([]byte, 1) s.gcStartPos[0] = kpIndex