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

filter out "" from active peers in bitswap sessions

Merge pull request #4316 from ipfs/fix/bitswap-active-peers
filter out "" from active peers in bitswap sessions
329eb1cd · Jeromy Johnson · GitHub · 08733c2b · 37296d39 · 329eb1cd
Commit 329eb1cd authored Oct 18, 2017 by Jeromy Johnson Committed by GitHub Oct 18, 2017
Hide whitespace changes
Inline Side-by-side

Showing with 3 additions and 1 deletion

exchange/bitswap/session.go exchange/bitswap/session.go +3 -1

No files found.
--- 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)