Merge pull request #649 from filecoin-project/fix/open-fd-later
sectorbuilder: open FD later in AddPiece
This commit is contained in:
commit
734199b18e
@ -170,14 +170,14 @@ func (sb *SectorBuilder) AcquireSectorId() (uint64, error) {
|
|||||||
}
|
}
|
||||||
|
|
||||||
func (sb *SectorBuilder) AddPiece(pieceSize uint64, sectorId uint64, file io.Reader, existingPieceSizes []uint64) (PublicPieceInfo, error) {
|
func (sb *SectorBuilder) AddPiece(pieceSize uint64, sectorId uint64, file io.Reader, existingPieceSizes []uint64) (PublicPieceInfo, error) {
|
||||||
|
ret := sb.RateLimit()
|
||||||
|
defer ret()
|
||||||
|
|
||||||
f, werr, err := toReadableFile(file, int64(pieceSize))
|
f, werr, err := toReadableFile(file, int64(pieceSize))
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return PublicPieceInfo{}, err
|
return PublicPieceInfo{}, err
|
||||||
}
|
}
|
||||||
|
|
||||||
ret := sb.RateLimit()
|
|
||||||
defer ret()
|
|
||||||
|
|
||||||
stagedFile, err := sb.stagedSectorFile(sectorId)
|
stagedFile, err := sb.stagedSectorFile(sectorId)
|
||||||
if err != nil {
|
if err != nil {
|
||||||
return PublicPieceInfo{}, err
|
return PublicPieceInfo{}, err
|
||||||
|
Loading…
Reference in New Issue
Block a user