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

guard with ctx

Browse Source
This commit is contained in:
Aarsh Shah 2022-02-21 11:56:49 +04:00
parent 26707a5e03
commit 1245871004
1 changed files with 6 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

8
extern/storage-sealing/input.go vendored
View File

@ -340,8 +340,12 @@ func (m *Sealing) SectorAddPieceToAny(ctx context.Context, size abi.UnpaddedPiec
}
}()
res := <-resCh
return api.SectorOffset{Sector: res.sn, Offset: res.offset.Padded()}, res.err
select {
case res := <-resCh:
return api.SectorOffset{Sector: res.sn, Offset: res.offset.Padded()}, res.err
case <-ctx.Done():
return api.SectorOffset{}, ctx.Err()
}
}
func (m *Sealing) MatchPendingPiecesToOpenSectors(ctx context.Context) error {