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

Address review

Browse Source
This commit is contained in:
Łukasz Magiera 2020-05-26 21:08:51 +02:00
parent ffaeb89347
commit e3d3887a0b
1 changed files with 4 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
ffiwrapper/partialfile.go
View File

@ -32,13 +32,14 @@ type partialFile struct {
file *os.File file *os.File
} }
func writeTrailer(psz int64, w *os.File, r rlepluslazy.RunIterator) error { func writeTrailer(maxPieceSize int64, w *os.File, r rlepluslazy.RunIterator) error {
trailer, err := rlepluslazy.EncodeRuns(r, nil) trailer, err := rlepluslazy.EncodeRuns(r, nil)
if err != nil { if err != nil {
return xerrors.Errorf("encoding trailer: %w", err) return xerrors.Errorf("encoding trailer: %w", err)
} }
if _, err := w.Seek(psz, io.SeekStart); err != nil { // maxPieceSize == unpadded(sectorSize) == trailer start
if _, err := w.Seek(maxPieceSize, io.SeekStart); err != nil {
return xerrors.Errorf("seek to trailer start: %w", err) return xerrors.Errorf("seek to trailer start: %w", err)
} }
@ -51,7 +52,7 @@ func writeTrailer(psz int64, w *os.File, r rlepluslazy.RunIterator) error {
return xerrors.Errorf("writing trailer length: %w", err) return xerrors.Errorf("writing trailer length: %w", err)
} }
return w.Truncate(psz + int64(rb) + 4) return w.Truncate(maxPieceSize + int64(rb) + 4)
} }
func createPartialFile(maxPieceSize abi.UnpaddedPieceSize, path string) (*partialFile, error) { func createPartialFile(maxPieceSize abi.UnpaddedPieceSize, path string) (*partialFile, error) {