YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-06-07 14:21:55 +00:00
Code Issues Releases Wiki Activity

update fair

Browse Source
This commit is contained in:
Newnius 2020-05-28 17:53:17 +08:00
parent ad723641bc
commit fcd0ac52f0
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
src/scheduler_fair.go
View File

@ -394,7 +394,7 @@ func (scheduler *SchedulerFair) UpdateQuota() {
quota.CPU += (requests[queue].CPU * base) / requests[queue].NumberGPU quota.CPU += (requests[queue].CPU * base) / requests[queue].NumberGPU
availableCPU -= (requests[queue].CPU * base) / requests[queue].NumberGPU availableCPU -= (requests[queue].CPU * base) / requests[queue].NumberGPU
quota.Memory += (requests[queue].Memory * base) / requests[queue].NumberGPU / 1000 quota.Memory += ((requests[queue].Memory * base) / requests[queue].NumberGPU) / 1000
} }
if availableGPU > 0 { if availableGPU > 0 {
for _, queue := range candidates { for _, queue := range candidates {
@ -403,6 +403,8 @@ func (scheduler *SchedulerFair) UpdateQuota() {
} }
quota := scheduler.queuesQuota[queue] quota := scheduler.queuesQuota[queue]
quota.NumberGPU += availableGPU quota.NumberGPU += availableGPU
quota.CPU += (requests[queue].CPU * availableGPU) / requests[queue].NumberGPU
quota.Memory += ((requests[queue].Memory * availableGPU) / requests[queue].NumberGPU) / 1000
break break
} }
} }