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

update

Browse Source
This commit is contained in:
Newnius
2020-05-04 00:34:26 +08:00
parent 73cbbb5509
commit f7077e9efd
1 changed files with 2 additions and 5 deletions
Download Patch File Download Diff File Expand all files Collapse all files

7
src/scheduler_fair.go
View File

@@ -530,9 +530,6 @@ func (scheduler *SchedulerFair) AcquireResource(job Job, task Task, nodes []Node
log.Info("Unlock ", segID) log.Info("Unlock ", segID)
lock.Unlock() lock.Unlock()
} }
pool.pools[0].Lock.Lock()
pool.pools[0].Lock.Unlock()
log.Info("all locks released")
go func(res NodeStatus) { go func(res NodeStatus) {
if len(res.Status) == 0 { if len(res.Status) == 0 {
@@ -744,7 +741,7 @@ func (scheduler *SchedulerFair) UpdateNextQueue() {
start := pool.pools[0].Next start := pool.pools[0].Next
for cur := start; ; { for cur := start; ; {
log.Info(cur.ID) log.Info(cur.ID)
cur.Lock.Lock() //cur.Lock.Lock()
for _, node := range cur.Nodes { for _, node := range cur.Nodes {
CPU += float64(node.NumCPU) CPU += float64(node.NumCPU)
Memory += float64(node.MemTotal) Memory += float64(node.MemTotal)
@@ -753,7 +750,7 @@ func (scheduler *SchedulerFair) UpdateNextQueue() {
MemoryGPU += float64(card.MemoryTotal) MemoryGPU += float64(card.MemoryTotal)
} }
} }
cur.Lock.Unlock() //cur.Lock.Unlock()
cur = cur.Next cur = cur.Next
if cur == start { if cur == start {
break break