From cd7a758acd764231c1c99c0f0b27eaeaaa444798 Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Thu, 24 Jul 2014 13:45:18 +1000 Subject: [PATCH] dht: Message only the most likely peers --- dht/dht.go | 13 +++++++++++-- 1 file changed, 11 insertions(+), 2 deletions(-) diff --git a/dht/dht.go b/dht/dht.go index abcc7a42..3cb1f0f4 100644 --- a/dht/dht.go +++ b/dht/dht.go @@ -626,7 +626,7 @@ func (s *Server) GetPeers(infoHash string) (ps *peerStream, err error) { done := make(chan struct{}) pending := 0 s.mu.Lock() - for _, n := range s.nodes { + for _, n := range s.closestGoodNodes(160, infoHash) { var t *transaction t, err = s.getPeers(n.addr, infoHash) if err != nil { @@ -727,13 +727,22 @@ func (s *Server) Bootstrap() (err error) { } s.mu.Lock() // log.Printf("now have %d nodes", len(s.nodes)) - if len(s.nodes) >= 8*160 { + if s.numGoodNodes() >= 160 { break } } return } +func (s *Server) numGoodNodes() (num int) { + for _, n := range s.nodes { + if n.Good() { + num++ + } + } + return +} + func (s *Server) NumNodes() int { s.mu.Lock() defer s.mu.Unlock() -- 2.50.0