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

Merge pull request #1168 from filecoin-project/bugs/invalid-state-transition

Browse Source 
planCommitting must handle SectorCommitFailed
This commit is contained in:
Łukasz Magiera 2020-01-28 23:32:42 +01:00 committed by GitHub
commit b60860456d
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
2 changed files with 16 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
storage/sealing/fsm.go
View File

@ -205,6 +205,8 @@ func planCommitting(events []statemachine.Event, state *SectorInfo) error {
state.State = api.SealCommitFailed state.State = api.SealCommitFailed
case SectorSealFailed: case SectorSealFailed:
state.State = api.CommitFailed state.State = api.CommitFailed
case SectorCommitFailed:
state.State = api.CommitFailed
default: default:
return xerrors.Errorf("planCommitting got event of unknown type %T, events: %+v", event.User, events) return xerrors.Errorf("planCommitting got event of unknown type %T, events: %+v", event.User, events)
} }

14
storage/sealing/fsm_test.go
View File

@ -83,3 +83,17 @@ func TestSeedRevert(t *testing.T) {
m.planSingle(SectorProving{}) m.planSingle(SectorProving{})
require.Equal(m.t, m.state.State, api.Proving) require.Equal(m.t, m.state.State, api.Proving)
} }
func TestPlanCommittingHandlesSectorCommitFailed(t *testing.T) {
m := test{
s: &Sealing{},
t: t,
state: &SectorInfo{State: api.Committing},
}
events := []statemachine.Event{{SectorCommitFailed{}}}
require.NoError(t, planCommitting(events, m.state))
require.Equal(t, api.SectorStates[api.CommitFailed], api.SectorStates[m.state.State])
}