cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

modify workerRequest

Browse Source
This commit is contained in:
ocean 2020-07-27 14:21:29 +08:00
parent ed2e57dde6
commit 7aa1ccf726
1 changed files with 3 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
sched.go
View File

@ -122,6 +122,7 @@ type workerRequest struct {
index int // The index of the item in the heap. index int // The index of the item in the heap.
indexHeap int
ret chan<- workerResponse ret chan<- workerResponse
ctx context.Context ctx context.Context
} }
@ -250,6 +251,7 @@ func (sh *scheduler) trySched() {
task := (*sh.schedQueue)[sqi] task := (*sh.schedQueue)[sqi]
needRes := ResourceTable[task.taskType][sh.spt] needRes := ResourceTable[task.taskType][sh.spt]
task.indexHeap = sqi
for wnd, windowRequest := range sh.openWindows { for wnd, windowRequest := range sh.openWindows {
worker := sh.workers[windowRequest.worker] worker := sh.workers[windowRequest.worker]
@ -312,7 +314,7 @@ func (sh *scheduler) trySched() {
needRes := ResourceTable[task.taskType][sh.spt] needRes := ResourceTable[task.taskType][sh.spt]
selectedWindow := -1 selectedWindow := -1
for _, wnd := range acceptableWindows[sqi+scheduled] { for _, wnd := range acceptableWindows[task.indexHeap] {
wid := sh.openWindows[wnd].worker wid := sh.openWindows[wnd].worker
wr := sh.workers[wid].info.Resources wr := sh.workers[wid].info.Resources