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

cleanup: remove isUnschedPodUpdateIncluded variable

Browse Source
This commit is contained in:
Kensei Nakada 2024-10-09 18:52:11 +09:00
parent 4f853fceb9
commit 6624541893
1 changed files with 3 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
pkg/scheduler/eventhandlers.go
View File

@ -142,17 +142,12 @@ func (sched *Scheduler) updatePodInSchedulingQueue(oldObj, newObj interface{}) {
return
}
isUnschedPodUpdateIncluded := false
defer metrics.EventHandlingLatency.WithLabelValues(framework.UnscheduledPodUpdate.Label).Observe(metrics.SinceInSeconds(start))
for _, evt := range framework.PodSchedulingPropertiesChange(newPod, oldPod) {
defer metrics.EventHandlingLatency.WithLabelValues(evt.Label).Observe(metrics.SinceInSeconds(start))
if evt.Label == framework.UnscheduledPodUpdate.Label {
isUnschedPodUpdateIncluded = true
if evt.Label != framework.UnscheduledPodUpdate.Label {
defer metrics.EventHandlingLatency.WithLabelValues(evt.Label).Observe(metrics.SinceInSeconds(start))
}
}
if !isUnschedPodUpdateIncluded {
// make sure we always record the latency with UnscheduledPodUpdate label.
defer metrics.EventHandlingLatency.WithLabelValues(framework.UnscheduledPodUpdate.Label).Observe(metrics.SinceInSeconds(start))
}
isAssumed, err := sched.Cache.IsAssumedPod(newPod)
if err != nil {