cerc-io/lotus
16
0
Fork 0
Code Issues Pull Requests Packages Projects Releases 27 Wiki Activity

Merge pull request #6537 from filecoin-project/test/pledge-batching-msg-prop

Browse Source 
Test/pledge batching msg prop
This commit is contained in:
Steven Allen 2021-07-29 21:07:21 -07:00 committed by GitHub
commit 73b2b5f384
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 80 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

80
itests/sector_pledge_test.go
View File

@ -7,12 +7,17 @@ import (
"testing"
"time"
"github.com/filecoin-project/go-state-types/abi"
"github.com/filecoin-project/lotus/itests/kit"
"github.com/stretchr/testify/assert"
"github.com/stretchr/testify/require"
"github.com/filecoin-project/lotus/api"
"github.com/filecoin-project/lotus/build"
"github.com/filecoin-project/lotus/chain/types"
sealing "github.com/filecoin-project/lotus/extern/storage-sealing"
"github.com/filecoin-project/lotus/node/impl"
miner5 "github.com/filecoin-project/specs-actors/v5/actors/builtin/miner"
)
func TestPledgeSectors(t *testing.T) {
@ -104,6 +109,81 @@ func TestPledgeBatching(t *testing.T) {
})
}
func TestPledgeMaxBatching(t *testing.T) {
blockTime := 50 * time.Millisecond
runTest := func(t *testing.T) {
nSectors := miner5.MaxAggregatedSectors
ctx, cancel := context.WithCancel(context.Background())
defer cancel()
opts := kit.ConstructorOpts(kit.LatestActorsAt(-1))
client, full, miner, ens := kit.EnsembleTwoOne(t, kit.MockProofs(), opts)
ens.InterconnectAll().BeginMining(blockTime)
m, ok := miner.StorageMiner.(*impl.StorageMinerAPI)
require.True(t, ok)
cfg, err := m.GetSealingConfigFunc()
require.NoError(t, err)
cfg.MinCommitBatch = miner5.MaxAggregatedSectors
require.NoError(t, m.SetSealingConfigFunc(cfg))
client.WaitTillChain(ctx, kit.HeightAtLeast(10))
toCheck := miner.StartPledge(ctx, nSectors, 0, nil)
var lastSectorNo abi.SectorNumber
for len(toCheck) > 0 {
states := map[api.SectorState]int{}
for n := range toCheck {
lastSectorNo = n
st, err := miner.SectorsStatus(ctx, n, false)
require.NoError(t, err)
states[st.State]++
if st.State == api.SectorState(sealing.Proving) {
delete(toCheck, n)
}
if strings.Contains(string(st.State), "Fail") {
t.Fatal("sector in a failed state", st.State)
}
}
if states[api.SectorState(sealing.SubmitPreCommitBatch)] == nSectors ||
(states[api.SectorState(sealing.SubmitPreCommitBatch)] > 0 && states[api.SectorState(sealing.PreCommit1)] == 0 && states[api.SectorState(sealing.PreCommit2)] == 0) {
pcb, err := miner.SectorPreCommitFlush(ctx)
require.NoError(t, err)
if pcb != nil {
fmt.Printf("PRECOMMIT BATCH: %+v\n", pcb)
}
}
if states[api.SectorState(sealing.SubmitCommitAggregate)] == nSectors {
cb, err := miner.SectorCommitFlush(ctx)
require.NoError(t, err)
if cb != nil {
fmt.Printf("COMMIT BATCH: %+v\n", cb)
}
}
build.Clock.Sleep(100 * time.Millisecond)
fmt.Printf("WaitSeal: %d %+v\n", len(toCheck), states)
}
// Wait for flushed ProveCommitAggregate to land on chain
st, err := miner.SectorsStatus(ctx, lastSectorNo, false)
require.NoError(t, err)
for st.State == api.SectorState(sealing.CommitAggregateWait) {
build.Clock.Sleep(100 * time.Millisecond)
}
// Ensure that max aggregate message has propagated to the other node by checking current state
sectorInfosAfter, err := full.StateMinerSectors(ctx, miner.ActorAddr, nil, types.EmptyTSK)
require.NoError(t, err)
assert.Equal(t, miner5.MaxAggregatedSectors+kit.DefaultPresealsPerBootstrapMiner, len(sectorInfosAfter))
}
t.Run("Force max prove commit aggregate size", runTest)
}
func TestPledgeBeforeNv13(t *testing.T) {
blocktime := 50 * time.Millisecond