- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for applyOOMScoreAdj (0.13 sec)
-
pkg/util/oom/oom_linux.go
"strconv" "time" cmutil "k8s.io/kubernetes/pkg/kubelet/cm/util" "k8s.io/klog/v2" ) func NewOOMAdjuster() *OOMAdjuster { oomAdjuster := &OOMAdjuster{ pidLister: getPids, ApplyOOMScoreAdj: applyOOMScoreAdj, } oomAdjuster.ApplyOOMScoreAdjContainer = oomAdjuster.applyOOMScoreAdjContainer return oomAdjuster } func getPids(cgroupName string) ([]int, error) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Oct 20 07:13:28 UTC 2022 - 4K bytes - Viewed (0) -
pkg/util/oom/oom_linux_test.go
func applyOOMScoreAdjContainerTester(pidListSequence [][]int, maxTries int, appliedPids []int, expectedError bool, t *testing.T) { pidOOMs := make(map[int]bool) // Mock ApplyOOMScoreAdj and pidLister. oomAdjuster := NewOOMAdjuster() oomAdjuster.ApplyOOMScoreAdj = func(pid int, oomScoreAdj int) error { pidOOMs[pid] = true return nil } oomAdjuster.pidLister = sequenceToPidLister(pidListSequence)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 3.3K bytes - Viewed (0) -
pkg/util/oom/oom_unsupported.go
*/ package oom import ( "errors" ) var unsupportedErr = errors.New("setting OOM scores is unsupported in this build") func NewOOMAdjuster() *OOMAdjuster { return &OOMAdjuster{ ApplyOOMScoreAdj: unsupportedApplyOOMScoreAdj, ApplyOOMScoreAdjContainer: unsupportedApplyOOMScoreAdjContainer, } } func unsupportedApplyOOMScoreAdj(pid int, oomScoreAdj int) error { return unsupportedErr }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 1.1K bytes - Viewed (0)