opensource/cloudpods
3
0
Fork 0
mirror of https://github.com/yunionio/cloudpods.git synced 2026-09-24 16:03:43 +08:00
Code Issues Packages Projects Releases Wiki Activity

fix(scheduler): check capacity of disk_schedtag_predicate (#15336)

Browse Source 
* only check free_capacity when not migrating or non schared storage

* only check actual_free_capacity when storage is local
This commit is contained in:
Zexi Li
2022-11-10 11:42:38 +08:00
committed by GitHub
parent 7df7b672ab
commit af0dcee9e3
1 changed files with 10 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files
pkg/scheduler/algorithm/predicates/disk_schedtag_predicate.go
+10 -5
View File
@@ -150,13 +150,18 @@ func (p *DiskSchedtagPredicate) IsResourceFitInput(ctx context.Context, u *core.
if u.GetHypervisorDriver().DoScheduleStorageFilter() {
// free capacity check
if storage.FreeCapacity < int64(d.SizeMb) {
return &FailReason{
Reason: fmt.Sprintf("Storage %s free capacity %d < %d(request)", storage.Name, storage.FreeCapacity, d.SizeMb),
Type: StorageCapacity,
isMigrate := len(u.SchedData().HostId) > 0
if !isMigrate || !utils.IsInStringArray(storage.StorageType, computeapi.SHARED_STORAGE) {
if storage.FreeCapacity < int64(d.SizeMb) {
return &FailReason{
Reason: fmt.Sprintf("Storage %s free capacity %d < %d(request)", storage.Name, storage.FreeCapacity, d.SizeMb),
Type: StorageCapacity,
}
}
}
if storage.ActualFreeCapacity < int64(d.SizeMb) {
// only check ActualFreeCapacity when storage_type is local
if storage.StorageType == computeapi.STORAGE_LOCAL && storage.ActualFreeCapacity < int64(d.SizeMb) {
return &FailReason{
Reason: fmt.Sprintf("Storage %s actual free capacity %d < %d(request)", storage.Name, storage.ActualFreeCapacity, d.SizeMb),
Type: StorageCapacity,