113 lines
2.0 KiB
Go
113 lines
2.0 KiB
Go
package sealing
|
|
|
|
import (
|
|
sectorbuilder "github.com/filecoin-project/go-sectorbuilder"
|
|
"github.com/ipfs/go-cid"
|
|
|
|
"github.com/filecoin-project/lotus/api"
|
|
)
|
|
|
|
type SealTicket struct {
|
|
BlockHeight uint64
|
|
TicketBytes []byte
|
|
}
|
|
|
|
func (t *SealTicket) SB() sectorbuilder.SealTicket {
|
|
out := sectorbuilder.SealTicket{BlockHeight: t.BlockHeight}
|
|
copy(out.TicketBytes[:], t.TicketBytes)
|
|
return out
|
|
}
|
|
|
|
type SealSeed struct {
|
|
BlockHeight uint64
|
|
TicketBytes []byte
|
|
}
|
|
|
|
func (t *SealSeed) SB() sectorbuilder.SealSeed {
|
|
out := sectorbuilder.SealSeed{BlockHeight: t.BlockHeight}
|
|
copy(out.TicketBytes[:], t.TicketBytes)
|
|
return out
|
|
}
|
|
|
|
func (t *SealSeed) Equals(o *SealSeed) bool {
|
|
return string(t.TicketBytes) == string(o.TicketBytes) && t.BlockHeight == o.BlockHeight
|
|
}
|
|
|
|
type Piece struct {
|
|
DealID uint64
|
|
|
|
Size uint64
|
|
CommP []byte
|
|
}
|
|
|
|
func (p *Piece) ppi() (out sectorbuilder.PublicPieceInfo) {
|
|
out.Size = p.Size
|
|
copy(out.CommP[:], p.CommP)
|
|
return out
|
|
}
|
|
|
|
type SectorInfo struct {
|
|
State api.SectorState
|
|
SectorID uint64
|
|
Nonce uint64
|
|
|
|
// Packing
|
|
|
|
Pieces []Piece
|
|
|
|
// PreCommit
|
|
CommD []byte
|
|
CommR []byte
|
|
Proof []byte
|
|
Ticket SealTicket
|
|
|
|
PreCommitMessage *cid.Cid
|
|
|
|
// PreCommitted
|
|
Seed SealSeed
|
|
|
|
// Committing
|
|
CommitMessage *cid.Cid
|
|
|
|
// Faults
|
|
FaultReportMsg *cid.Cid
|
|
|
|
// Debug
|
|
LastErr string
|
|
|
|
// TODO: Log []struct{ts, msg, trace string}
|
|
}
|
|
|
|
func (t *SectorInfo) pieceInfos() []sectorbuilder.PublicPieceInfo {
|
|
out := make([]sectorbuilder.PublicPieceInfo, len(t.Pieces))
|
|
for i, piece := range t.Pieces {
|
|
out[i] = piece.ppi()
|
|
}
|
|
return out
|
|
}
|
|
|
|
func (t *SectorInfo) deals() []uint64 {
|
|
out := make([]uint64, len(t.Pieces))
|
|
for i, piece := range t.Pieces {
|
|
out[i] = piece.DealID
|
|
}
|
|
return out
|
|
}
|
|
|
|
func (t *SectorInfo) existingPieces() []uint64 {
|
|
out := make([]uint64, len(t.Pieces))
|
|
for i, piece := range t.Pieces {
|
|
out[i] = piece.Size
|
|
}
|
|
return out
|
|
}
|
|
|
|
func (t *SectorInfo) rspco() sectorbuilder.RawSealPreCommitOutput {
|
|
var out sectorbuilder.RawSealPreCommitOutput
|
|
|
|
copy(out.CommD[:], t.CommD)
|
|
copy(out.CommR[:], t.CommR)
|
|
|
|
return out
|
|
}
|