|
8 | 8 |
|
9 | 9 | "github.com/filecoin-project/go-padreader" |
10 | 10 | "github.com/filecoin-project/go-sectorbuilder" |
| 11 | + "github.com/filecoin-project/specs-actors/actors/abi" |
11 | 12 | "github.com/ipfs/go-cid" |
12 | 13 | blockstore "github.com/ipfs/go-ipfs-blockstore" |
13 | 14 | "github.com/ipld/go-ipld-prime" |
@@ -50,7 +51,7 @@ func NewPieceIOWithStore(carIO CarIO, store filestore.FileStore, bs blockstore.B |
50 | 51 | return &pieceIOWithStore{pieceIO{carIO, bs}, store} |
51 | 52 | } |
52 | 53 |
|
53 | | -func (pio *pieceIO) GeneratePieceCommitment(payloadCid cid.Cid, selector ipld.Node) ([]byte, uint64, error) { |
| 54 | +func (pio *pieceIO) GeneratePieceCommitment(payloadCid cid.Cid, selector ipld.Node) ([]byte, abi.UnpaddedPieceSize, error) { |
54 | 55 | preparedCar, err := pio.carIO.PrepareCar(context.Background(), pio.bs, payloadCid, selector) |
55 | 56 | if err != nil { |
56 | 57 | return nil, 0, err |
@@ -86,7 +87,7 @@ func (pio *pieceIO) GeneratePieceCommitment(payloadCid cid.Cid, selector ipld.No |
86 | 87 | return commitment, paddedSize, nil |
87 | 88 | } |
88 | 89 |
|
89 | | -func (pio *pieceIOWithStore) GeneratePieceCommitmentToFile(payloadCid cid.Cid, selector ipld.Node) ([]byte, filestore.Path, uint64, error) { |
| 90 | +func (pio *pieceIOWithStore) GeneratePieceCommitmentToFile(payloadCid cid.Cid, selector ipld.Node) ([]byte, filestore.Path, abi.UnpaddedPieceSize, error) { |
90 | 91 | f, err := pio.store.CreateTemp() |
91 | 92 | if err != nil { |
92 | 93 | return nil, "", 0, err |
@@ -115,7 +116,7 @@ func (pio *pieceIOWithStore) GeneratePieceCommitmentToFile(payloadCid cid.Cid, s |
115 | 116 | return commitment, f.Path(), paddedSize, nil |
116 | 117 | } |
117 | 118 |
|
118 | | -func GeneratePieceCommitment(rd io.Reader, pieceSize uint64) ([]byte, uint64, error) { |
| 119 | +func GeneratePieceCommitment(rd io.Reader, pieceSize uint64) ([]byte, abi.UnpaddedPieceSize, error) { |
119 | 120 | paddedReader, paddedSize := padreader.New(rd, pieceSize) |
120 | 121 | commitment, err := sectorbuilder.GeneratePieceCommitment(paddedReader, paddedSize) |
121 | 122 | if err != nil { |
|
0 commit comments