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

more fixes to wdpost worker tests

Browse Source
This commit is contained in:
Łukasz Magiera 2023-12-04 20:00:33 +01:00
parent 534a7d974f
commit b12ea68e53
1 changed files with 7 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
itests/worker_test.go
View File

@ -3,6 +3,7 @@ package itests
import ( import (
"bytes" "bytes"
"context" "context"
"sort"
"strings" "strings"
"sync/atomic" "sync/atomic"
"testing" "testing"
@ -172,7 +173,7 @@ func TestWindowPostWorker(t *testing.T) {
t.Log("post message landed") t.Log("post message landed")
bm.MineBlocks(ctx, 2*time.Millisecond) bm.MineBlocksMustPost(ctx, 2*time.Millisecond)
waitUntil = di.Open + di.WPoStChallengeWindow*3 waitUntil = di.Open + di.WPoStChallengeWindow*3
t.Logf("End for head.Height > %d", waitUntil) t.Logf("End for head.Height > %d", waitUntil)
@ -648,6 +649,11 @@ waitForProof:
require.NoError(t, params.UnmarshalCBOR(bytes.NewBuffer(slmsg.Params))) require.NoError(t, params.UnmarshalCBOR(bytes.NewBuffer(slmsg.Params)))
require.Equal(t, abi.RegisteredPoStProof_StackedDrgWindow2KiBV1_1, params.Proofs[0].PoStProof) require.Equal(t, abi.RegisteredPoStProof_StackedDrgWindow2KiBV1_1, params.Proofs[0].PoStProof)
// sort params.Partitions by index
sort.Slice(params.Partitions, func(i, j int) bool {
return params.Partitions[i].Index < params.Partitions[j].Index
})
require.Len(t, params.Partitions, 2) require.Len(t, params.Partitions, 2)
sc0, err := params.Partitions[0].Skipped.Count() sc0, err := params.Partitions[0].Skipped.Count()
require.NoError(t, err) require.NoError(t, err)