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

Lint

Browse Source
This commit is contained in:
zenground0 2022-11-14 10:16:37 -05:00
parent d86a68f713
commit 087da50ecc
1 changed files with 5 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

6
storage/pipeline/states_replica_update.go
View File

@ -237,13 +237,17 @@ func (m *Sealing) handleWaitMutable(ctx statemachine.Context, sector SectorInfo)
} }
atHeight := make(chan struct{}) atHeight := make(chan struct{})
m.events.ChainAt(ctx.Context(), func(context.Context, *types.TipSet, abi.ChainEpoch) error { err := m.events.ChainAt(ctx.Context(), func(context.Context, *types.TipSet, abi.ChainEpoch) error {
close(atHeight) close(atHeight)
return nil return nil
}, func(ctx context.Context, ts *types.TipSet) error { }, func(ctx context.Context, ts *types.TipSet) error {
log.Warn("revert in handleWaitMutable") log.Warn("revert in handleWaitMutable")
return nil return nil
}, 5, targetEpoch) }, 5, targetEpoch)
if err != nil {
log.Errorf("handleWaitMutalbe: events error: api error, not proceeding: %w", err)
return nil
}
select { select {
case <-atHeight: case <-atHeight: