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

Fix tests

Browse Source
This commit is contained in:
Łukasz Magiera 2020-07-30 22:38:05 +02:00
parent 3d2084ab93
commit 7153e1dd05
4 changed files with 13 additions and 10 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
ffiwrapper/partialfile.go
View File

@ -285,7 +285,7 @@ func (pf *partialFile) HasAllocated(offset storiface.UnpaddedByteIndex, size abi
return false, err return false, err
} }
u, err := rlepluslazy.Union(have, pieceRun(offset.Padded(), size.Padded())) u, err := rlepluslazy.And(have, pieceRun(offset.Padded(), size.Padded()))
if err != nil { if err != nil {
return false, err return false, err
} }

17
ffiwrapper/sealer_test.go
View File

@ -111,7 +111,7 @@ func (s *seal) unseal(t *testing.T, sb *Sealer, sp *basicfs.Provider, si abi.Sec
defer done() defer done()
var b bytes.Buffer var b bytes.Buffer
err := sb.ReadPiece(context.TODO(), &b, si, 0, 1016) _, err := sb.ReadPiece(context.TODO(), &b, si, 0, 1016)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@ -130,7 +130,7 @@ func (s *seal) unseal(t *testing.T, sb *Sealer, sp *basicfs.Provider, si abi.Sec
} }
sd() sd()
err = sb.ReadPiece(context.TODO(), &b, si, 0, 1016) _, err = sb.ReadPiece(context.TODO(), &b, si, 0, 1016)
if err == nil { if err == nil {
t.Fatal("HOW?!") t.Fatal("HOW?!")
} }
@ -141,7 +141,7 @@ func (s *seal) unseal(t *testing.T, sb *Sealer, sp *basicfs.Provider, si abi.Sec
} }
b.Reset() b.Reset()
err = sb.ReadPiece(context.TODO(), &b, si, 0, 1016) _, err = sb.ReadPiece(context.TODO(), &b, si, 0, 1016)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
@ -150,14 +150,17 @@ func (s *seal) unseal(t *testing.T, sb *Sealer, sp *basicfs.Provider, si abi.Sec
require.Equal(t, expect, b.Bytes()) require.Equal(t, expect, b.Bytes())
b.Reset() b.Reset()
err = sb.ReadPiece(context.TODO(), &b, si, 0, 2032) have, err := sb.ReadPiece(context.TODO(), &b, si, 0, 2032)
if err != nil { if err != nil {
t.Fatal(err) t.Fatal(err)
} }
expect = append(expect, bytes.Repeat([]byte{0}, 1016)...) if have {
if !bytes.Equal(b.Bytes(), expect) { t.Errorf("didn't expect to read things")
t.Fatal("read wrong bytes") }
if b.Len() != 0 {
t.Fatal("read bytes")
} }
} }

2
sched_test.go
View File

@ -88,7 +88,7 @@ func (s *schedTestWorker) UnsealPiece(ctx context.Context, id abi.SectorID, inde
panic("implement me") panic("implement me")
} }
func (s *schedTestWorker) ReadPiece(ctx context.Context, writer io.Writer, id abi.SectorID, index storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize) error { func (s *schedTestWorker) ReadPiece(ctx context.Context, writer io.Writer, id abi.SectorID, index storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize) (bool, error) {
panic("implement me") panic("implement me")
} }

2
testworker_test.go
View File

@ -53,7 +53,7 @@ func (t *testWorker) UnsealPiece(ctx context.Context, id abi.SectorID, index sto
panic("implement me") panic("implement me")
} }
func (t *testWorker) ReadPiece(ctx context.Context, writer io.Writer, id abi.SectorID, index storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize) error { func (t *testWorker) ReadPiece(ctx context.Context, writer io.Writer, id abi.SectorID, index storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize) (bool, error) {
panic("implement me") panic("implement me")
} }