External/mediamtx
1
0
Fork 1
mirror of https://github.com/bluenviron/mediamtx.git synced 2025-12-20 02:00:05 -08:00
Code Issues Projects Releases Packages Wiki Activity Actions 2

tests: fix race condition (#5187)

Browse source
This commit is contained in:
Alessandro Ros 2025-11-11 21:12:01 +01:00 • committed by GitHub
parent 6380c5514b
commit ac1d4360b2
No known key found for this signature in database
GPG key ID: B5690EEEBB952194
1 changed files with 4 additions and 4 deletions
Download patch file Download diff file Expand all files Collapse all files

8
internal/servers/rtmp/server_test.go
View file

@ -87,7 +87,7 @@ func TestServerPublish(t *testing.T) {
} }
s := &Server{ s := &Server{
Address: "127.0.0.1:1935", Address: "127.0.0.1:1939",
ReadTimeout: conf.Duration(10 * time.Second), ReadTimeout: conf.Duration(10 * time.Second),
WriteTimeout: conf.Duration(10 * time.Second), WriteTimeout: conf.Duration(10 * time.Second),
IsTLS: encrypt == "tls", IsTLS: encrypt == "tls",
@ -113,7 +113,7 @@ func TestServerPublish(t *testing.T) {
rawURL += "rtmp://" rawURL += "rtmp://"
} }
rawURL += "127.0.0.1:1935/teststream?user=myuser&pass=mypass&param=value" rawURL += "127.0.0.1:1939/teststream?user=myuser&pass=mypass&param=value"
u, err := url.Parse(rawURL) u, err := url.Parse(rawURL)
require.NoError(t, err) require.NoError(t, err)
@ -217,7 +217,7 @@ func TestServerRead(t *testing.T) {
} }
s := &Server{ s := &Server{
Address: "127.0.0.1:1935", Address: "127.0.0.1:1939",
ReadTimeout: conf.Duration(10 * time.Second), ReadTimeout: conf.Duration(10 * time.Second),
WriteTimeout: conf.Duration(10 * time.Second), WriteTimeout: conf.Duration(10 * time.Second),
IsTLS: encrypt == "tls", IsTLS: encrypt == "tls",
@ -243,7 +243,7 @@ func TestServerRead(t *testing.T) {
rawURL += "rtmp://" rawURL += "rtmp://"
} }
rawURL += "127.0.0.1:1935/teststream?user=myuser&pass=mypass&param=value" rawURL += "127.0.0.1:1939/teststream?user=myuser&pass=mypass&param=value"
u, err := url.Parse(rawURL) u, err := url.Parse(rawURL)
require.NoError(t, err) require.NoError(t, err)