Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 7 of 7 for IsCgroup2UnifiedMode (0.31 sec)

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. 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)
  6. 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)
  7. pkg/kubelet/kuberuntime/kuberuntime_container_linux_test.go

    	}
    }
    
    type CgroupVersion string
    
    const (
    	cgroupV1 CgroupVersion = "v1"
    	cgroupV2 CgroupVersion = "v2"
    )
    
    func setCgroupVersionDuringTest(version CgroupVersion) {
    	isCgroup2UnifiedMode = func() bool {
    		return version == cgroupV2
    	}
    }
    
    func setSwapControllerAvailableDuringTest(available bool) func() {
    	original := swapControllerAvailable
    	swapControllerAvailable = func() bool {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed May 29 22:40:29 UTC 2024
    - 41K bytes
    - Viewed (0)
Back to top