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

v1.27.0-a #10

Closed
jonathanface wants to merge 473 commits from v1.27.0-a into master
pull from: v1.27.0-a
merge into: cerc-io:master
Conversation 0 Commits 473 Files Changed 452 +6
1 changed files with 6 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files
Showing only changes of commit 3c4c286eeb - Show all commits

6
cmd/lotus-provider/tasks/tasks.go
View File

@ -71,6 +71,7 @@ func StartTasks(ctx context.Context, dependencies *deps.Deps) (*harmonytask.Task
slr = lpffi.NewSealCalls(stor, lstor, si) slr = lpffi.NewSealCalls(stor, lstor, si)
} }
// NOTE: Tasks with the LEAST priority are at the top
if cfg.Subsystems.EnableSealSDR { if cfg.Subsystems.EnableSealSDR {
sdrTask := lpseal.NewSDRTask(full, db, sp, slr, cfg.Subsystems.SealSDRMaxTasks) sdrTask := lpseal.NewSDRTask(full, db, sp, slr, cfg.Subsystems.SealSDRMaxTasks)
activeTasks = append(activeTasks, sdrTask) activeTasks = append(activeTasks, sdrTask)
@ -101,6 +102,11 @@ func StartTasks(ctx context.Context, dependencies *deps.Deps) (*harmonytask.Task
"miner_addresses", maddrs, "miner_addresses", maddrs,
"tasks", lo.Map(activeTasks, func(t harmonytask.TaskInterface, _ int) string { return t.TypeDetails().Name })) "tasks", lo.Map(activeTasks, func(t harmonytask.TaskInterface, _ int) string { return t.TypeDetails().Name }))
// harmony treats the first task as highest priority, so reverse the order
// (we could have just appended to this list in the reverse order, but defining
// tasks in pipeline order is more intuitive)
activeTasks = lo.Reverse(activeTasks)
ht, err := harmonytask.New(db, activeTasks, dependencies.ListenAddr) ht, err := harmonytask.New(db, activeTasks, dependencies.ListenAddr)
if err != nil { if err != nil {
return nil, err return nil, err