test

seal/seal_api.go

@@ -49,6 +49,7 @@ func AddPiece(sb *ffiwrapper.Sealer, ctx context.Context, sector storage.SectorR
 // func EncodeDataToPieces(sb *ffiwrapper.Sealer, ctx context.Context, sector storage.SectorRef, sectorSize abi.SectorSize, file storage.Data) (abi.PieceInfo, error) {
 // 	var piecesID []byte
 // 	var FinalPiece abi.PieceInfo
+// 	var pieceNumber int32 = 1
 
 // 	UnpaddedSectorSize := abi.PaddedPieceSize(sectorSize).Unpadded()
 // 	buf := make([]byte, UnpaddedSectorSize)
@@ -66,15 +67,15 @@ func AddPiece(sb *ffiwrapper.Sealer, ctx context.Context, sector storage.SectorR
 // 				return nil, rerr
 // 			}
 // 			rbuf = rbuf[n:]
-// 			MetaLen += n;
+// 			MetaLen += n
 
 // 			if rerr == io.EOF{
-// 				break;
+// 				break
 // 			}
 // 		}
 // 		if rerr == io.EOF{
 // 			//encode first sector
-// 			FinalPiece, err = EncodeData(buf, MetaLen, DataLen, piecesID)
+// 			pieceNumber, FinalPiece, err = EncodeData(buf, MetaLen, DataLen, piecesID, pieceNumber)
 // 			if err != nil{
 // 				return nil, err
 // 			}
@@ -82,16 +83,17 @@ func AddPiece(sb *ffiwrapper.Sealer, ctx context.Context, sector storage.SectorR
 // 		}
 // 		copy(buf[:4], []byte(MetaLen))
 
-// 		piece, err := sb.AddPiece(ctx, sector, nil, UnpaddedSectorSize, bytes.NewReader(buf))
+// 		piece, err := sb.AddPiece(ctx, sector, nil, UnpaddedSectorSize, bytes.NewReader(buf), pieceNumber)
 // 		if err != nil{
 // 			return nil, err
 // 		}
 // 		piecesID = append(pieces, commcid.CIDToReplicaCommitmentV1(piece.PieceCID)...)
+// 		pieceNumber += 1
 // 	}
-// 	return FinalPiece, nil
+// 	return pieceNumber, FinalPiece, nil
 // }
 
-// func EncodeData(buf []byte, MetaLen int, DataLen int, piecesID []byte) (abi.PieceInfo, error) {
+// func EncodeData(buf []byte, MetaLen int, DataLen int, piecesID []byte, pieceNumber int32) (int32, abi.PieceInfo, error) {
 // 	//encode first sector
 // 	remain := len(piecesID)
 // 	CommLen := min(remain, ((DataLen-MetaLen)/32) * 32)
@@ -107,7 +109,8 @@ func AddPiece(sb *ffiwrapper.Sealer, ctx context.Context, sector storage.SectorR
 // 	remain -= CommLen
 // 	rbuf = buf[TagLen+32:]
 
-// 	prePiece, err := sb.AddPiece(ctx, sector, nil, UnpaddedSectorSize, bytes.NewReader(buf))
+// 	prePiece, err := sb.AddPiece(ctx, sector, nil, UnpaddedSectorSize, bytes.NewReader(buf), pieceNumber)
+// 	pieceNumber += 1
 // 	if err != nil{
 // 		return nil, err
 // 	}
@@ -127,17 +130,60 @@ func AddPiece(sb *ffiwrapper.Sealer, ctx context.Context, sector storage.SectorR
 // 		remain -= CommLen
 // 		rbuf = buf[TagLen:]
 
-// 		prePiece, err = sb.AddPiece(ctx, sector, nil, UnpaddedSectorSize, bytes.NewReader(buf))
+// 		prePiece, err = sb.AddPiece(ctx, sector, nil, UnpaddedSectorSize, bytes.NewReader(buf), pieceNumber)
+// 		pieceNumber += 1
 // 		if err != nil{
 // 			return nil, err
 // 		}
 // 	}
 
-// 	return prePiece, nil
+// 	return pieceNumber, prePiece, nil
+// }
+
+// func DecodePieceToData(sb *ffiwrapper.Sealer, ctx context.Context, out io.Writer, finalPiece abi.PieceInfo, pieceNum int32, sectorSize abi.SectorSize) ([]abi.PieceInfo, error){
+// 	var piecesID []abi.PieceInfo
+// 	var commds []byte
+
+// 	unpaddedSectorSize := abi.PaddedPieceSize(sectorSize).Unpadded()
+// 	buf := make([]byte, unpaddedSectorSize)
+// 	DataLen := unpaddedSectorSize-TagLen
+
+// 	for ;pieceNum > 0; PieceNum-- {
+// 		ok, err := sb.ReadPiece(ctx, sid, bytes.NewWriter(buf), 0, unpaddedSectorSize, pieceNum)
+// 		if err != nil {
+// 			return nil
+// 		}
+// 		if !ok {
+// 			return xerrors.Errorf("Read pieces error!")
 // 		}
 
-// func DecodePieceToData(sb *ffiwrapper.Sealer, ctx context.Context, ) ([]abi.PieceInfo, error){
+// 		MetaLen := buf[0:4] & 0x7fffffff
+// 		HasPre := buf[0:4] >> 31
+// 		CommLen := buf[4:8]
+// 		rbuf := buf[8:]
+
+// 		if HasPre {
+// 			prePiece := buf[8:40]
+// 			CommLen -= 32
+// 			rbuf = rbuf[32:]
+// 			commd, _ := commcid.DataCommitmentV1ToCID(prePiece)
+// 			piecesID = append(piecesID, abi.PieceInfo{abi.PaddedPieceSize(sectorSize), commd})
+// 		}
+// 		data := rbuf[:MetaLen]
+// 		commds = append(commds, rbuf[MetaLen:MetaLen+CommLen]...)
+// 		//**data顺序错了，需要
+// 		n, werr := out.write(data[:])
+// 		if werr != nil {
+// 			return nil, werr
+// 		}
+// 	}
 
+// 	for cbuf := commds; len(cbuf) > 0; {
+// 		commd, _ := cbuf.DataCommitmentV1ToCID(commds[32])
+// 		piecesID = append(piecesID, abi.PieceInfo{abi.PaddedPieceSize(sectorSize), commd})
+// 		cbuf = cbuf[32:]
+// 	}
+// 	return piecesID, nil
 // }
 
 func CheckPieceAndDataRoot(sid storage.SectorRef, comm_d cid.Cid, pieces []abi.PieceInfo) (bool, error){