Track IPv6 peers received over PEX and simplify the adding code

diff --git a/connection.go b/connection.go
index bf4485746b2057dbe333d9524507bf640ff2a05f..235d043005e3a421af8bc50d32e4d3780174fb78 100644 (file)
--- a/connection.go
+++ b/connection.go
@@ -1155,12 +1155,8 @@ func (c *connection) onReadExtendedMsg(id byte, payload []byte) (err error) {
                if err != nil {
                        return fmt.Errorf("error unmarshalling PEX message: %s", err)
                }
-               go func() {
-                       ps := pexMsg.AddedPeers()
-                       cl.mu.Lock()
-                       t.addPeers(ps)
-                       cl.mu.Unlock()
-               }()
+               torrent.Add("pex added6 peers received", int64(len(pexMsg.Added6)))
+               t.addPeers(pexMsg.AddedPeers())
                return nil
        default:
                return fmt.Errorf("unexpected extended message ID: %v", id)