From: Matt Joiner Date: Tue, 18 Nov 2014 00:03:28 +0000 (-0600) Subject: dht: Reduce announce peer parallelism now that node goodness is fixed X-Git-Tag: v1.0.0~1522 X-Git-Url: http://www.git.stargrave.org/?a=commitdiff_plain;h=d7764a5c23e302da4f910b3d870155c67d05a60f;p=btrtrc.git dht: Reduce announce peer parallelism now that node goodness is fixed --- 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)