X-Git-Url: http://www.git.stargrave.org/?a=blobdiff_plain;f=utp_libutp.go;h=6da9402c3fe820337b286dd89f0fe5ab3df75978;hb=87f6cdc1e96fdd846bb9c55cfd5176a17373d4b6;hp=1e8fa6738fc8165067ab4aa7007038417dbadb0b;hpb=3b62b0054df3ecd7cdca571ddcef06e90c0e8778;p=btrtrc.git diff --git a/utp_libutp.go b/utp_libutp.go index 1e8fa673..6da9402c 100644 --- a/utp_libutp.go +++ b/utp_libutp.go @@ -4,11 +4,12 @@ package torrent import ( - "github.com/anacrolix/go-libutp" + utp "github.com/anacrolix/go-libutp" + "github.com/anacrolix/log" ) -func NewUtpSocket(network, addr string, fc firewallCallback) (utpSocket, error) { - s, err := utp.NewSocket(network, addr) +func NewUtpSocket(network, addr string, fc firewallCallback, logger log.Logger) (utpSocket, error) { + s, err := utp.NewSocket(network, addr, utp.WithLogger(logger)) if s == nil { return nil, err } @@ -16,7 +17,7 @@ func NewUtpSocket(network, addr string, fc firewallCallback) (utpSocket, error) return s, err } if fc != nil { - s.SetFirewallCallback(utp.FirewallCallback(fc)) + s.SetSyncFirewallCallback(utp.FirewallCallback(fc)) } return s, err }