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
cc9028d1 · Jeromy Johnson · GitHub · bec48890 · 42f8fed0 · cc9028d1
Commit cc9028d1 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

session.go session.go +3 -1

No files found.
--- a/session.go
+++ b/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)