From 17c15a74a2597c191781579da303c1ece42b27ba Mon Sep 17 00:00:00 2001 From: Dirk McCormick Date: Tue, 8 Sep 2020 13:50:56 +0200 Subject: [PATCH] fix: return true from Sealer.ReadPiece() on success --- extern/sector-storage/ffiwrapper/sealer_cgo.go | 2 +- extern/sector-storage/manager.go | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/extern/sector-storage/ffiwrapper/sealer_cgo.go b/extern/sector-storage/ffiwrapper/sealer_cgo.go index 9ab9bd5a6f1..9bc2680edfa 100644 --- a/extern/sector-storage/ffiwrapper/sealer_cgo.go +++ b/extern/sector-storage/ffiwrapper/sealer_cgo.go @@ -410,7 +410,7 @@ func (sb *Sealer) ReadPiece(ctx context.Context, writer io.Writer, sector abi.Se return false, xerrors.Errorf("closing partial file: %w", err) } - return false, nil + return true, nil } func (sb *Sealer) SealPreCommit1(ctx context.Context, sector abi.SectorID, ticket abi.SealRandomness, pieces []abi.PieceInfo) (out storage.PreCommit1Out, err error) { diff --git a/extern/sector-storage/manager.go b/extern/sector-storage/manager.go index d94647fec69..fe9bf5d4569 100644 --- a/extern/sector-storage/manager.go +++ b/extern/sector-storage/manager.go @@ -272,7 +272,7 @@ func (m *Manager) ReadPiece(ctx context.Context, sink io.Writer, sector abi.Sect return xerrors.Errorf("reading piece from sealed sector: %w", err) } - if readOk { + if !readOk { return xerrors.Errorf("failed to read unsealed piece") }