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

changes as per review

Browse Source
This commit is contained in:
Aarsh Shah 2020-09-11 23:15:57 +05:30
parent 62b2963781
commit eabdf74946
1 changed files with 6 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

7
markets/storageadapter/provider.go
View File

@ -37,6 +37,7 @@ import (
) )
var addPieceRetryWait = 5 * time.Minute var addPieceRetryWait = 5 * time.Minute
var addPieceRetryTimeout = 6 * time.Hour
var log = logging.Logger("storageadapter") var log = logging.Logger("storageadapter")
type ProviderNodeAdapter struct { type ProviderNodeAdapter struct {
@ -104,7 +105,11 @@ func (n *ProviderNodeAdapter) OnDealComplete(ctx context.Context, deal storagema
} }
p, offset, err := n.secb.AddPiece(ctx, pieceSize, pieceData, sdInfo) p, offset, err := n.secb.AddPiece(ctx, pieceSize, pieceData, sdInfo)
if xerrors.Is(err, sealing.ErrTooManySectorsSealing) { curTime := time.Now()
for time.Since(curTime) < addPieceRetryTimeout {
if !xerrors.Is(err, sealing.ErrTooManySectorsSealing) {
break
}
select { select {
case <-time.After(addPieceRetryWait): case <-time.After(addPieceRetryWait):
p, offset, err = n.secb.AddPiece(ctx, pieceSize, pieceData, sdInfo) p, offset, err = n.secb.AddPiece(ctx, pieceSize, pieceData, sdInfo)