diff --git a/itests/ccupgrade_test.go b/itests/ccupgrade_test.go index 6e7a5d090..b8e58643f 100644 --- a/itests/ccupgrade_test.go +++ b/itests/ccupgrade_test.go @@ -10,7 +10,6 @@ import ( "github.com/filecoin-project/go-address" "github.com/filecoin-project/go-state-types/abi" "github.com/filecoin-project/go-state-types/network" - "github.com/filecoin-project/lotus/api" "github.com/filecoin-project/lotus/chain/types" "github.com/filecoin-project/lotus/itests/kit" @@ -89,18 +88,6 @@ func runTestCCUpgrade(t *testing.T) *kit.TestFullNode { return client } -func waitForDeadline(ctx context.Context, t *testing.T, waitIdx uint64, node *kit.TestFullNode, maddr address.Address) { - for { - ts, err := node.ChainHead(ctx) - require.NoError(t, err) - dl, err := node.StateMinerProvingDeadline(ctx, maddr, ts.Key()) - require.NoError(t, err) - if dl.Index == waitIdx { - return - } - } -} - func waitForSectorActive(ctx context.Context, t *testing.T, sn abi.SectorNumber, node *kit.TestFullNode, maddr address.Address) { for { active, err := node.StateMinerActiveSectors(ctx, maddr, types.EmptyTSK) @@ -116,18 +103,6 @@ func waitForSectorActive(ctx context.Context, t *testing.T, sn abi.SectorNumber, } } -func waitForSectorStartUpgrade(ctx context.Context, t *testing.T, sn abi.SectorNumber, miner *kit.TestMiner) { - for { - si, err := miner.StorageMiner.SectorsStatus(ctx, sn, false) - require.NoError(t, err) - if si.State != api.SectorState("Proving") { - t.Logf("Done proving sector in state: %s", si.State) - return - } - - } -} - func TestCCUpgradeAndPoSt(t *testing.T) { kit.QuietMiningLogs() t.Run("upgrade and then post", func(t *testing.T) { @@ -147,48 +122,3 @@ func TestCCUpgradeAndPoSt(t *testing.T) { }) }) } - -func TestTooManyMarkedForUpgrade(t *testing.T) { - kit.QuietMiningLogs() - - ctx := context.Background() - blockTime := 1 * time.Millisecond - - client, miner, ens := kit.EnsembleMinimal(t, kit.GenesisNetworkVersion(network.Version15)) - ens.InterconnectAll().BeginMiningMustPost(blockTime) - - maddr, err := miner.ActorAddress(ctx) - if err != nil { - t.Fatal(err) - } - - CCUpgrade := abi.SectorNumber(kit.DefaultPresealsPerBootstrapMiner + 1) - waitForDeadline(ctx, t, 1, client, maddr) - miner.PledgeSectors(ctx, 3, 0, nil) - - sl, err := miner.SectorsList(ctx) - require.NoError(t, err) - require.Len(t, sl, 3, "expected 3 sectors") - - { - si, err := client.StateSectorGetInfo(ctx, maddr, CCUpgrade, types.EmptyTSK) - require.NoError(t, err) - require.Less(t, 50000, int(si.Expiration)) - } - - waitForSectorActive(ctx, t, CCUpgrade, client, maddr) - waitForSectorActive(ctx, t, CCUpgrade+1, client, maddr) - waitForSectorActive(ctx, t, CCUpgrade+2, client, maddr) - - err = miner.SectorMarkForUpgrade(ctx, CCUpgrade, true) - require.NoError(t, err) - err = miner.SectorMarkForUpgrade(ctx, CCUpgrade+1, true) - require.NoError(t, err) - - waitForSectorStartUpgrade(ctx, t, CCUpgrade, miner) - waitForSectorStartUpgrade(ctx, t, CCUpgrade+1, miner) - - err = miner.SectorMarkForUpgrade(ctx, CCUpgrade+2, true) - require.Error(t, err) - assert.Contains(t, err.Error(), "no free resources to wait for deals") -}