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

Merge pull request #10696 from filecoin-project/fix/nil-terminate-wait

Browse Source 
fix: sealing pipeline: Allow nil message in TerminateWait
This commit is contained in:
Łukasz Magiera 2023-04-25 19:28:52 +02:00 committed by GitHub
commit aeee542fb9
No known key found for this signature in database
GPG Key ID: 4AEE18F83AFDEB23
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
storage/pipeline/states_proving.go
View File

@ -81,7 +81,12 @@ func (m *Sealing) handleTerminating(ctx statemachine.Context, sector SectorInfo)
func (m *Sealing) handleTerminateWait(ctx statemachine.Context, sector SectorInfo) error { func (m *Sealing) handleTerminateWait(ctx statemachine.Context, sector SectorInfo) error {
if sector.TerminateMessage == nil { if sector.TerminateMessage == nil {
return xerrors.New("entered TerminateWait with nil TerminateMessage") ts, err := m.Api.ChainHead(ctx.Context())
if err != nil {
return ctx.Send(SectorTerminateFailed{xerrors.Errorf("getting chain head: %w", err)})
}
return ctx.Send(SectorTerminated{TerminatedAt: ts.Height()})
} }
mw, err := m.Api.StateWaitMsg(ctx.Context(), *sector.TerminateMessage, build.MessageConfidence, api.LookbackNoLimit, true) mw, err := m.Api.StateWaitMsg(ctx.Context(), *sector.TerminateMessage, build.MessageConfidence, api.LookbackNoLimit, true)