|
|
|
@ -247,8 +247,6 @@ func TestPublishRead(t *testing.T) { |
|
|
|
defer p.close() |
|
|
|
defer p.close() |
|
|
|
} |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
time.Sleep(1 * time.Second) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
switch ca.publisherSoft { |
|
|
|
switch ca.publisherSoft { |
|
|
|
case "ffmpeg": |
|
|
|
case "ffmpeg": |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
@ -321,8 +319,6 @@ func TestTCPOnly(t *testing.T) { |
|
|
|
require.Equal(t, true, ok) |
|
|
|
require.Equal(t, true, ok) |
|
|
|
defer p.close() |
|
|
|
defer p.close() |
|
|
|
|
|
|
|
|
|
|
|
time.Sleep(1 * time.Second) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
"-re", |
|
|
|
"-re", |
|
|
|
"-stream_loop", "-1", |
|
|
|
"-stream_loop", "-1", |
|
|
|
@ -542,8 +538,6 @@ func TestAuthFail(t *testing.T) { |
|
|
|
require.Equal(t, true, ok) |
|
|
|
require.Equal(t, true, ok) |
|
|
|
defer p.close() |
|
|
|
defer p.close() |
|
|
|
|
|
|
|
|
|
|
|
time.Sleep(1 * time.Second) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
"-re", |
|
|
|
"-re", |
|
|
|
"-stream_loop", "-1", |
|
|
|
"-stream_loop", "-1", |
|
|
|
@ -601,8 +595,6 @@ func TestAuthFail(t *testing.T) { |
|
|
|
require.Equal(t, true, ok) |
|
|
|
require.Equal(t, true, ok) |
|
|
|
defer p.close() |
|
|
|
defer p.close() |
|
|
|
|
|
|
|
|
|
|
|
time.Sleep(1 * time.Second) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
"-re", |
|
|
|
"-re", |
|
|
|
"-stream_loop", "-1", |
|
|
|
"-stream_loop", "-1", |
|
|
|
@ -639,8 +631,6 @@ func TestAuthIpFail(t *testing.T) { |
|
|
|
require.Equal(t, true, ok) |
|
|
|
require.Equal(t, true, ok) |
|
|
|
defer p.close() |
|
|
|
defer p.close() |
|
|
|
|
|
|
|
|
|
|
|
time.Sleep(1 * time.Second) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
"-re", |
|
|
|
"-re", |
|
|
|
"-stream_loop", "-1", |
|
|
|
"-stream_loop", "-1", |
|
|
|
@ -791,8 +781,6 @@ func TestRedirect(t *testing.T) { |
|
|
|
require.Equal(t, true, ok) |
|
|
|
require.Equal(t, true, ok) |
|
|
|
defer p1.close() |
|
|
|
defer p1.close() |
|
|
|
|
|
|
|
|
|
|
|
time.Sleep(1 * time.Second) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
"-re", |
|
|
|
"-re", |
|
|
|
"-stream_loop", "-1", |
|
|
|
"-stream_loop", "-1", |
|
|
|
@ -828,8 +816,6 @@ func TestFallback(t *testing.T) { |
|
|
|
require.Equal(t, true, ok) |
|
|
|
require.Equal(t, true, ok) |
|
|
|
defer p1.close() |
|
|
|
defer p1.close() |
|
|
|
|
|
|
|
|
|
|
|
time.Sleep(1 * time.Second) |
|
|
|
|
|
|
|
|
|
|
|
|
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
cnt1, err := newContainer("ffmpeg", "source", []string{ |
|
|
|
"-re", |
|
|
|
"-re", |
|
|
|
"-stream_loop", "-1", |
|
|
|
"-stream_loop", "-1", |
|
|
|
|