storagenode/gracefulexit: fix wrong error handling for corrupted pieces (#3930)
This commit is contained in:
parent
959cd5cd83
commit
db57d76ee9
@ -239,6 +239,7 @@ func (worker *Worker) transferPiece(ctx context.Context, transferPiece *pb.Trans
|
||||
zap.Stringer("Piece ID", pieceID),
|
||||
zap.Error(errs.Wrap(err)))
|
||||
worker.handleFailure(ctx, pb.TransferFailed_NOT_FOUND, pieceID, c.Send)
|
||||
return err
|
||||
}
|
||||
|
||||
if worker.minBytesPerSecond == 0 {
|
||||
|
Loading…
Reference in New Issue
Block a user