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

harmonytask: consider remaining tasks too

Browse Source
This commit is contained in:
Andrew Jackson (Ajax) 2023-08-15 19:44:33 -05:00
parent 225f093103
commit dfb029cb30
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

10
lib/harmony/harmonytask/taskTypeHandler.go
View File

@ -52,6 +52,7 @@ func (h *taskTypeHandler) AddTask(extra func(TaskID, *harmonydb.Tx) bool) {
} }
func (h *taskTypeHandler) considerWork(ids []TaskID) (workAccepted bool) { func (h *taskTypeHandler) considerWork(ids []TaskID) (workAccepted bool) {
top:
if len(ids) == 0 { if len(ids) == 0 {
return true // stop looking for takers return true // stop looking for takers
} }
@ -91,7 +92,14 @@ func (h *taskTypeHandler) considerWork(ids []TaskID) (workAccepted bool) {
} }
if ct == 0 { if ct == 0 {
log.Infow("did not accept task", "task_id", strconv.Itoa(int(*tID)), "reason", "already Taken") log.Infow("did not accept task", "task_id", strconv.Itoa(int(*tID)), "reason", "already Taken")
return false var tryAgain = make([]TaskID, 0, len(ids)-1)
for _, id := range ids {
if id != *tID {
tryAgain = append(tryAgain, id)
}
}
ids = tryAgain
goto top
} }
go func() { go func() {