github/kubernetes
1
0
Fork 0
mirror of https://github.com/k3s-io/kubernetes.git synced 2025-09-14 05:36:12 +00:00
Code Issues Projects Releases Wiki Activity

scheduler: fast check when there is no conflicts

Browse Source
This commit is contained in:
Xiang Li
2015-12-09 11:45:56 -08:00
parent d2dfb4906f
commit a0e6d68026
1 changed files with 6 additions and 2 deletions
Download Patch File Download Diff File Expand all files Collapse all files

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

@@ -73,9 +73,13 @@ func (c *CachedNodeInfo) GetNodeInfo(id string) (*api.Node, error) {
} }
func isVolumeConflict(volume api.Volume, pod *api.Pod) bool { func isVolumeConflict(volume api.Volume, pod *api.Pod) bool {
// fast path if there is no conflict checking targets.
if volume.GCEPersistentDisk == nil && volume.AWSElasticBlockStore == nil && volume.RBD == nil {
return false
}
for _, existingVolume := range pod.Spec.Volumes { for _, existingVolume := range pod.Spec.Volumes {
// Same GCE Disk can be mounted as read-only by multiple pod simultaneously. // Same GCE disk mounted by multiple pods conflicts unless all pods mount it read-only.
// Or they conflicts
if volume.GCEPersistentDisk != nil && existingVolume.GCEPersistentDisk != nil { if volume.GCEPersistentDisk != nil && existingVolume.GCEPersistentDisk != nil {
disk, existingDisk := volume.GCEPersistentDisk, existingVolume.GCEPersistentDisk disk, existingDisk := volume.GCEPersistentDisk, existingVolume.GCEPersistentDisk
if disk.PDName == existingDisk.PDName && !(disk.ReadOnly && existingDisk.ReadOnly) { if disk.PDName == existingDisk.PDName && !(disk.ReadOnly && existingDisk.ReadOnly) {