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

fix(sectorblocks): minor cleanups

Browse Source 
add error check, slice keys
This commit is contained in:
hannahhoward 2020-01-28 14:15:12 -08:00
parent 503b16f6b1
commit 00941e4461
1 changed files with 6 additions and 3 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

9
storage/sectorblocks/blocks.go
View File

@ -34,8 +34,8 @@ var ErrNotFound = errors.New("not found")
func DealIDToDsKey(dealID uint64) datastore.Key { func DealIDToDsKey(dealID uint64) datastore.Key {
buf := make([]byte, binary.MaxVarintLen64) buf := make([]byte, binary.MaxVarintLen64)
binary.PutUvarint(buf, dealID) size := binary.PutUvarint(buf, dealID)
return dshelp.NewKeyFromBinary(buf) return dshelp.NewKeyFromBinary(buf[:size])
} }
func DsKeyToDealID(key datastore.Key) (uint64, error) { func DsKeyToDealID(key datastore.Key) (uint64, error) {
@ -104,7 +104,10 @@ func (st *SectorBlocks) AddPiece(ctx context.Context, size uint64, r io.Reader,
return 0, err return 0, err
} }
st.writeRef(dealID, sectorID, pieceOffset, size) err = st.writeRef(dealID, sectorID, pieceOffset, size)
if err != nil {
return 0, err
}
return sectorID, st.Miner.SealPiece(ctx, size, r, sectorID, dealID) return sectorID, st.Miner.SealPiece(ctx, size, r, sectorID, dealID)
} }