github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-07-27 13:37:30 +00:00
Code Issues Projects Releases Wiki Activity

haveSame is suboptimal, fix it as well as the name

Browse Source
This commit is contained in:
Yongkun Anfernee Gui 2017-10-27 16:32:25 -07:00
parent 68b9fa2b89
commit 5d268eb1d3
1 changed files with 6 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
plugin/pkg/scheduler/algorithm/predicates/predicates.go
View File

@ -165,7 +165,7 @@ func isVolumeConflict(volume v1.Volume, pod *v1.Pod) bool {
// two RBDs images are the same if they share the same Ceph monitor, are in the same RADOS Pool, and have the same image name // two RBDs images are the same if they share the same Ceph monitor, are in the same RADOS Pool, and have the same image name
// only one read-write mount is permitted for the same RBD image. // only one read-write mount is permitted for the same RBD image.
// same RBD image mounted by multiple Pods conflicts unless all Pods mount the image read-only // same RBD image mounted by multiple Pods conflicts unless all Pods mount the image read-only
if haveSame(mon, emon) && pool == epool && image == eimage && !(volume.RBD.ReadOnly && existingVolume.RBD.ReadOnly) { if haveOverlap(mon, emon) && pool == epool && image == eimage && !(volume.RBD.ReadOnly && existingVolume.RBD.ReadOnly) {
return true return true
} }
} }
@ -911,20 +911,18 @@ func PodFitsHostPorts(pod *v1.Pod, meta algorithm.PredicateMetadata, nodeInfo *s
} }
// search two arrays and return true if they have at least one common element; return false otherwise // search two arrays and return true if they have at least one common element; return false otherwise
func haveSame(a1, a2 []string) bool { func haveOverlap(a1, a2 []string) bool {
m := map[string]int{} m := map[string]bool{}
for _, val := range a1 { for _, val := range a1 {
m[val] = 1 m[val] = true
} }
for _, val := range a2 { for _, val := range a2 {
m[val] = m[val] + 1 if _, ok := m[val]; ok {
}
for _, val := range m {
if val > 1 {
return true return true
} }
} }
return false return false
} }