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

Respect context

Browse Source
This commit is contained in:
zenground0 2022-11-07 16:03:22 +00:00
parent 6dee0d8ca8
commit c902218baf
1 changed files with 9 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

11
storage/pipeline/states_replica_update.go
View File

@ -226,12 +226,19 @@ func (m *Sealing) handleWaitMutable(ctx statemachine.Context, sector SectorInfo)
// Sleep for immutable epochs
if immutable {
dlineEpochsRemaining := dlinfo.NextOpen() - ts.Height()
waitTime := time.Duration(0)
if sectorDeadlineOpen {
// sleep for remainder of deadline
time.Sleep(time.Duration(build.BlockDelaySecs) * time.Second * time.Duration(dlineEpochsRemaining))
waitTime = time.Duration(build.BlockDelaySecs) * time.Second * time.Duration(dlineEpochsRemaining)
} else {
// sleep for remainder of deadline and next one
time.Sleep(time.Duration(build.BlockDelaySecs) * time.Second * time.Duration(dlineEpochsRemaining+dlinfo.WPoStChallengeWindow))
waitTime = time.Duration(build.BlockDelaySecs) * time.Second * time.Duration(dlineEpochsRemaining+dlinfo.WPoStChallengeWindow)
}
select {
case <-time.After(waitTime):
case <-ctx.Context().Done():
return ctx.Context().Err()
}
}
}