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

worker: Fix build

Browse Source
This commit is contained in:
Łukasz Magiera 2020-03-05 23:40:40 +01:00
parent 16cb27b5f9
commit d10b84d8cd
3 changed files with 9 additions and 17 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

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

@ -2,21 +2,11 @@ package main
import ( import (
"os" "os"
"sync"
paramfetch "github.com/filecoin-project/go-paramfetch"
"github.com/filecoin-project/go-sectorbuilder"
"github.com/mitchellh/go-homedir"
logging "github.com/ipfs/go-log/v2" logging "github.com/ipfs/go-log/v2"
"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/build" "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/lib/lotuslog"
"github.com/filecoin-project/lotus/node/repo" "github.com/filecoin-project/lotus/node/repo"
) )
@ -85,7 +75,7 @@ var runCmd = &cli.Command{
Name: "run", Name: "run",
Usage: "Start lotus worker", Usage: "Start lotus worker",
Action: func(cctx *cli.Context) error { Action: func(cctx *cli.Context) error {
if !cctx.Bool("enable-gpu-proving") { /* if !cctx.Bool("enable-gpu-proving") {
os.Setenv("BELLMAN_NO_GPU", "true") os.Setenv("BELLMAN_NO_GPU", "true")
} }
@ -138,12 +128,12 @@ var runCmd = &cli.Command{
return xerrors.Errorf("get params: %w", err) return xerrors.Errorf("get params: %w", err)
} }
ppt, spt, err := api.ProofTypeFromSectorSize(ssize) /*ppt, spt, err := api.ProofTypeFromSectorSize(ssize)
if err != nil { if err != nil {
return err return err
} }
sb, err := sectorbuilder.NewStandalone(&sectorbuilder.Config{ /*sb, err := sectorbuilder.NewStandalone(&sectorbuilder.Config{
SealProofType: spt, SealProofType: spt,
PoStProofType: ppt, PoStProofType: ppt,
Miner: act, Miner: act,
@ -162,14 +152,14 @@ var runCmd = &cli.Command{
go func() { go func() {
defer wg.Done() defer wg.Done()
if err := acceptJobs(ctx, nodeApi, sb, limiter, "http://"+storageAddr, ainfo.AuthHeader(), r, cctx.Bool("no-precommit"), cctx.Bool("no-commit")); err != nil { /* if err := acceptJobs(ctx, nodeApi, sb, limiter, "http://"+storageAddr, ainfo.AuthHeader(), r, cctx.Bool("no-precommit"), cctx.Bool("no-commit")); err != nil {
log.Warnf("%+v", err) log.Warnf("%+v", err)
return return
} }
}() }()
} }
wg.Wait() wg.Wait()*/
return nil return nil
}, },
} }

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

@ -1,5 +1,5 @@
package main package main
/*
import ( import (
"context" "context"
"net/http" "net/http"
@ -128,3 +128,4 @@ func (w *worker) processTask(ctx context.Context, task sectorbuilder.WorkerTask)
func errRes(err error) sectorbuilder.SealRes { func errRes(err error) sectorbuilder.SealRes {
return sectorbuilder.SealRes{Err: err.Error(), GoErr: err} return sectorbuilder.SealRes{Err: err.Error(), GoErr: err}
} }
*/

3
cmd/lotus-seal-worker/transfer.go
View File

@ -1,5 +1,5 @@
package main package main
/*
import ( import (
"fmt" "fmt"
"io" "io"
@ -174,3 +174,4 @@ func (w *worker) fetchSector(sectorID abi.SectorNumber, typ sectorbuilder.Worker
} }
return nil return nil
} }
*/