]> Sergey Matveev's repositories - btrtrc.git/commitdiff
dht: Reduce announce peer parallelism now that node goodness is fixed
authorMatt Joiner <anacrolix@gmail.com>
Tue, 18 Nov 2014 00:03:28 +0000 (18:03 -0600)
committerMatt Joiner <anacrolix@gmail.com>
Tue, 18 Nov 2014 00:03:28 +0000 (18:03 -0600)
dht/dht.go

index a58bdd0c5276be5475ebb629cbefc94f30287cb7..14a0af0ffa4e89552b4ed390acef9d816bc23bfe 100644 (file)
@@ -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)