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

Merge pull request #79804 from yqwang-ms/yqwang/fix-bind-interest

Browse Source 
Extender bind should respect IsInterested
This commit is contained in:
Kubernetes Prow Robot 2019-08-15 19:16:34 -07:00 committed by GitHub
commit a56e86a405
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 4 additions and 9 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

13
pkg/scheduler/factory/factory.go
View File

@ -443,17 +443,12 @@ func (c *Configurator) CreateFromKeys(predicateKeys, priorityKeys sets.String, e
// getBinderFunc returns a func which returns an extender that supports bind or a default binder based on the given pod. // getBinderFunc returns a func which returns an extender that supports bind or a default binder based on the given pod.
func getBinderFunc(client clientset.Interface, extenders []algorithm.SchedulerExtender) func(pod *v1.Pod) Binder { func getBinderFunc(client clientset.Interface, extenders []algorithm.SchedulerExtender) func(pod *v1.Pod) Binder {
var extenderBinder algorithm.SchedulerExtender
for i := range extenders {
if extenders[i].IsBinder() {
extenderBinder = extenders[i]
break
}
}
defaultBinder := &binder{client} defaultBinder := &binder{client}
return func(pod *v1.Pod) Binder { return func(pod *v1.Pod) Binder {
if extenderBinder != nil && extenderBinder.IsInterested(pod) { for _, extender := range extenders {
return extenderBinder if extender.IsBinder() && extender.IsInterested(pod) {
return extender
}
} }
return defaultBinder return defaultBinder
} }