Merge pull request #4316 from ipfs/fix/bitswap-active-peers

filter out "" from active peers in bitswap sessions
ipfs · Oct 18, 2017 · 329eb1c · 329eb1c
2 parents 08733c2 + 37296d3
commit 329eb1c
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/exchange/bitswap/session.go b/exchange/bitswap/session.go
@@ -159,7 +159,9 @@ func (s *Session) run(ctx context.Context) {
 		case blk := <-s.incoming:
 			s.tick.Stop()
 
-			s.addActivePeer(blk.from)
+			if blk.from != "" {
+				s.addActivePeer(blk.from)
+			}
 
 			s.receiveBlock(ctx, blk.blk)