github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-08-05 18:24:07 +00:00
Code Issues Projects Releases Wiki Activity

Use pod level hugepage limits for cgroup when unset in container

Browse Source
This commit is contained in:
Kevin Torres 2025-02-19 19:54:13 +00:00
parent e3f4c6e62a
commit 51db93c3fb
1 changed files with 34 additions and 18 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

52
pkg/kubelet/kuberuntime/kuberuntime_container_linux.go
View File

@ -143,7 +143,7 @@ func (m *kubeGenericRuntimeManager) generateLinuxContainerResources(pod *v1.Pod,
lcr.OomScoreAdj = int64(qos.GetContainerOOMScoreAdjust(pod, container, lcr.OomScoreAdj = int64(qos.GetContainerOOMScoreAdjust(pod, container,
int64(m.machineInfo.MemoryCapacity))) int64(m.machineInfo.MemoryCapacity)))
lcr.HugepageLimits = GetHugepageLimitsFromResources(container.Resources) lcr.HugepageLimits = GetHugepageLimitsFromResources(pod, container.Resources)
// Configure swap for the container // Configure swap for the container
m.configureContainerSwapResources(lcr, pod, container) m.configureContainerSwapResources(lcr, pod, container)
@ -300,7 +300,7 @@ func (m *kubeGenericRuntimeManager) calculateLinuxResources(cpuRequest, cpuLimit
} }
// GetHugepageLimitsFromResources returns limits of each hugepages from resources. // GetHugepageLimitsFromResources returns limits of each hugepages from resources.
func GetHugepageLimitsFromResources(resources v1.ResourceRequirements) []*runtimeapi.HugepageLimit { func GetHugepageLimitsFromResources(pod *v1.Pod, resources v1.ResourceRequirements) []*runtimeapi.HugepageLimit {
var hugepageLimits []*runtimeapi.HugepageLimit var hugepageLimits []*runtimeapi.HugepageLimit
// For each page size, limit to 0. // For each page size, limit to 0.
@ -312,23 +312,20 @@ func GetHugepageLimitsFromResources(resources v1.ResourceRequirements) []*runtim
} }
requiredHugepageLimits := map[string]uint64{} requiredHugepageLimits := map[string]uint64{}
// When hugepage limits are specified at pod level, the container limit will
// match the pod level limit, however if the container also specifies,
// its limit will have precedence over the pod level limit
if utilfeature.DefaultFeatureGate.Enabled(kubefeatures.PodLevelResources) && resourcehelper.IsPodLevelResourcesSet(pod) {
for limitName, limitAmount := range pod.Spec.Resources.Limits {
readAndDefineRequiredHugepageLimit(requiredHugepageLimits, limitName, limitAmount)
}
}
// If the container and the pod specify, the container will have precedence,
// overriding the pod level limit
for resourceObj, amountObj := range resources.Limits { for resourceObj, amountObj := range resources.Limits {
if !v1helper.IsHugePageResourceName(resourceObj) { readAndDefineRequiredHugepageLimit(requiredHugepageLimits, resourceObj, amountObj)
continue
}
pageSize, err := v1helper.HugePageSizeFromResourceName(resourceObj)
if err != nil {
klog.InfoS("Failed to get hugepage size from resource", "object", resourceObj, "err", err)
continue
}
sizeString, err := v1helper.HugePageUnitSizeFromByteSize(pageSize.Value())
if err != nil {
klog.InfoS("Size is invalid", "object", resourceObj, "err", err)
continue
}
requiredHugepageLimits[sizeString] = uint64(amountObj.Value())
} }
for _, hugepageLimit := range hugepageLimits { for _, hugepageLimit := range hugepageLimits {
@ -340,6 +337,25 @@ func GetHugepageLimitsFromResources(resources v1.ResourceRequirements) []*runtim
return hugepageLimits return hugepageLimits
} }
func readAndDefineRequiredHugepageLimit(requiredHugepageLimits map[string]uint64, resourceObj v1.ResourceName, amountObj resource.Quantity) {
if !v1helper.IsHugePageResourceName(resourceObj) {
return
}
pageSize, err := v1helper.HugePageSizeFromResourceName(resourceObj)
if err != nil {
klog.InfoS("Failed to get hugepage size from resource", "object", resourceObj, "err", err)
return
}
sizeString, err := v1helper.HugePageUnitSizeFromByteSize(pageSize.Value())
if err != nil {
klog.InfoS("Size is invalid", "object", resourceObj, "err", err)
return
}
requiredHugepageLimits[sizeString] = uint64(amountObj.Value())
}
func toKubeContainerResources(statusResources *runtimeapi.ContainerResources) *kubecontainer.ContainerResources { func toKubeContainerResources(statusResources *runtimeapi.ContainerResources) *kubecontainer.ContainerResources {
var cStatusResources *kubecontainer.ContainerResources var cStatusResources *kubecontainer.ContainerResources
runtimeStatusResources := statusResources.GetLinux() runtimeStatusResources := statusResources.GetLinux()