From b52b1591763b95e86cc6012dc353f7fa95b23f49 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?=C5=81ukasz=20Magiera?= Date: Sun, 18 Feb 2024 20:04:02 +0100 Subject: [PATCH] lotus-provider: Apply the Proving.ParallelCheckLimit config to WdPost executor --- cmd/lotus-provider/deps/deps.go | 15 ++++++++------- provider/lpseal/task_submit_precommit.go | 1 - 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/cmd/lotus-provider/deps/deps.go b/cmd/lotus-provider/deps/deps.go index 74e7c91a4..43f95625e 100644 --- a/cmd/lotus-provider/deps/deps.go +++ b/cmd/lotus-provider/deps/deps.go @@ -7,12 +7,6 @@ import ( "encoding/base64" "errors" "fmt" - "net" - "net/http" - "os" - "regexp" - "strings" - "github.com/BurntSushi/toml" "github.com/gbrlsnchs/jwt/v3" ds "github.com/ipfs/go-datastore" @@ -20,6 +14,11 @@ import ( logging "github.com/ipfs/go-log/v2" "github.com/urfave/cli/v2" "golang.org/x/xerrors" + "net" + "net/http" + "os" + "regexp" + "strings" "github.com/filecoin-project/go-address" "github.com/filecoin-project/go-jsonrpc/auth" @@ -235,7 +234,9 @@ Get it with: jq .PrivateKey ~/.lotus-miner/keystore/MF2XI2BNNJ3XILLQOJUXMYLUMU`, // todo localWorker isn't the abstraction layer we want to use here, we probably want to go straight to ffiwrapper // maybe with a lotus-provider specific abstraction. LocalWorker does persistent call tracking which we probably // don't need (ehh.. maybe we do, the async callback system may actually work decently well with harmonytask) - deps.LW = sealer.NewLocalWorker(sealer.WorkerConfig{}, deps.Stor, deps.LocalStore, deps.Si, nil, wstates) + deps.LW = sealer.NewLocalWorker(sealer.WorkerConfig{ + MaxParallelChallengeReads: deps.Cfg.Proving.ParallelCheckLimit, + }, deps.Stor, deps.LocalStore, deps.Si, nil, wstates) } if deps.Maddrs == nil { deps.Maddrs = map[dtypes.MinerAddress]bool{} diff --git a/provider/lpseal/task_submit_precommit.go b/provider/lpseal/task_submit_precommit.go index 4200c2d3e..3c6ce7b6f 100644 --- a/provider/lpseal/task_submit_precommit.go +++ b/provider/lpseal/task_submit_precommit.go @@ -91,7 +91,6 @@ func (s *SubmitPrecommitTask) Do(taskID harmonytask.TaskID, stillOwned func() bo if err != nil { return false, xerrors.Errorf("parsing unsealed CID: %w", err) } - _ = unsealedCID params := miner.PreCommitSectorBatchParams2{}