torrent.go | 10 ++++++++-- diff --git a/torrent.go b/torrent.go index 18a3f75859de1bc55129ca9ba7b12b9488d3a263..e38764742499d9db8fcd4b58b898cc9626d848aa 100644 --- a/torrent.go +++ b/torrent.go @@ -1538,17 +1538,23 @@ func (t *Torrent) consumeDhtAnnouncePeers(pvs <-chan dht.PeersValues) { cl := t.cl for v := range pvs { cl.lock() + added := 0 for _, cp := range v.Peers { if cp.Port == 0 { // Can't do anything with this. continue } - t.addPeer(PeerInfo{ + if t.addPeer(PeerInfo{ Addr: ipPortAddr{cp.IP, cp.Port}, Source: PeerSourceDhtGetPeers, - }) + }) { + added++ + } } cl.unlock() + if added != 0 { + //log.Printf("added %v peers from dht for %v", added, t.InfoHash().HexString()) + } } }