Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for ToCgroupfs (0.14 sec)

  1. pkg/kubelet/cm/pod_container_manager_linux_test.go

    			// Give the right cgroup structure based on whether systemd is enabled.
    			var name string
    			if cgroupDriver == "systemd" {
    				name = testCase.input.ToSystemd()
    			} else {
    				name = testCase.input.ToCgroupfs()
    			}
    			// check if this is a pod or not with the literal cgroupfs input
    			result, resultUID := pcm.IsPodCgroup(name)
    			if result != testCase.expectedResult {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Mon Aug 08 13:06:38 UTC 2022
    - 8.9K bytes
    - Viewed (0)
  2. pkg/kubelet/cm/cgroup_manager_unsupported.go

    }
    
    func (cgroupName CgroupName) ToSystemd() string {
    	return ""
    }
    
    func ParseSystemdToCgroupName(name string) CgroupName {
    	return nil
    }
    
    func (cgroupName CgroupName) ToCgroupfs() string {
    	return ""
    }
    
    func ParseCgroupfsToCgroupName(name string) CgroupName {
    	return nil
    }
    
    func IsSystemdStyleName(name string) bool {
    	return false
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 18:21:21 UTC 2023
    - 2.8K bytes
    - Viewed (0)
  3. pkg/kubelet/cm/cgroup_manager_linux_test.go

    			expected: "/",
    		},
    		{
    			input:    NewCgroupName(RootCgroupName, "Burstable"),
    			expected: "/Burstable",
    		},
    	}
    	for _, testCase := range testCases {
    		if actual := testCase.input.ToCgroupfs(); actual != testCase.expected {
    			t.Errorf("Unexpected result, input: %v, expected: %v, actual: %v", testCase.input, testCase.expected, actual)
    		}
    	}
    }
    
    func TestParseSystemdToCgroupName(t *testing.T) {
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Feb 24 18:21:21 UTC 2023
    - 6.1K bytes
    - Viewed (0)
  4. pkg/kubelet/cm/cgroup_manager_linux.go

    	result := []string{}
    	for _, part := range parts {
    		result = append(result, unescapeSystemdCgroupName(part))
    	}
    	return CgroupName(result)
    }
    
    func (cgroupName CgroupName) ToCgroupfs() string {
    	return "/" + path.Join(cgroupName...)
    }
    
    func ParseCgroupfsToCgroupName(name string) CgroupName {
    	components := strings.Split(strings.TrimPrefix(name, "/"), "/")
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Wed Sep 27 13:02:15 UTC 2023
    - 26.5K bytes
    - Viewed (0)
  5. pkg/kubelet/cm/helpers_linux.go

    		nodeAllocatableRoot = NewCgroupName(nodeAllocatableRoot, defaultNodeAllocatableCgroupName)
    	}
    	if cgroupDriver == "systemd" {
    		return nodeAllocatableRoot.ToSystemd()
    	}
    	return nodeAllocatableRoot.ToCgroupfs()
    }
    
    // GetKubeletContainer returns the cgroup the kubelet will use
    func GetKubeletContainer(kubeletCgroups string) (string, error) {
    	if kubeletCgroups == "" {
    		cont, err := getContainer(os.Getpid())
    Registered: Sat Jun 15 01:39:40 UTC 2024
    - Last Modified: Fri Jul 14 11:52:28 UTC 2023
    - 9.8K bytes
    - Viewed (0)
Back to top