-
Notifications
You must be signed in to change notification settings - Fork 1.3k
Commit
This commit does not belong to any branch on this repository, and may belong to a fork outside of the repository.
Merge pull request #8959 from filecoin-project/feat/post-check-config
sealer: Config for disabling builtin PoSt / PoSt pre-checks
- Loading branch information
Showing
16 changed files
with
899 additions
and
290 deletions.
There are no files selected for viewing
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
This file contains bidirectional Unicode text that may be interpreted or compiled differently than what appears below. To review, open the file in an editor that reveals hidden Unicode characters.
Learn more about bidirectional Unicode characters
| Original file line number | Diff line number | Diff line change |
|---|---|---|
| @@ -0,0 +1,188 @@ | ||
| package itests | ||
|
|
||
| import ( | ||
| "context" | ||
| "testing" | ||
| "time" | ||
|
|
||
| "github.com/stretchr/testify/require" | ||
|
|
||
| "github.com/filecoin-project/go-address" | ||
| "github.com/filecoin-project/go-state-types/abi" | ||
|
|
||
| "github.com/filecoin-project/lotus/chain/types" | ||
| "github.com/filecoin-project/lotus/itests/kit" | ||
| "github.com/filecoin-project/lotus/node" | ||
| "github.com/filecoin-project/lotus/node/config" | ||
| "github.com/filecoin-project/lotus/node/impl" | ||
| "github.com/filecoin-project/lotus/node/modules" | ||
| "github.com/filecoin-project/lotus/storage/sealer/mock" | ||
| "github.com/filecoin-project/lotus/storage/sealer/storiface" | ||
| "github.com/filecoin-project/lotus/storage/wdpost" | ||
| ) | ||
|
|
||
| func TestWindowPostNoPreChecks(t *testing.T) { | ||
| ctx, cancel := context.WithCancel(context.Background()) | ||
| defer cancel() | ||
|
|
||
| client, miner, ens := kit.EnsembleMinimal(t, | ||
| kit.LatestActorsAt(-1), | ||
| kit.MockProofs(), | ||
| kit.ConstructorOpts( | ||
| node.Override(new(*wdpost.WindowPoStScheduler), modules.WindowPostScheduler( | ||
| config.DefaultStorageMiner().Fees, | ||
| config.ProvingConfig{ | ||
| DisableWDPoStPreChecks: true, | ||
| }, | ||
| )))) | ||
| ens.InterconnectAll().BeginMining(2 * time.Millisecond) | ||
|
|
||
| nSectors := 10 | ||
|
|
||
| miner.PledgeSectors(ctx, nSectors, 0, nil) | ||
|
|
||
| maddr, err := miner.ActorAddress(ctx) | ||
| require.NoError(t, err) | ||
| di, err := client.StateMinerProvingDeadline(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| mid, err := address.IDFromAddress(maddr) | ||
| require.NoError(t, err) | ||
|
|
||
| t.Log("Running one proving period") | ||
| waitUntil := di.Open + di.WPoStProvingPeriod | ||
| t.Logf("End for head.Height > %d", waitUntil) | ||
|
|
||
| ts := client.WaitTillChain(ctx, kit.HeightAtLeast(waitUntil)) | ||
| t.Logf("Now head.Height = %d", ts.Height()) | ||
|
|
||
| p, err := client.StateMinerPower(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| ssz, err := miner.ActorSectorSize(ctx, maddr) | ||
| require.NoError(t, err) | ||
|
|
||
| require.Equal(t, p.MinerPower, p.TotalPower) | ||
| require.Equal(t, p.MinerPower.RawBytePower, types.NewInt(uint64(ssz)*uint64(nSectors+kit.DefaultPresealsPerBootstrapMiner))) | ||
|
|
||
| t.Log("Drop some sectors") | ||
|
|
||
| // Drop 2 sectors from deadline 2 partition 0 (full partition / deadline) | ||
| { | ||
| parts, err := client.StateMinerPartitions(ctx, maddr, 2, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
| require.Greater(t, len(parts), 0) | ||
|
|
||
| secs := parts[0].AllSectors | ||
| n, err := secs.Count() | ||
| require.NoError(t, err) | ||
| require.Equal(t, uint64(2), n) | ||
|
|
||
| // Drop the partition | ||
| err = secs.ForEach(func(sid uint64) error { | ||
| return miner.StorageMiner.(*impl.StorageMinerAPI).IStorageMgr.(*mock.SectorMgr).MarkCorrupted(storiface.SectorRef{ | ||
| ID: abi.SectorID{ | ||
| Miner: abi.ActorID(mid), | ||
| Number: abi.SectorNumber(sid), | ||
| }, | ||
| }, true) | ||
| }) | ||
| require.NoError(t, err) | ||
| } | ||
|
|
||
| var s storiface.SectorRef | ||
|
|
||
| // Drop 1 sectors from deadline 3 partition 0 | ||
| { | ||
| parts, err := client.StateMinerPartitions(ctx, maddr, 3, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
| require.Greater(t, len(parts), 0) | ||
|
|
||
| secs := parts[0].AllSectors | ||
| n, err := secs.Count() | ||
| require.NoError(t, err) | ||
| require.Equal(t, uint64(2), n) | ||
|
|
||
| // Drop the sector | ||
| sn, err := secs.First() | ||
| require.NoError(t, err) | ||
|
|
||
| all, err := secs.All(2) | ||
| require.NoError(t, err) | ||
| t.Log("the sectors", all) | ||
|
|
||
| s = storiface.SectorRef{ | ||
| ID: abi.SectorID{ | ||
| Miner: abi.ActorID(mid), | ||
| Number: abi.SectorNumber(sn), | ||
| }, | ||
| } | ||
|
|
||
| err = miner.StorageMiner.(*impl.StorageMinerAPI).IStorageMgr.(*mock.SectorMgr).MarkFailed(s, true) | ||
| require.NoError(t, err) | ||
| } | ||
|
|
||
| di, err = client.StateMinerProvingDeadline(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| t.Log("Go through another PP, wait for sectors to become faulty") | ||
| waitUntil = di.Open + di.WPoStProvingPeriod | ||
| t.Logf("End for head.Height > %d", waitUntil) | ||
|
|
||
| ts = client.WaitTillChain(ctx, kit.HeightAtLeast(waitUntil)) | ||
| t.Logf("Now head.Height = %d", ts.Height()) | ||
|
|
||
| p, err = client.StateMinerPower(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| require.Equal(t, p.MinerPower, p.TotalPower) | ||
|
|
||
| sectors := p.MinerPower.RawBytePower.Uint64() / uint64(ssz) | ||
| require.Equal(t, nSectors+kit.DefaultPresealsPerBootstrapMiner-3, int(sectors)) // -3 just removed sectors | ||
|
|
||
| t.Log("Recover one sector") | ||
|
|
||
| err = miner.StorageMiner.(*impl.StorageMinerAPI).IStorageMgr.(*mock.SectorMgr).MarkFailed(s, false) | ||
| require.NoError(t, err) | ||
|
|
||
| di, err = client.StateMinerProvingDeadline(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| waitUntil = di.Open + di.WPoStProvingPeriod | ||
| t.Logf("End for head.Height > %d", waitUntil) | ||
|
|
||
| ts = client.WaitTillChain(ctx, kit.HeightAtLeast(waitUntil)) | ||
| t.Logf("Now head.Height = %d", ts.Height()) | ||
|
|
||
| p, err = client.StateMinerPower(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| require.Equal(t, p.MinerPower, p.TotalPower) | ||
|
|
||
| sectors = p.MinerPower.RawBytePower.Uint64() / uint64(ssz) | ||
| require.Equal(t, nSectors+kit.DefaultPresealsPerBootstrapMiner-2, int(sectors)) // -2 not recovered sectors | ||
|
|
||
| // pledge a sector after recovery | ||
|
|
||
| miner.PledgeSectors(ctx, 1, nSectors, nil) | ||
|
|
||
| { | ||
| // Wait until proven. | ||
| di, err = client.StateMinerProvingDeadline(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| waitUntil := di.Open + di.WPoStProvingPeriod | ||
| t.Logf("End for head.Height > %d\n", waitUntil) | ||
|
|
||
| ts := client.WaitTillChain(ctx, kit.HeightAtLeast(waitUntil)) | ||
| t.Logf("Now head.Height = %d", ts.Height()) | ||
| } | ||
|
|
||
| p, err = client.StateMinerPower(ctx, maddr, types.EmptyTSK) | ||
| require.NoError(t, err) | ||
|
|
||
| require.Equal(t, p.MinerPower, p.TotalPower) | ||
|
|
||
| sectors = p.MinerPower.RawBytePower.Uint64() / uint64(ssz) | ||
| require.Equal(t, nSectors+kit.DefaultPresealsPerBootstrapMiner-2+1, int(sectors)) // -2 not recovered sectors + 1 just pledged | ||
| } |
Oops, something went wrong.