remove pieceProvider from DI; small refactors
This commit is contained in:
parent
82efe01c70
commit
16784aa2cc
@ -31,6 +31,50 @@ import (
|
|||||||
"github.com/filecoin-project/lotus/node/repo"
|
"github.com/filecoin-project/lotus/node/repo"
|
||||||
)
|
)
|
||||||
|
|
||||||
|
var restoreCmd = &cli.Command{
|
||||||
|
Name: "restore",
|
||||||
|
Usage: "Initialize a lotus miner repo from a backup",
|
||||||
|
Flags: []cli.Flag{
|
||||||
|
&cli.BoolFlag{
|
||||||
|
Name: "nosync",
|
||||||
|
Usage: "don't check full-node sync status",
|
||||||
|
},
|
||||||
|
&cli.StringFlag{
|
||||||
|
Name: "config",
|
||||||
|
Usage: "config file (config.toml)",
|
||||||
|
},
|
||||||
|
&cli.StringFlag{
|
||||||
|
Name: "storage-config",
|
||||||
|
Usage: "storage paths config (storage.json)",
|
||||||
|
},
|
||||||
|
},
|
||||||
|
ArgsUsage: "[backupFile]",
|
||||||
|
Action: func(cctx *cli.Context) error {
|
||||||
|
ctx := lcli.ReqContext(cctx)
|
||||||
|
log.Info("Initializing lotus miner using a backup")
|
||||||
|
|
||||||
|
if err := restore(ctx, cctx, nil, func(api lapi.FullNode, maddr address.Address, peerid peer.ID, mi miner.MinerInfo) error {
|
||||||
|
log.Info("Checking proof parameters")
|
||||||
|
|
||||||
|
if err := paramfetch.GetParams(ctx, build.ParametersJSON(), build.SrsJSON(), uint64(mi.SectorSize)); err != nil {
|
||||||
|
return xerrors.Errorf("fetching proof parameters: %w", err)
|
||||||
|
}
|
||||||
|
|
||||||
|
log.Info("Configuring miner actor")
|
||||||
|
|
||||||
|
if err := configureStorageMiner(ctx, api, maddr, peerid, big.Zero()); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
}); err != nil {
|
||||||
|
return err
|
||||||
|
}
|
||||||
|
|
||||||
|
return nil
|
||||||
|
},
|
||||||
|
}
|
||||||
|
|
||||||
func restore(ctx context.Context, cctx *cli.Context, manageConfig func(*config.StorageMiner) error, after func(api lapi.FullNode, addr address.Address, peerid peer.ID, mi miner.MinerInfo) error) error {
|
func restore(ctx context.Context, cctx *cli.Context, manageConfig func(*config.StorageMiner) error, after func(api lapi.FullNode, addr address.Address, peerid peer.ID, mi miner.MinerInfo) error) error {
|
||||||
if cctx.Args().Len() != 1 {
|
if cctx.Args().Len() != 1 {
|
||||||
return xerrors.Errorf("expected 1 argument")
|
return xerrors.Errorf("expected 1 argument")
|
||||||
@ -246,47 +290,3 @@ func restore(ctx context.Context, cctx *cli.Context, manageConfig func(*config.S
|
|||||||
|
|
||||||
return after(api, maddr, peerid, mi)
|
return after(api, maddr, peerid, mi)
|
||||||
}
|
}
|
||||||
|
|
||||||
var restoreCmd = &cli.Command{
|
|
||||||
Name: "restore",
|
|
||||||
Usage: "Initialize a lotus miner repo from a backup",
|
|
||||||
Flags: []cli.Flag{
|
|
||||||
&cli.BoolFlag{
|
|
||||||
Name: "nosync",
|
|
||||||
Usage: "don't check full-node sync status",
|
|
||||||
},
|
|
||||||
&cli.StringFlag{
|
|
||||||
Name: "config",
|
|
||||||
Usage: "config file (config.toml)",
|
|
||||||
},
|
|
||||||
&cli.StringFlag{
|
|
||||||
Name: "storage-config",
|
|
||||||
Usage: "storage paths config (storage.json)",
|
|
||||||
},
|
|
||||||
},
|
|
||||||
ArgsUsage: "[backupFile]",
|
|
||||||
Action: func(cctx *cli.Context) error {
|
|
||||||
ctx := lcli.ReqContext(cctx)
|
|
||||||
log.Info("Initializing lotus miner using a backup")
|
|
||||||
|
|
||||||
if err := restore(ctx, cctx, nil, func(api lapi.FullNode, maddr address.Address, peerid peer.ID, mi miner.MinerInfo) error {
|
|
||||||
log.Info("Checking proof parameters")
|
|
||||||
|
|
||||||
if err := paramfetch.GetParams(ctx, build.ParametersJSON(), build.SrsJSON(), uint64(mi.SectorSize)); err != nil {
|
|
||||||
return xerrors.Errorf("fetching proof parameters: %w", err)
|
|
||||||
}
|
|
||||||
|
|
||||||
log.Info("Configuring miner actor")
|
|
||||||
|
|
||||||
if err := configureStorageMiner(ctx, api, maddr, peerid, big.Zero()); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
}); err != nil {
|
|
||||||
return err
|
|
||||||
}
|
|
||||||
|
|
||||||
return nil
|
|
||||||
},
|
|
||||||
}
|
|
||||||
|
1
extern/sector-storage/manager.go
vendored
1
extern/sector-storage/manager.go
vendored
@ -723,4 +723,3 @@ func (m *Manager) Close(ctx context.Context) error {
|
|||||||
|
|
||||||
var _ Unsealer = &Manager{}
|
var _ Unsealer = &Manager{}
|
||||||
var _ SectorManager = &Manager{}
|
var _ SectorManager = &Manager{}
|
||||||
var _ Unsealer = &Manager{}
|
|
||||||
|
@ -668,7 +668,6 @@ func RetrievalProvider(
|
|||||||
pieceStore dtypes.ProviderPieceStore,
|
pieceStore dtypes.ProviderPieceStore,
|
||||||
mds dtypes.StagingMultiDstore,
|
mds dtypes.StagingMultiDstore,
|
||||||
dt dtypes.ProviderDataTransfer,
|
dt dtypes.ProviderDataTransfer,
|
||||||
pieceProvider sectorstorage.PieceProvider,
|
|
||||||
pricingFnc dtypes.RetrievalPricingFunc,
|
pricingFnc dtypes.RetrievalPricingFunc,
|
||||||
userFilter dtypes.RetrievalDealFilter,
|
userFilter dtypes.RetrievalDealFilter,
|
||||||
) (retrievalmarket.RetrievalProvider, error) {
|
) (retrievalmarket.RetrievalProvider, error) {
|
||||||
|
Loading…
Reference in New Issue
Block a user