From d9f85f76a0271a38c5577a8625287b2c1298e3a9 Mon Sep 17 00:00:00 2001 From: aler9 <46489434+aler9@users.noreply.github.com> Date: Sat, 13 Mar 2021 18:13:59 +0100 Subject: [PATCH] fix tests --- clientconnread_test.go | 6 ++++++ serverconn_test.go | 8 ++++---- serverconnpublish_test.go | 8 ++++---- serverconnread_test.go | 16 ++++++++-------- 4 files changed, 22 insertions(+), 16 deletions(-) diff --git a/clientconnread_test.go b/clientconnread_test.go index 2738c39d..1d662624 100644 --- a/clientconnread_test.go +++ b/clientconnread_test.go @@ -151,6 +151,8 @@ func TestClientConnRead(t *testing.T) { require.NoError(t, err) if ca.proto == "udp" { + time.Sleep(1 * time.Second) + l1, err := net.ListenPacket("udp", "localhost:34556") require.NoError(t, err) defer l1.Close() @@ -292,6 +294,8 @@ func TestClientConnReadNoServerPorts(t *testing.T) { }.Write(bconn.Writer) require.NoError(t, err) + time.Sleep(1 * time.Second) + l1, err := net.ListenPacket("udp", "localhost:0") require.NoError(t, err) defer l1.Close() @@ -545,6 +549,8 @@ func TestClientConnReadRedirect(t *testing.T) { }.Write(bconn.Writer) require.NoError(t, err) + time.Sleep(1 * time.Second) + l1, err := net.ListenPacket("udp", "localhost:34556") require.NoError(t, err) defer l1.Close() diff --git a/serverconn_test.go b/serverconn_test.go index 01041b63..86b6f584 100644 --- a/serverconn_test.go +++ b/serverconn_test.go @@ -34,12 +34,12 @@ func newTestServ(tlsConf *tls.Config) (*testServ, error) { } } else { conf = ServerConf{ - UDPRTPAddress: ":8000", - UDPRTCPAddress: ":8001", + UDPRTPAddress: "127.0.0.1:8000", + UDPRTCPAddress: "127.0.0.1:8001", } } - s, err := conf.Serve(":8554") + s, err := conf.Serve("127.0.0.1:8554") if err != nil { return nil, err } @@ -435,7 +435,7 @@ func TestServerConnPublishReadHighLevel(t *testing.T) { } func TestServerConnTeardownResponse(t *testing.T) { - s, err := Serve(":8554") + s, err := Serve("127.0.0.1:8554") require.NoError(t, err) defer s.Close() diff --git a/serverconnpublish_test.go b/serverconnpublish_test.go index 38c16e12..389e94ea 100644 --- a/serverconnpublish_test.go +++ b/serverconnpublish_test.go @@ -25,11 +25,11 @@ func TestServerConnPublishReceivePackets(t *testing.T) { packetsReceived := make(chan struct{}) conf := ServerConf{ - UDPRTPAddress: ":8000", - UDPRTCPAddress: ":8001", + UDPRTPAddress: "127.0.0.1:8000", + UDPRTCPAddress: "127.0.0.1:8001", } - s, err := conf.Serve(":8554") + s, err := conf.Serve("127.0.0.1:8554") require.NoError(t, err) defer s.Close() @@ -168,7 +168,7 @@ func TestServerConnPublishReceivePackets(t *testing.T) { require.Equal(t, base.StatusOK, res.StatusCode) if proto == "udp" { - time.Sleep(500 * time.Millisecond) + time.Sleep(1 * time.Second) l1, err := net.ListenPacket("udp", "localhost:35466") require.NoError(t, err) diff --git a/serverconnread_test.go b/serverconnread_test.go index 8d0640ef..98dd94d4 100644 --- a/serverconnread_test.go +++ b/serverconnread_test.go @@ -22,11 +22,11 @@ func TestServerConnReadReceivePackets(t *testing.T) { packetsReceived := make(chan struct{}) conf := ServerConf{ - UDPRTPAddress: ":8000", - UDPRTCPAddress: ":8001", + UDPRTPAddress: "127.0.0.1:8000", + UDPRTCPAddress: "127.0.0.1:8001", } - s, err := conf.Serve(":8554") + s, err := conf.Serve("127.0.0.1:8554") require.NoError(t, err) defer s.Close() @@ -122,7 +122,7 @@ func TestServerConnReadReceivePackets(t *testing.T) { require.Equal(t, base.StatusOK, res.StatusCode) if proto == "udp" { - time.Sleep(500 * time.Millisecond) + time.Sleep(1 * time.Second) l1, err := net.ListenPacket("udp", "localhost:35467") require.NoError(t, err) @@ -147,7 +147,7 @@ func TestServerConnReadReceivePackets(t *testing.T) { } func TestServerConnReadWithoutSetupTrackID(t *testing.T) { - s, err := Serve(":8554") + s, err := Serve("127.0.0.1:8554") require.NoError(t, err) defer s.Close() @@ -235,7 +235,7 @@ func TestServerConnReadWithoutSetupTrackID(t *testing.T) { } func TestServerConnReadTCPResponseBeforeFrames(t *testing.T) { - s, err := Serve(":8554") + s, err := Serve("127.0.0.1:8554") require.NoError(t, err) defer s.Close() @@ -343,7 +343,7 @@ func TestServerConnReadTCPResponseBeforeFrames(t *testing.T) { } func TestServerConnReadPlayMultiple(t *testing.T) { - s, err := Serve(":8554") + s, err := Serve("127.0.0.1:8554") require.NoError(t, err) defer s.Close() @@ -458,7 +458,7 @@ func TestServerConnReadPlayMultiple(t *testing.T) { } func TestServerConnReadPauseMultiple(t *testing.T) { - s, err := Serve(":8554") + s, err := Serve("127.0.0.1:8554") require.NoError(t, err) defer s.Close()