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

Minor improvements to scheduling queue

Browse Source
This commit is contained in:
Bobby (Babak) Salamat 2018-02-21 12:55:22 -08:00
parent ecc5eb67d9
commit 5a00c42848
1 changed files with 3 additions and 15 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
pkg/scheduler/core/scheduling_queue.go
View File

@ -484,29 +484,17 @@ var _ = UnschedulablePods(&UnschedulablePodsMap{})
// Add adds a pod to the unschedulable pods.
func (u *UnschedulablePodsMap) Add(pod *v1.Pod) {
podKey := u.keyFunc(pod)
if _, exists := u.pods[podKey]; !exists {
u.pods[podKey] = pod
}
u.pods[u.keyFunc(pod)] = pod
}
// Delete deletes a pod from the unschedulable pods.
func (u *UnschedulablePodsMap) Delete(pod *v1.Pod) {
podKey := u.keyFunc(pod)
if _, exists := u.pods[podKey]; exists {
delete(u.pods, podKey)
}
delete(u.pods, u.keyFunc(pod))
}
// Update updates a pod in the unschedulable pods.
func (u *UnschedulablePodsMap) Update(pod *v1.Pod) {
podKey := u.keyFunc(pod)
_, exists := u.pods[podKey]
if !exists {
u.Add(pod)
return
}
u.pods[podKey] = pod
u.Add(pod)
}
// Get returns the pod if a pod with the same key as the key of the given "pod"