From d69cfbc41901217a06b1563043801bc67fdfbf80 Mon Sep 17 00:00:00 2001 From: Matt Joiner Date: Thu, 15 Feb 2018 14:43:57 +1100 Subject: [PATCH] Track IPv6 peers received over PEX and simplify the adding code --- connection.go | 8 ++------ 1 file changed, 2 insertions(+), 6 deletions(-) diff --git a/connection.go b/connection.go index bf448574..235d0430 100644 --- 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)