Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for IsCgroup2UnifiedMode (0.18 sec)

  1. 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)
  2. cmd/kubelet/app/server_linux.go

    		case err = <-watcher.Error:
    			klog.ErrorS(err, "inotify watcher error")
    		}
    		close(done)
    		watcher.Close()
    	}()
    	return nil
    }
    
    func isCgroup2UnifiedMode() bool {
    	return libcontainercgroups.IsCgroup2UnifiedMode()
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Tue Apr 26 09:04:06 UTC 2022
    - 1.4K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/util/cgroups_linux.go

    )
    
    // GetPids gets pids of the desired cgroup
    // Forked from opencontainers/runc/libcontainer/cgroup/fs.Manager.GetPids()
    func GetPids(cgroupPath string) ([]int, error) {
    	dir := ""
    
    	if libcontainercgroups.IsCgroup2UnifiedMode() {
    		path, err := filepath.Rel("/", cgroupPath)
    		if err != nil {
    			return nil, err
    		}
    		dir = filepath.Join(CgroupRoot, path)
    	} else {
    		var err error
    		dir, err = getCgroupV1Path(cgroupPath)
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Thu Mar 12 07:50:19 UTC 2020
    - 2.9K bytes
    - Viewed (0)
  4. 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)
  5. 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)
Back to top