fix kcp test

This commit is contained in:
ginuerzh 2018-12-09 14:11:25 +08:00
parent 6ccb6e52ae
commit 75f71daa99
2 changed files with 6 additions and 6 deletions

2
kcp.go
View File

@ -124,7 +124,7 @@ func (tr *kcpTransporter) Dial(addr string, options ...DialOption) (conn net.Con
session, ok := tr.sessions[addr] session, ok := tr.sessions[addr]
if !ok { if !ok {
conn, err = net.DialUDP("udp", &net.UDPAddr{IP: net.IPv4zero}, uaddr) conn, err = net.DialUDP("udp", nil, uaddr)
if err != nil { if err != nil {
return return
} }

View File

@ -10,7 +10,7 @@ import (
func httpOverKCPRoundtrip(targetURL string, data []byte, func httpOverKCPRoundtrip(targetURL string, data []byte,
clientInfo *url.Userinfo, serverInfo []*url.Userinfo) error { clientInfo *url.Userinfo, serverInfo []*url.Userinfo) error {
ln, err := KCPListener("", nil) ln, err := KCPListener("localhost:0", nil)
if err != nil { if err != nil {
return err return err
} }
@ -128,7 +128,7 @@ func BenchmarkHTTPOverKCPParallel(b *testing.B) {
func socks5OverKCPRoundtrip(targetURL string, data []byte, func socks5OverKCPRoundtrip(targetURL string, data []byte,
clientInfo *url.Userinfo, serverInfo []*url.Userinfo) error { clientInfo *url.Userinfo, serverInfo []*url.Userinfo) error {
ln, err := KCPListener("", nil) ln, err := KCPListener("localhost:0", nil)
if err != nil { if err != nil {
return err return err
} }
@ -177,7 +177,7 @@ func TestSOCKS5OverKCP(t *testing.T) {
} }
func socks4OverKCPRoundtrip(targetURL string, data []byte) error { func socks4OverKCPRoundtrip(targetURL string, data []byte) error {
ln, err := KCPListener("", nil) ln, err := KCPListener("localhost:0", nil)
if err != nil { if err != nil {
return err return err
} }
@ -213,7 +213,7 @@ func TestSOCKS4OverKCP(t *testing.T) {
} }
func socks4aOverKCPRoundtrip(targetURL string, data []byte) error { func socks4aOverKCPRoundtrip(targetURL string, data []byte) error {
ln, err := KCPListener("", nil) ln, err := KCPListener("localhost:0", nil)
if err != nil { if err != nil {
return err return err
} }
@ -252,7 +252,7 @@ func TestSOCKS4AOverKCP(t *testing.T) {
func ssOverKCPRoundtrip(targetURL string, data []byte, func ssOverKCPRoundtrip(targetURL string, data []byte,
clientInfo, serverInfo *url.Userinfo) error { clientInfo, serverInfo *url.Userinfo) error {
ln, err := KCPListener("", nil) ln, err := KCPListener("localhost:0", nil)
if err != nil { if err != nil {
return err return err
} }