fix(scheduler): clean expire cache before schedule

This commit is contained in:
Zexi Li
2020-11-25 21:50:14 +08:00
parent 69d712a1b4
commit c0da4cc524
2 changed files with 6 additions and 2 deletions
@@ -168,6 +168,7 @@ func (p *DiskSchedtagPredicate) DoSelect(
res []ISchedtagCandidateResource,
) []ISchedtagCandidateResource {
return p.GetUsedStorages(res, input.(*diskW).Backend)
}
func (p *DiskSchedtagPredicate) GetCandidateResourceSortScore(selectRes ISchedtagCandidateResource) int64 {
@@ -207,8 +208,8 @@ func (p *DiskSchedtagPredicate) GetUsedStorages(res []ISchedtagCandidateResource
} else {
backendStorages = storages
}
if len(backendStorages) == 0 {
/*if len(backendStorages) == 0 {
backendStorages = storages
}
}*/
return backendStorages
}