blockservice: don't store blocks we already have

License: MIT Signed-off-by: Jeromy <why@ipfs.io>

blockservice: don't store blocks we already have
License: MIT Signed-off-by: Jeromy <why@ipfs.io>
25bfef8d · Jeromy · 67815d2e · 25bfef8d
Commit 25bfef8d authored Aug 19, 2016 by Jeromy
Hide whitespace changes
Inline Side-by-side

Showing with 1 addition and 0 deletions

workers.go workers.go +1 -0

No files found.
--- a/workers.go
+++ b/workers.go
@@ -133,6 +133,7 @@ func (bs *Bitswap) provideCollector(ctx context.Context) {
 				log.Debug("newBlocks channel closed")
 				return
 			}
+
 			if keysOut == nil {
 				nextKey = blk.Key()
 				keysOut = bs.provideKeys