]> Sergey Matveev's repositories - btrtrc.git/commitdiff
Backed out changeset: 603a76a6bdb0
authorMatt Joiner <anacrolix@gmail.com>
Tue, 2 Dec 2014 06:11:39 +0000 (00:11 -0600)
committerMatt Joiner <anacrolix@gmail.com>
Tue, 2 Dec 2014 06:11:39 +0000 (00:11 -0600)
client.go

index 6ac5a2298571190d5502d7092e1f7fe70892bffe..24af34da4f8c636e92ac1a654fae409e525c9dc4 100644 (file)
--- a/client.go
+++ b/client.go
@@ -426,15 +426,9 @@ func NewClient(cfg *Config) (cl *Client, err error) {
                cl.listeners = append(cl.listeners, l)
                go cl.acceptConnections(l, false)
        }
-       var utpL *utp.Listener
+       var utpL *utp.UTPListener
        if !cfg.DisableUTP {
-               var utpAddr *utp.Addr
-               utpAddr, err = utp.ResolveAddr("utp", listenAddr())
-               if err != nil {
-                       err = fmt.Errorf("error resolving utp listen addr: %s", err)
-                       return
-               }
-               utpL, err = utp.Listen("utp", utpAddr)
+               utpL, err = utp.Listen("utp", listenAddr())
                if err != nil {
                        return
                }
@@ -887,9 +881,10 @@ func (me *Client) runConnection(sock net.Conn, torrent *torrent, discovery peerS
                })
        }
        if conn.PeerExtensionBytes[7]&0x01 != 0 && me.dHT != nil {
+               addr, _ := me.dHT.LocalAddr().(*net.UDPAddr)
                conn.Post(pp.Message{
                        Type: pp.Port,
-                       Port: uint16(AddrPort(me.dHT.LocalAddr())),
+                       Port: uint16(addr.Port),
                })
        }
        if torrent.haveInfo() {