github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-21 02:41:25 +00:00
Code Issues Projects Releases Wiki Activity

code cleanup: scheduler/framework use max function instead of if-condition in types.go

Browse Source
This commit is contained in:
BinacsLee 2021-04-21 17:40:35 +08:00
parent 43a32c14f5
commit 8f57233a3a
1 changed files with 4 additions and 13 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

17
pkg/scheduler/framework/types.go
View File

@ -554,25 +554,16 @@ func (r *Resource) SetMaxResource(rl v1.ResourceList) {
for rName, rQuantity := range rl { for rName, rQuantity := range rl {
switch rName { switch rName {
case v1.ResourceMemory: case v1.ResourceMemory:
if mem := rQuantity.Value(); mem > r.Memory { r.Memory = max(r.Memory, rQuantity.Value())
r.Memory = mem
}
case v1.ResourceCPU: case v1.ResourceCPU:
if cpu := rQuantity.MilliValue(); cpu > r.MilliCPU { r.MilliCPU = max(r.MilliCPU, rQuantity.MilliValue())
r.MilliCPU = cpu
}
case v1.ResourceEphemeralStorage: case v1.ResourceEphemeralStorage:
if utilfeature.DefaultFeatureGate.Enabled(features.LocalStorageCapacityIsolation) { if utilfeature.DefaultFeatureGate.Enabled(features.LocalStorageCapacityIsolation) {
if ephemeralStorage := rQuantity.Value(); ephemeralStorage > r.EphemeralStorage { r.EphemeralStorage = max(r.EphemeralStorage, rQuantity.Value())
r.EphemeralStorage = ephemeralStorage
}
} }
default: default:
if schedutil.IsScalarResourceName(rName) { if schedutil.IsScalarResourceName(rName) {
value := rQuantity.Value() r.SetScalar(rName, max(r.ScalarResources[rName], rQuantity.Value()))
if value > r.ScalarResources[rName] {
r.SetScalar(rName, value)
}
} }
} }
} }