mirror of
https://github.com/aler9/gortsplib
synced 2025-11-02 11:24:05 +08:00
fix race condition in test (#826)
This commit is contained in:
@@ -1335,13 +1335,9 @@ func TestClientPlayAnyPort(t *testing.T) {
|
||||
packetRecv := make(chan struct{})
|
||||
|
||||
c := Client{
|
||||
AnyPortEnable: true,
|
||||
receiverReportPeriod: 100 * time.Millisecond,
|
||||
AnyPortEnable: true,
|
||||
}
|
||||
|
||||
clientErr := make(chan struct{})
|
||||
defer func() { <-clientErr }()
|
||||
|
||||
var med *description.Media
|
||||
err = readAll(&c, "rtsp://localhost:8554/teststream",
|
||||
func(medi *description.Media, _ format.Format, pkt *rtp.Packet) {
|
||||
@@ -1352,12 +1348,6 @@ func TestClientPlayAnyPort(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
defer c.Close()
|
||||
|
||||
go func() {
|
||||
err := c.Wait()
|
||||
require.EqualError(t, err, "terminated")
|
||||
close(clientErr)
|
||||
}()
|
||||
|
||||
<-packetRecv
|
||||
|
||||
if ca == "random" {
|
||||
@@ -1365,13 +1355,6 @@ func TestClientPlayAnyPort(t *testing.T) {
|
||||
require.NoError(t, err)
|
||||
<-serverRecv
|
||||
}
|
||||
|
||||
// make sure that RTCP receiver reports do not cause any error
|
||||
select {
|
||||
case <-time.After(200 * time.Millisecond):
|
||||
case <-clientErr:
|
||||
t.Error("should not happen")
|
||||
}
|
||||
})
|
||||
}
|
||||
}
|
||||
|
||||
Reference in New Issue
Block a user