forked from kubernetes/kubernetes
-
Notifications
You must be signed in to change notification settings - Fork 99
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
UPSTREAM: <carry>: add management support to kubelet
UPSTREAM: <carry>: management workloads enhancement 741 UPSTREAM: <carry>: lower verbosity of managed workloads logging Support for managed workloads was introduced by PR#627. However, the the CPU manager reconcile loop now seems to flood kubelet log with "reconcileState: skipping pod; pod is managed" warnings. Lower the verbosity of these log messages.
- Loading branch information
Showing
9 changed files
with
505 additions
and
1 deletion.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,30 @@ | ||
| package managed | ||
|
|
||
| const ( | ||
| // These limits are defined in the kernel: | ||
| // https://github.com/torvalds/linux/blob/0bddd227f3dc55975e2b8dfa7fc6f959b062a2c7/kernel/sched/sched.h#L427-L428 | ||
| MinShares = 2 | ||
| MaxShares = 262144 | ||
|
|
||
| SharesPerCPU = 1024 | ||
| MilliCPUToCPU = 1000 | ||
| ) | ||
|
|
||
| // MilliCPUToShares converts the milliCPU to CFS shares. | ||
| func MilliCPUToShares(milliCPU int64) uint64 { | ||
| if milliCPU == 0 { | ||
| // Docker converts zero milliCPU to unset, which maps to kernel default | ||
| // for unset: 1024. Return 2 here to really match kernel default for | ||
| // zero milliCPU. | ||
| return MinShares | ||
| } | ||
| // Conceptually (milliCPU / milliCPUToCPU) * sharesPerCPU, but factored to improve rounding. | ||
| shares := (milliCPU * SharesPerCPU) / MilliCPUToCPU | ||
| if shares < MinShares { | ||
| return MinShares | ||
| } | ||
| if shares > MaxShares { | ||
| return MaxShares | ||
| } | ||
| return uint64(shares) | ||
| } |
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,141 @@ | ||
| /* | ||
| Copyright 2021 The Kubernetes Authors. | ||
| Licensed under the Apache License, Version 2.0 (the "License"); | ||
| you may not use this file except in compliance with the License. | ||
| You may obtain a copy of the License at | ||
| http://www.apache.org/licenses/LICENSE-2.0 | ||
| Unless required by applicable law or agreed to in writing, software | ||
| distributed under the License is distributed on an "AS IS" BASIS, | ||
| WITHOUT WARRANTIES OR CONDITIONS OF ANY KIND, either express or implied. | ||
| See the License for the specific language governing permissions and | ||
| limitations under the License. | ||
| */ | ||
|
|
||
| package managed | ||
|
|
||
| import ( | ||
| "encoding/json" | ||
| "fmt" | ||
| "os" | ||
| "strings" | ||
|
|
||
| v1 "k8s.io/api/core/v1" | ||
| "k8s.io/apimachinery/pkg/api/resource" | ||
| ) | ||
|
|
||
| var ( | ||
| pinnedManagementEnabled bool | ||
| pinnedManagementFilename = "/etc/kubernetes/openshift-workload-pinning" | ||
| WorkloadsAnnotationPrefix = "target.workload.openshift.io/" | ||
| WorkloadsCapacitySuffix = "workload.openshift.io/cores" | ||
| ContainerAnnotationFormat = "resources.workload.openshift.io/%v" | ||
| ) | ||
|
|
||
| type WorkloadContainerAnnotation struct { | ||
| CpuShares uint64 `json:"cpushares"` | ||
| } | ||
|
|
||
| func NewWorkloadContainerAnnotation(cpushares uint64) WorkloadContainerAnnotation { | ||
| return WorkloadContainerAnnotation{ | ||
| CpuShares: cpushares, | ||
| } | ||
| } | ||
|
|
||
| func (w WorkloadContainerAnnotation) Serialize() ([]byte, error) { | ||
| return json.Marshal(w) | ||
| } | ||
|
|
||
| func init() { | ||
| readEnablementFile() | ||
| } | ||
|
|
||
| func readEnablementFile() { | ||
| if _, err := os.Stat(pinnedManagementFilename); err == nil { | ||
| pinnedManagementEnabled = true | ||
| } | ||
| } | ||
|
|
||
| func IsEnabled() bool { | ||
| return pinnedManagementEnabled | ||
| } | ||
|
|
||
| /// IsPodManaged returns true and the name of the workload if enabled. | ||
| /// returns true, workload name, and the annotation payload. | ||
| func IsPodManaged(pod *v1.Pod) (bool, string, string) { | ||
| if pod.ObjectMeta.Annotations == nil { | ||
| return false, "", "" | ||
| } | ||
| for annotation, value := range pod.ObjectMeta.Annotations { | ||
| if strings.HasPrefix(annotation, WorkloadsAnnotationPrefix) { | ||
| return true, strings.TrimPrefix(annotation, WorkloadsAnnotationPrefix), value | ||
| } | ||
| } | ||
| return false, "", "" | ||
| } | ||
|
|
||
| // ModifyStaticPodForPinnedManagement will modify a pod for pod management | ||
| func ModifyStaticPodForPinnedManagement(pod *v1.Pod) (*v1.Pod, string, error) { | ||
| pod = pod.DeepCopy() | ||
| enabled, workloadName, value := IsPodManaged(pod) | ||
| if !enabled { | ||
| return nil, "", nil | ||
| } | ||
| if pod.Annotations == nil { | ||
| pod.Annotations = make(map[string]string) | ||
| } | ||
| pod.Annotations[fmt.Sprintf("%v%v", WorkloadsAnnotationPrefix, workloadName)] = value | ||
| if err := updateContainers(workloadName, pod); err != nil { | ||
| return nil, "", err | ||
| } | ||
| return pod, workloadName, nil | ||
| } | ||
|
|
||
| func GenerateResourceName(workloadName string) v1.ResourceName { | ||
| return v1.ResourceName(fmt.Sprintf("%v.%v", workloadName, WorkloadsCapacitySuffix)) | ||
| } | ||
|
|
||
| func updateContainers(workloadName string, pod *v1.Pod) error { | ||
| updateContainer := func(container *v1.Container) error { | ||
| if container.Resources.Requests == nil { | ||
| return fmt.Errorf("managed container %v does not have Resource.Requests", container.Name) | ||
| } | ||
| if _, ok := container.Resources.Requests[v1.ResourceCPU]; !ok { | ||
| return fmt.Errorf("managed container %v does not have cpu requests", container.Name) | ||
| } | ||
| if _, ok := container.Resources.Requests[v1.ResourceMemory]; !ok { | ||
| return fmt.Errorf("managed container %v does not have memory requests", container.Name) | ||
| } | ||
| if container.Resources.Limits == nil { | ||
| container.Resources.Limits = v1.ResourceList{} | ||
| } | ||
| cpuRequest := container.Resources.Requests[v1.ResourceCPU] | ||
| cpuRequestInMilli := cpuRequest.MilliValue() | ||
|
|
||
| containerAnnotation := NewWorkloadContainerAnnotation(MilliCPUToShares(cpuRequestInMilli)) | ||
| jsonAnnotation, _ := containerAnnotation.Serialize() | ||
| containerNameKey := fmt.Sprintf(ContainerAnnotationFormat, container.Name) | ||
|
|
||
| newCPURequest := resource.NewMilliQuantity(cpuRequestInMilli*1000, cpuRequest.Format) | ||
|
|
||
| pod.Annotations[containerNameKey] = string(jsonAnnotation) | ||
| container.Resources.Requests[GenerateResourceName(workloadName)] = *newCPURequest | ||
| container.Resources.Limits[GenerateResourceName(workloadName)] = *newCPURequest | ||
|
|
||
| delete(container.Resources.Requests, v1.ResourceCPU) | ||
| return nil | ||
| } | ||
| for idx := range pod.Spec.Containers { | ||
| if err := updateContainer(&pod.Spec.Containers[idx]); err != nil { | ||
| return err | ||
| } | ||
| } | ||
| for idx := range pod.Spec.InitContainers { | ||
| if err := updateContainer(&pod.Spec.InitContainers[idx]); err != nil { | ||
| return err | ||
| } | ||
| } | ||
| return nil | ||
| } |
Oops, something went wrong.