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

minor renaming.

Browse Source
This commit is contained in:
Raúl Kripalani 2021-08-03 12:23:36 +01:00
parent bd3811e652
commit 691da14996
2 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

14
markets/dagstore/miner_api.go
View File

@ -37,17 +37,17 @@ type MinerAPI interface {
Start(ctx context.Context) error Start(ctx context.Context) error
} }
type lotusAccessor struct { type minerAPI struct {
pieceStore piecestore.PieceStore pieceStore piecestore.PieceStore
rm retrievalmarket.RetrievalProviderNode rm retrievalmarket.RetrievalProviderNode
throttle throttle.Throttler throttle throttle.Throttler
readyMgr *shared.ReadyManager readyMgr *shared.ReadyManager
} }
var _ MinerAPI = (*lotusAccessor)(nil) var _ MinerAPI = (*minerAPI)(nil)
func NewMinerAPI(store piecestore.PieceStore, rm retrievalmarket.RetrievalProviderNode) MinerAPI { func NewMinerAPI(store piecestore.PieceStore, rm retrievalmarket.RetrievalProviderNode) MinerAPI {
return &lotusAccessor{ return &minerAPI{
pieceStore: store, pieceStore: store,
rm: rm, rm: rm,
throttle: throttle.Fixed(MaxConcurrentStorageCalls), throttle: throttle.Fixed(MaxConcurrentStorageCalls),
@ -55,11 +55,11 @@ func NewMinerAPI(store piecestore.PieceStore, rm retrievalmarket.RetrievalProvid
} }
} }
func (m *lotusAccessor) Start(_ context.Context) error { func (m *minerAPI) Start(_ context.Context) error {
return m.readyMgr.FireReady(nil) return m.readyMgr.FireReady(nil)
} }
func (m *lotusAccessor) IsUnsealed(ctx context.Context, pieceCid cid.Cid) (bool, error) { func (m *minerAPI) IsUnsealed(ctx context.Context, pieceCid cid.Cid) (bool, error) {
err := m.readyMgr.AwaitReady() err := m.readyMgr.AwaitReady()
if err != nil { if err != nil {
return false, xerrors.Errorf("failed while waiting for accessor to start: %w", err) return false, xerrors.Errorf("failed while waiting for accessor to start: %w", err)
@ -107,7 +107,7 @@ func (m *lotusAccessor) IsUnsealed(ctx context.Context, pieceCid cid.Cid) (bool,
return false, nil return false, nil
} }
func (m *lotusAccessor) FetchUnsealedPiece(ctx context.Context, pieceCid cid.Cid) (io.ReadCloser, error) { func (m *minerAPI) FetchUnsealedPiece(ctx context.Context, pieceCid cid.Cid) (io.ReadCloser, error) {
err := m.readyMgr.AwaitReady() err := m.readyMgr.AwaitReady()
if err != nil { if err != nil {
return nil, err return nil, err
@ -179,7 +179,7 @@ func (m *lotusAccessor) FetchUnsealedPiece(ctx context.Context, pieceCid cid.Cid
return nil, lastErr return nil, lastErr
} }
func (m *lotusAccessor) GetUnpaddedCARSize(ctx context.Context, pieceCid cid.Cid) (uint64, error) { func (m *minerAPI) GetUnpaddedCARSize(ctx context.Context, pieceCid cid.Cid) (uint64, error) {
err := m.readyMgr.AwaitReady() err := m.readyMgr.AwaitReady()
if err != nil { if err != nil {
return 0, err return 0, err

2
markets/dagstore/mount_test.go
View File

@ -69,7 +69,7 @@ func TestLotusMount(t *testing.T) {
} }
func TestLotusMountDeserialize(t *testing.T) { func TestLotusMountDeserialize(t *testing.T) {
api := &lotusAccessor{} api := &minerAPI{}
bgen := blocksutil.NewBlockGenerator() bgen := blocksutil.NewBlockGenerator()
cid := bgen.Next().Cid() cid := bgen.Next().Cid()