torrent loop does not block processing dht results

cenkalti · Feb 20, 2019 · a3cd6c9 · a3cd6c9
1 parent c33df81
commit a3cd6c9
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/torrent/dhtannouncer.go b/torrent/dhtannouncer.go
@@ -18,7 +18,7 @@ func newDHTAnnouncer(node *node.DHT, infoHash []byte, port int) *dhtAnnouncer {
 		node:     node,
 		infoHash: string(infoHash),
 		port:     port,
-		peersC:   make(chan []*net.TCPAddr),
+		peersC:   make(chan []*net.TCPAddr, 1),
 	}
 }
 

diff --git a/torrent/session.go b/torrent/session.go
@@ -193,6 +193,7 @@ func (s *Session) processDHTResults() {
 					select {
 					case t.dhtAnnouncer.peersC <- addrs:
 					case <-t.removed:
+					default:
 					}
 				}
 			}