]> Sergey Matveev's repositories - btrtrc.git/commitdiff
Count peers added from DHT for logging
authorMatt Joiner <anacrolix@gmail.com>
Mon, 24 May 2021 08:08:32 +0000 (18:08 +1000)
committerMatt Joiner <anacrolix@gmail.com>
Mon, 7 Jun 2021 02:57:32 +0000 (12:57 +1000)
torrent.go

index 18a3f75859de1bc55129ca9ba7b12b9488d3a263..e38764742499d9db8fcd4b58b898cc9626d848aa 100644 (file)
@@ -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())
+               }
        }
 }