61e173215b
- FSM handles the actual cc upgrade process including error states - PoSting (winning and window) works over upgraded and upgrading sectors - Integration test and changes to itest framework to reduce flakes - Update CLI to handle new upgrade - Update dependencies
110 lines
3.9 KiB
Go
110 lines
3.9 KiB
Go
package sectorstorage
|
|
|
|
import (
|
|
"context"
|
|
"io"
|
|
|
|
"github.com/ipfs/go-cid"
|
|
|
|
"github.com/filecoin-project/go-state-types/abi"
|
|
"github.com/filecoin-project/specs-actors/v7/actors/runtime/proof"
|
|
"github.com/filecoin-project/specs-storage/storage"
|
|
|
|
"github.com/filecoin-project/lotus/extern/sector-storage/ffiwrapper"
|
|
"github.com/filecoin-project/lotus/extern/sector-storage/storiface"
|
|
)
|
|
|
|
type apres struct {
|
|
pi abi.PieceInfo
|
|
err error
|
|
}
|
|
|
|
type testExec struct {
|
|
apch chan chan apres
|
|
}
|
|
|
|
func (t *testExec) GenerateWinningPoSt(ctx context.Context, minerID abi.ActorID, sectorInfo []proof.ExtendedSectorInfo, randomness abi.PoStRandomness) ([]proof.PoStProof, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) GenerateWindowPoSt(ctx context.Context, minerID abi.ActorID, sectorInfo []proof.ExtendedSectorInfo, randomness abi.PoStRandomness) (proof []proof.PoStProof, skipped []abi.SectorID, err error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) SealPreCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, pieces []abi.PieceInfo) (storage.PreCommit1Out, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) SealPreCommit2(ctx context.Context, sector storage.SectorRef, pc1o storage.PreCommit1Out) (storage.SectorCids, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) SealCommit1(ctx context.Context, sector storage.SectorRef, ticket abi.SealRandomness, seed abi.InteractiveSealRandomness, pieces []abi.PieceInfo, cids storage.SectorCids) (storage.Commit1Out, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) SealCommit2(ctx context.Context, sector storage.SectorRef, c1o storage.Commit1Out) (storage.Proof, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) FinalizeSector(ctx context.Context, sector storage.SectorRef, keepUnsealed []storage.Range) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ReleaseUnsealed(ctx context.Context, sector storage.SectorRef, safeToFree []storage.Range) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ReleaseSealed(ctx context.Context, sector storage.SectorRef) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ReleaseSectorKey(ctx context.Context, sector storage.SectorRef) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ReleaseReplicaUpgrade(ctx context.Context, sector storage.SectorRef) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) Remove(ctx context.Context, sector storage.SectorRef) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ReplicaUpdate(ctx context.Context, sector storage.SectorRef, pieces []abi.PieceInfo) (storage.ReplicaUpdateOut, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ProveReplicaUpdate1(ctx context.Context, sector storage.SectorRef, sectorKey, newSealed, newUnsealed cid.Cid) (storage.ReplicaVanillaProofs, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ProveReplicaUpdate2(ctx context.Context, sector storage.SectorRef, sectorKey, newSealed, newUnsealed cid.Cid, vanillaProofs storage.ReplicaVanillaProofs) (storage.ReplicaUpdateProof, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) GenerateSectorKeyFromData(ctx context.Context, sector storage.SectorRef, commD cid.Cid) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) NewSector(ctx context.Context, sector storage.SectorRef) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) AddPiece(ctx context.Context, sector storage.SectorRef, pieceSizes []abi.UnpaddedPieceSize, newPieceSize abi.UnpaddedPieceSize, pieceData storage.Data) (abi.PieceInfo, error) {
|
|
resp := make(chan apres)
|
|
t.apch <- resp
|
|
ar := <-resp
|
|
return ar.pi, ar.err
|
|
}
|
|
|
|
func (t *testExec) UnsealPiece(ctx context.Context, sector storage.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize, randomness abi.SealRandomness, commd cid.Cid) error {
|
|
panic("implement me")
|
|
}
|
|
|
|
func (t *testExec) ReadPiece(ctx context.Context, writer io.Writer, sector storage.SectorRef, offset storiface.UnpaddedByteIndex, size abi.UnpaddedPieceSize) (bool, error) {
|
|
panic("implement me")
|
|
}
|
|
|
|
var _ ffiwrapper.Storage = &testExec{}
|