sealing: Actually call handleSealFailed
This commit is contained in:
parent
2715ff763f
commit
74095b25c5
4
fsm.go
4
fsm.go
@ -88,7 +88,7 @@ func (m *Sealing) plan(events []statemachine.Event, state *SectorInfo) (func(sta
|
|||||||
|
|
||||||
p := fsmPlanners[state.State]
|
p := fsmPlanners[state.State]
|
||||||
if p == nil {
|
if p == nil {
|
||||||
return nil, xerrors.Errorf("planner for state %s not found", state.State, api.SectorStates[state.State])
|
return nil, xerrors.Errorf("planner for state %s not found", api.SectorStates[state.State])
|
||||||
}
|
}
|
||||||
|
|
||||||
if err := p(events, state); err != nil {
|
if err := p(events, state); err != nil {
|
||||||
@ -152,7 +152,7 @@ func (m *Sealing) plan(events []statemachine.Event, state *SectorInfo) (func(sta
|
|||||||
|
|
||||||
// Handled failure modes
|
// Handled failure modes
|
||||||
case api.SealFailed:
|
case api.SealFailed:
|
||||||
log.Warnf("sector %d entered unimplemented state 'SealFailed'", state.SectorID)
|
return m.handleSealFailed, nil
|
||||||
case api.PreCommitFailed:
|
case api.PreCommitFailed:
|
||||||
log.Warnf("sector %d entered unimplemented state 'PreCommitFailed'", state.SectorID)
|
log.Warnf("sector %d entered unimplemented state 'PreCommitFailed'", state.SectorID)
|
||||||
case api.SealCommitFailed:
|
case api.SealCommitFailed:
|
||||||
|
Loading…
Reference in New Issue
Block a user