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

switch pledging func

Browse Source
This commit is contained in:
LexLuthr 2022-08-03 22:32:12 +05:30
parent b15f1e5b93
commit 4e2536e0ef
1 changed files with 11 additions and 7 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

18
itests/worker_test.go
View File

@ -426,7 +426,7 @@ func TestSchedulerRemoveRequest(t *testing.T) {
Requests []SchedDiagRequestInfo Requests []SchedDiagRequestInfo
OpenWindows []string OpenWindows []string
} }
type i struct { type info struct {
SchedInfo interface{} SchedInfo interface{}
ReturnedWork []string ReturnedWork []string
Waiting []string Waiting []string
@ -434,10 +434,14 @@ func TestSchedulerRemoveRequest(t *testing.T) {
EarlyRet []string EarlyRet []string
} }
go miner.PledgeSectors(ctx, 1, 0, nil) tocheck := miner.StartPledge(ctx, 1, 0, nil)
var sn abi.SectorNumber
for n := range tocheck {
sn = n
}
// Keep checking till sector state is PC2, the request should get stuck as worker cannot process PC2 // Keep checking till sector state is PC2, the request should get stuck as worker cannot process PC2
for { for {
st, err := miner.SectorsStatus(ctx, abi.SectorNumber(1), false) st, err := miner.SectorsStatus(ctx, sn, false)
require.NoError(t, err) require.NoError(t, err)
if st.State == api.SectorState(sealing.PreCommit2) { if st.State == api.SectorState(sealing.PreCommit2) {
break break
@ -454,8 +458,8 @@ func TestSchedulerRemoveRequest(t *testing.T) {
var schedidb uuid.UUID var schedidb uuid.UUID
// cast scheduler info and get the request UUID. Call the SealingRemoveRequest() // cast scheduler info and get the request UUID. Call the SealingRemoveRequest()
if schedb.(i).SchedInfo.(SchedDiagInfo).Requests[0].TaskType == "seal/v0/precommit/2" { if schedb.(info).SchedInfo.(SchedDiagInfo).Requests[0].TaskType == "seal/v0/precommit/2" {
schedidb = schedb.(i).SchedInfo.(SchedDiagInfo).Requests[0].SchedId schedidb = schedb.(info).SchedInfo.(SchedDiagInfo).Requests[0].SchedId
err = miner.SealingRemoveRequest(ctx, schedidb) err = miner.SealingRemoveRequest(ctx, schedidb)
if err != nil { if err != nil {
t.Log("Failed to dump scheduler state before: %w", err) t.Log("Failed to dump scheduler state before: %w", err)
@ -471,8 +475,8 @@ func TestSchedulerRemoveRequest(t *testing.T) {
t.FailNow() t.FailNow()
} }
if len(scheda.(i).SchedInfo.(SchedDiagInfo).Requests) > 0 && scheda.(i).SchedInfo.(SchedDiagInfo).Requests[0].TaskType == "seal/v0/precommit/2" { if len(scheda.(info).SchedInfo.(SchedDiagInfo).Requests) > 0 && scheda.(info).SchedInfo.(SchedDiagInfo).Requests[0].TaskType == "seal/v0/precommit/2" {
schedida := scheda.(i).SchedInfo.(SchedDiagInfo).Requests[0].SchedId schedida := scheda.(info).SchedInfo.(SchedDiagInfo).Requests[0].SchedId
require.NotEqual(t, schedida, schedidb) require.NotEqual(t, schedida, schedidb)
} }
} }