apps/core
1
0
Fork 0
mirror of https://github.com/datarhei/core.git synced 2025-12-24 13:07:56 +08:00
Code Issues Packages Projects Releases Wiki Activity

Fix tests

Browse Source
This commit is contained in:
Ingo Oppermann
2025-07-17 17:09:25 +02:00
parent 8d2f0b2c16
commit ea108a011f
1 changed files with 5 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

10
restream/core_test.go
View File

@@ -988,15 +988,15 @@ func TestTeeAddressReference(t *testing.T) {
r := rs.(*restream)
task, ok := r.tasks.LoadAndRLock(app.ProcessID{ID: "process2"})
task, ok := r.tasks.LoadUnsafe(app.ProcessID{ID: "process2"})
require.True(t, ok)
require.Equal(t, "http://example.com/live.m3u8", task.config.Input[0].Address)
task, ok = r.tasks.LoadAndRLock(app.ProcessID{ID: "process3"})
task, ok = r.tasks.LoadUnsafe(app.ProcessID{ID: "process3"})
require.True(t, ok)
require.Equal(t, "http://example.com/live.m3u8", task.config.Input[0].Address)
task, ok = r.tasks.LoadAndRLock(app.ProcessID{ID: "process4"})
task, ok = r.tasks.LoadUnsafe(app.ProcessID{ID: "process4"})
require.True(t, ok)
require.Equal(t, "rtmp://example.com/live.stream?token=123", task.config.Input[0].Address)
}
@@ -1598,7 +1598,7 @@ func TestProcessReplacer(t *testing.T) {
LogPatterns: []string{},
}
task, ok := rs.tasks.LoadAndRLock(app.ProcessID{ID: "314159265359"})
task, ok := rs.tasks.LoadUnsafe(app.ProcessID{ID: "314159265359"})
require.True(t, ok)
require.Equal(t, process, task.config)
@@ -1692,7 +1692,7 @@ func TestProcessLimit(t *testing.T) {
rs := rsi.(*restream)
task, ok := rs.tasks.LoadAndRLock(app.ProcessID{ID: process.ID})
task, ok := rs.tasks.LoadUnsafe(app.ProcessID{ID: process.ID})
require.True(t, ok)
status := task.ffmpeg.Status()