- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 12 for IsCgroup2UnifiedMode (0.32 sec)
-
pkg/kubelet/kuberuntime/kuberuntime_container_linux.go
// the cgroup version for unit tests by assigning a new mocked function into it. Without it, // the cgroup version would solely depend on the environment running the test. var isCgroup2UnifiedMode = func() bool { return libcontainercgroups.IsCgroup2UnifiedMode() } var ( swapControllerAvailability bool swapControllerAvailabilityOnce sync.Once )
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed May 29 22:40:29 UTC 2024 - 17.2K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux_test.go
assert.NoError(t, err) if cgroups.IsCgroup2UnifiedMode() { assert.True(t, f.cpuHardcapping, "cpu hardcapping is expected to be enabled") } else { assert.False(t, f.cpuHardcapping, "cpu hardcapping is expected to be disabled") } } func TestCgroupMountValidationMemoryMissing(t *testing.T) { if cgroups.IsCgroup2UnifiedMode() { t.Skip("skipping cgroup v1 test on a cgroup v2 system") }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Mar 07 08:12:16 UTC 2024 - 9.7K bytes - Viewed (0) -
cmd/kubelet/app/server_linux.go
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Apr 26 09:04:06 UTC 2022 - 1.4K bytes - Viewed (0) -
cmd/kubelet/app/server_unsupported.go
limitations under the License. */ package app import "errors" func watchForLockfileContention(path string, done chan struct{}) error { return errors.New("kubelet unsupported in this build") } func isCgroup2UnifiedMode() bool { return false
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Aug 24 19:47:49 UTC 2021 - 820 bytes - Viewed (0) -
pkg/kubelet/cm/cgroup_manager_linux.go
if libcontainercgroups.IsCgroup2UnifiedMode() { return getCgroupv2CpuConfig(cgroupPath) } else { return getCgroupv1CpuConfig(cgroupPath) } } func getCgroupMemoryConfig(cgroupPath string) (*ResourceConfig, error) { memLimitFile := "memory.limit_in_bytes" if libcontainercgroups.IsCgroup2UnifiedMode() { memLimitFile = "memory.max" }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 13:02:15 UTC 2023 - 26.5K bytes - Viewed (0) -
pkg/kubelet/eviction/threshold_notifier_linux.go
// For now, let's return a fake "disabled" cgroup notifier on cgroupv2. // https://github.com/kubernetes/kubernetes/issues/106331 if libcontainercgroups.IsCgroup2UnifiedMode() { return &disabledThresholdNotifier{}, nil } var watchfd, eventfd, epfd, controlfd int var err error watchfd, err = unix.Open(fmt.Sprintf("%s/%s", path, attribute), unix.O_RDONLY|unix.O_CLOEXEC, 0)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 01 21:59:54 UTC 2022 - 5.8K bytes - Viewed (0) -
pkg/kubelet/cm/helpers_linux.go
MountPoints: mountPoints, }, nil } // GetCgroupSubsystems returns information about the mounted cgroup subsystems func GetCgroupSubsystems() (*CgroupSubsystems, error) { if libcontainercgroups.IsCgroup2UnifiedMode() { return getCgroupSubsystemsV2() } return getCgroupSubsystemsV1() } // getCgroupProcs takes a cgroup directory name as an argument
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jul 14 11:52:28 UTC 2023 - 9.8K bytes - Viewed (0) -
pkg/kubelet/cm/pod_container_manager_linux.go
// check if container already exist alreadyExists := m.Exists(pod) if !alreadyExists { enforceMemoryQoS := false if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.MemoryQoS) && libcontainercgroups.IsCgroup2UnifiedMode() { enforceMemoryQoS = true } // Create the pod container podContainerName, _ := m.GetPodContainerName(pod) containerConfig := &CgroupConfig{ Name: podContainerName,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 14 16:38:36 UTC 2023 - 12.5K bytes - Viewed (0) -
pkg/kubelet/cm/qos_container_manager_linux.go
return err } // update the qos level cgrougs v2 settings of memory qos if feature enabled if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.MemoryQoS) && libcontainercgroups.IsCgroup2UnifiedMode() { m.setMemoryQoS(qosConfigs) } if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.QOSReserved) { for resource, percentReserve := range m.qosReserved { switch resource {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 11 20:42:59 UTC 2024 - 13.3K bytes - Viewed (0) -
pkg/kubelet/cm/container_manager_linux.go
) var ( cpuMountPoint string f features ) mountPoints, err := mountUtil.List() if err != nil { return f, fmt.Errorf("%s - %v", localErr, err) } if cgroups.IsCgroup2UnifiedMode() { f.cpuHardcapping = true return f, nil } expectedCgroups := sets.New("cpu", "cpuacct", "cpuset", "memory") for _, mountPoint := range mountPoints { if mountPoint.Type == cgroupMountType {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue May 21 10:18:16 UTC 2024 - 35.1K bytes - Viewed (0)