From d7764a5c23e302da4f910b3d870155c67d05a60f Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Mon, 17 Nov 2014 18:03:28 -0600 Subject: [PATCH] dht: Reduce announce peer parallelism now that node goodness is fixed --- dht/dht.go | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/dht/dht.go b/dht/dht.go index a58bdd0c..14a0af0f 100644 --- a/dht/dht.go +++ b/dht/dht.go @@ -546,7 +546,7 @@ func (s *Server) Ping(node *net.UDPAddr) (*transaction, error) { func (s *Server) AnnouncePeer(port int, impliedPort bool, infoHash string) (err error) { s.mu.Lock() defer s.mu.Unlock() - for _, node := range s.closestNodes(10000, infoHash, func(n *Node) bool { + for _, node := range s.closestNodes(160, infoHash, func(n *Node) bool { return n.Good() && n.announceToken != "" }) { err = s.announcePeer(node.addr, infoHash, port, node.announceToken, impliedPort) -- 2.48.1