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

Fix tests

Browse Source
This commit is contained in:
Ingo Oppermann
2023-04-26 16:12:41 +02:00
parent d59158de03
commit 1e35d29371
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

8
restream/restream_test.go
View File

@@ -10,6 +10,7 @@ import (
"github.com/datarhei/core/v16/internal/testhelper" "github.com/datarhei/core/v16/internal/testhelper"
"github.com/datarhei/core/v16/io/fs" "github.com/datarhei/core/v16/io/fs"
"github.com/datarhei/core/v16/net" "github.com/datarhei/core/v16/net"
"github.com/datarhei/core/v16/psutil"
"github.com/datarhei/core/v16/restream/app" "github.com/datarhei/core/v16/restream/app"
rfs "github.com/datarhei/core/v16/restream/fs" rfs "github.com/datarhei/core/v16/restream/fs"
"github.com/datarhei/core/v16/restream/replace" "github.com/datarhei/core/v16/restream/replace"
@@ -1237,6 +1238,9 @@ func TestProcessLimit(t *testing.T) {
status := task.ffmpeg.Status() status := task.ffmpeg.Status()
require.Equal(t, float64(244), status.CPU.Limit) ncpu, err := psutil.CPUCounts(true)
require.Equal(t, uint64(42), status.Memory.Limit) require.NoError(t, err)
require.Equal(t, ncpu*process.LimitCPU, status.CPU.Limit)
require.Equal(t, process.LimitMemory, status.Memory.Limit)
} }