t.Fatal(err)
}
defer l.Close()
+ utpAddr, err := utp.ResolveAddr("utp", fmt.Sprintf("localhost:%d", util.AddrPort(l.Addr())))
+ if err != nil {
+ t.Fatal(err)
+ }
go func() {
for {
_, err := l.Accept()
}
}()
// Connect a UTP peer to see if the RawConn will still work.
- utpPeer, err := utp.DialUTP("utp", nil, l.Addr().(*utp.Addr))
+ utpPeer, err := utp.DialUTP("utp", nil, utpAddr)
if err != nil {
t.Fatalf("error dialing utp listener: %s", err)
}
}
}
}()
+ udpAddr, err := net.ResolveUDPAddr("udp", fmt.Sprintf("localhost:%d", util.AddrPort(l.Addr())))
+ if err != nil {
+ t.Fatal(err)
+ }
for i := 0; i < N; i++ {
- _, err := peer.WriteTo([]byte(fmt.Sprintf("%d", i)), l.Addr().(*utp.Addr).Addr)
+ _, err := peer.WriteTo([]byte(fmt.Sprintf("%d", i)), udpAddr)
if err != nil {
t.Fatal(err)
}