YAO/YAO-scheduler
1
0
Fork 0
mirror of https://github.com/newnius/YAO-scheduler.git synced 2025-12-15 16:16:44 +00:00
Code Issues Releases Wiki Activity

update fair

Browse Source
This commit is contained in:
Newnius
2020-05-28 15:28:04 +08:00
parent f0c856f5e1
commit 01b8f0673e
1 changed files with 3 additions and 1 deletions
Download Patch File Download Diff File Expand all files Collapse all files

4
src/scheduler_fair.go
View File

@@ -134,6 +134,8 @@ func (scheduler *SchedulerFair) Start() {
} }
cnt, _ := scheduler.resourceAllocations[bestQueue] cnt, _ := scheduler.resourceAllocations[bestQueue]
cnt.NumberGPU += numberGPUtmp cnt.NumberGPU += numberGPUtmp
cnt.CPU += numberCPUtmp
cnt.Memory += Memorytmp
scheduler.resourceAllocationsMu.Unlock() scheduler.resourceAllocationsMu.Unlock()
scheduler.allocatingGPUMu.Lock() scheduler.allocatingGPUMu.Lock()
@@ -328,7 +330,7 @@ func (scheduler *SchedulerFair) UpdateQuota() {
availableCPU := pool.TotalCPU*1000 - usingCPU*1000 - allocatedCPU availableCPU := pool.TotalCPU*1000 - usingCPU*1000 - allocatedCPU
//availableMemory := pool.TotalMemory - usingMemory - allocatedMemory //availableMemory := pool.TotalMemory - usingMemory - allocatedMemory
/* <0 means some nodes exited */ /* <0 means some nodes exited */
log.Info(availableGPU) //log.Info(availableGPU)
if availableGPU <= 0 { if availableGPU <= 0 {
return return
} }