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

ffiwrapper: Correctly create unsealed file when doesn't exist

Browse Source
This commit is contained in:
Łukasz Magiera 2023-07-31 15:06:03 +02:00 committed by Jennifer Wang
parent e74eb6af09
commit 8ea44e82d1
1 changed files with 9 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
storage/sealer/ffiwrapper/sealer_cgo.go
View File

@ -10,6 +10,7 @@ import (
"crypto/rand" "crypto/rand"
"encoding/base64" "encoding/base64"
"encoding/json" "encoding/json"
"errors"
"io" "io"
"math/bits" "math/bits"
"os" "os"
@ -567,8 +568,15 @@ func (sb *Sealer) UnsealPiece(ctx context.Context, sector storiface.SectorRef, o
pf, err = partialfile.OpenPartialFile(maxPieceSize, unsealedPath.Unsealed) pf, err = partialfile.OpenPartialFile(maxPieceSize, unsealedPath.Unsealed)
if err != nil { if err != nil {
if errors.Is(err, os.ErrNotExist) {
pf, err = partialfile.CreatePartialFile(maxPieceSize, unsealedPath.Unsealed)
if err != nil {
return xerrors.Errorf("creating partial file: %w", err)
}
} else {
return xerrors.Errorf("opening partial file: %w", err) return xerrors.Errorf("opening partial file: %w", err)
} }
}
defer pf.Close() // nolint defer pf.Close() // nolint
allocated, err := pf.Allocated() allocated, err := pf.Allocated()