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

fix lint errors.

Browse Source
This commit is contained in:
Raúl Kripalani 2021-07-30 15:25:18 +01:00
parent 2e30891005
commit 932767d014
4 changed files with 8 additions and 8 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

1
markets/dagstore/lotusaccessor.go
View File

@ -65,7 +65,6 @@ func (m *lotusAccessor) IsUnsealed(ctx context.Context, pieceCid cid.Cid) (bool,
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)
} }
var pieceInfo piecestore.PieceInfo var pieceInfo piecestore.PieceInfo
err = m.throttle.Do(ctx, func(ctx context.Context) (err error) { err = m.throttle.Do(ctx, func(ctx context.Context) (err error) {
pieceInfo, err = m.pieceStore.GetPieceInfo(pieceCid) pieceInfo, err = m.pieceStore.GetPieceInfo(pieceCid)

10
markets/dagstore/lotusaccessor_test.go
View File

@ -45,9 +45,9 @@ func TestLotusAccessorFetchUnsealedPiece(t *testing.T) {
name string name string
deals []abi.SectorNumber deals []abi.SectorNumber
fetchedData string fetchedData string
isUnsealed bool isUnsealed bool
expectErr bool expectErr bool
}{{ }{{
// Expect error if there is no deal info for piece CID // Expect error if there is no deal info for piece CID
name: "no deals", name: "no deals",
@ -58,13 +58,13 @@ func TestLotusAccessorFetchUnsealedPiece(t *testing.T) {
name: "prefer unsealed deal", name: "prefer unsealed deal",
deals: []abi.SectorNumber{unsealedSectorID, sealedSectorID}, deals: []abi.SectorNumber{unsealedSectorID, sealedSectorID},
fetchedData: unsealedSectorData, fetchedData: unsealedSectorData,
isUnsealed: true, isUnsealed: true,
}, { }, {
// Expect the API to unseal the data if there are no unsealed deals // Expect the API to unseal the data if there are no unsealed deals
name: "unseal if necessary", name: "unseal if necessary",
deals: []abi.SectorNumber{sealedSectorID}, deals: []abi.SectorNumber{sealedSectorID},
fetchedData: sealedSectorData, fetchedData: sealedSectorData,
isUnsealed: false, isUnsealed: false,
}} }}
for _, tc := range testCases { for _, tc := range testCases {
@ -194,7 +194,7 @@ func getPieceStore(t *testing.T) piecestore.PieceStore {
err = ps.Start(context.Background()) err = ps.Start(context.Background())
require.NoError(t, err) require.NoError(t, err)
<- ch <-ch
return ps return ps
} }

2
markets/dagstore/mount.go
View File

@ -91,7 +91,7 @@ func (l *LotusMount) Stat(ctx context.Context) (mount.Stat, error) {
return mount.Stat{ return mount.Stat{
Exists: true, Exists: true,
Size: int64(size), Size: int64(size),
Ready: isUnsealed, Ready: isUnsealed,
}, nil }, nil
} }

3
markets/dagstore/wrapper_test.go
View File

@ -92,7 +92,8 @@ func TestWrapperBackground(t *testing.T) {
w.dagStore = mock w.dagStore = mock
// Start up the wrapper // Start up the wrapper
w.Start(ctx) err = w.Start(ctx)
require.NoError(t, err)
// Expect GC to be called automatically // Expect GC to be called automatically
tctx, cancel := context.WithTimeout(ctx, time.Second) tctx, cancel := context.WithTimeout(ctx, time.Second)