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

worker: Paramfetch once

Browse Source
This commit is contained in:
Łukasz Magiera 2020-02-04 20:17:18 +01:00
parent 1a9c775407
commit 63af9f2a9e
2 changed files with 7 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
cmd/lotus-seal-worker/main.go
View File

@ -4,6 +4,7 @@ import (
"os" "os"
"sync" "sync"
paramfetch "github.com/filecoin-project/go-paramfetch"
"github.com/filecoin-project/go-sectorbuilder" "github.com/filecoin-project/go-sectorbuilder"
"github.com/mitchellh/go-homedir" "github.com/mitchellh/go-homedir"
@ -11,12 +12,13 @@ import (
"golang.org/x/xerrors" "golang.org/x/xerrors"
"gopkg.in/urfave/cli.v2" "gopkg.in/urfave/cli.v2"
manet "github.com/multiformats/go-multiaddr-net"
"github.com/filecoin-project/lotus/api" "github.com/filecoin-project/lotus/api"
"github.com/filecoin-project/lotus/build" "github.com/filecoin-project/lotus/build"
lcli "github.com/filecoin-project/lotus/cli" lcli "github.com/filecoin-project/lotus/cli"
"github.com/filecoin-project/lotus/lib/lotuslog" "github.com/filecoin-project/lotus/lib/lotuslog"
"github.com/filecoin-project/lotus/node/repo" "github.com/filecoin-project/lotus/node/repo"
manet "github.com/multiformats/go-multiaddr-net"
) )
var log = logging.Logger("main") var log = logging.Logger("main")
@ -132,6 +134,10 @@ var runCmd = &cli.Command{
return err return err
} }
if err := paramfetch.GetParams(build.ParametersJson(), ssize); err != nil {
return xerrors.Errorf("get params: %w", err)
}
sb, err := sectorbuilder.NewStandalone(&sectorbuilder.Config{ sb, err := sectorbuilder.NewStandalone(&sectorbuilder.Config{
SectorSize: ssize, SectorSize: ssize,
Miner: act, Miner: act,

6
cmd/lotus-seal-worker/sub.go
View File

@ -4,12 +4,10 @@ import (
"context" "context"
"net/http" "net/http"
paramfetch "github.com/filecoin-project/go-paramfetch"
"github.com/filecoin-project/go-sectorbuilder" "github.com/filecoin-project/go-sectorbuilder"
"golang.org/x/xerrors" "golang.org/x/xerrors"
lapi "github.com/filecoin-project/lotus/api" lapi "github.com/filecoin-project/lotus/api"
"github.com/filecoin-project/lotus/build"
) )
type worker struct { 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 { 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{ w := &worker{
api: api, api: api,
minerEndpoint: endpoint, minerEndpoint: endpoint,