lywsvip/cloudpods
1
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-06-09 07:54:28 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix: scheduler choose backend incorrect (#22)

Browse Source
This commit is contained in:
Zexi Li
2019-03-27 14:35:20 +08:00
committed by GitHub
parent cb22d1126b
commit b9cc29f4f1
1 changed files with 14 additions and 9 deletions
Download Patch File Download Diff File Expand all files Collapse all files

23
pkg/scheduler/algorithm/predicates/disk_schedtag_predicate.go
View File

@@ -278,15 +278,20 @@ func (p *DiskSchedtagPredicate) selectStorage(d *computeapi.DiskConfig, storages
}
func (p *DiskSchedtagPredicate) GetLeastUsedStorage(storages []*api.CandidateStorage, backend string) *api.CandidateStorage {
//var backends []string
//if backend == computeapi.STORAGE_LOCAL {
//backends = []string{computeapi.STORAGE_NAS, computeapi.STORAGE_LOCAL}
//} else if len(backend) > 0 {
//backends = []string{backend}
//} else {
//backends = []string{}
//}
return p.getLeastUsedStorage(storages)
backendStorages := make([]*api.CandidateStorage, 0)
if backend != "" {
for _, s := range storages {
if s.StorageType == backend {
backendStorages = append(backendStorages, s)
}
}
} else {
backendStorages = storages
}
if len(backendStorages) == 0 {
backendStorages = storages
}
return p.getLeastUsedStorage(backendStorages)
}
func (p *DiskSchedtagPredicate) getLeastUsedStorage(storages []*api.CandidateStorage) *api.CandidateStorage {