code: func (t *Torrent) consumeDhtAnnouncePeers(pvs <-chan dht.PeersValues) {
  	cl := t.cl
  	for v := range pvs {
  		cl.lock()
  		for _, cp := range v.Peers {
  			if cp.Port == 0 {
  				// Can't do anything with this.
  				continue
  			}
  			t.addPeer(Peer{
  				IP:     cp.IP[:],
  				Port:   cp.Port,
  				Source: peerSourceDHTGetPeers,
  			})
  		}
  		cl.unlock()
  	}
  }
docs: // Adds peers revealed in an announce until the announce ends, or we have
  // enough peers.