storgefsm: Use locks correctly
This commit is contained in:
parent
5c605d99e2
commit
957d3f0636
2
extern/storage-sealing/fsm.go
vendored
2
extern/storage-sealing/fsm.go
vendored
@ -412,7 +412,7 @@ func (m *Sealing) onUpdateSector(ctx context.Context, state *SectorInfo) error {
|
|||||||
// trigger more input processing when we've dipped below max sealing limits
|
// trigger more input processing when we've dipped below max sealing limits
|
||||||
if shouldUpdateInput {
|
if shouldUpdateInput {
|
||||||
go func() {
|
go func() {
|
||||||
m.inputLk.Unlock()
|
m.inputLk.Lock()
|
||||||
defer m.inputLk.Unlock()
|
defer m.inputLk.Unlock()
|
||||||
|
|
||||||
if err := m.updateInput(ctx, sp); err != nil {
|
if err := m.updateInput(ctx, sp); err != nil {
|
||||||
|
Loading…
Reference in New Issue
Block a user