diff --git a/cmd/lotus-seal-worker/main.go b/cmd/lotus-seal-worker/main.go index 4bcd00c80..208d64eb5 100644 --- a/cmd/lotus-seal-worker/main.go +++ b/cmd/lotus-seal-worker/main.go @@ -4,6 +4,7 @@ import ( "os" "sync" + paramfetch "github.com/filecoin-project/go-paramfetch" "github.com/filecoin-project/go-sectorbuilder" "github.com/mitchellh/go-homedir" @@ -11,12 +12,13 @@ import ( "golang.org/x/xerrors" "gopkg.in/urfave/cli.v2" + manet "github.com/multiformats/go-multiaddr-net" + "github.com/filecoin-project/lotus/api" "github.com/filecoin-project/lotus/build" lcli "github.com/filecoin-project/lotus/cli" "github.com/filecoin-project/lotus/lib/lotuslog" "github.com/filecoin-project/lotus/node/repo" - manet "github.com/multiformats/go-multiaddr-net" ) var log = logging.Logger("main") @@ -132,6 +134,10 @@ var runCmd = &cli.Command{ return err } + if err := paramfetch.GetParams(build.ParametersJson(), ssize); err != nil { + return xerrors.Errorf("get params: %w", err) + } + sb, err := sectorbuilder.NewStandalone(§orbuilder.Config{ SectorSize: ssize, Miner: act, diff --git a/cmd/lotus-seal-worker/sub.go b/cmd/lotus-seal-worker/sub.go index e0b8b0705..0c2d233de 100644 --- a/cmd/lotus-seal-worker/sub.go +++ b/cmd/lotus-seal-worker/sub.go @@ -4,12 +4,10 @@ import ( "context" "net/http" - paramfetch "github.com/filecoin-project/go-paramfetch" "github.com/filecoin-project/go-sectorbuilder" "golang.org/x/xerrors" lapi "github.com/filecoin-project/lotus/api" - "github.com/filecoin-project/lotus/build" ) type worker struct { @@ -23,10 +21,6 @@ type worker struct { } func acceptJobs(ctx context.Context, api lapi.StorageMiner, sb *sectorbuilder.SectorBuilder, limiter *limits, endpoint string, auth http.Header, repo string, noprecommit, nocommit bool) error { - if err := paramfetch.GetParams(build.ParametersJson(), sb.SectorSize()); err != nil { - return xerrors.Errorf("get params: %w", err) - } - w := &worker{ api: api, minerEndpoint: endpoint,