for attempts <= 3 {
				aerr := api.AbortMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, ObjectOptions{})
				if aerr == nil {
					return
				}
				batchLogIf(ctx,
					fmt.Errorf("trying %s: Unable to cleanup failed multipart replication %s on remote %s/%s: %w - this may consume space on remote cluster",
						humanize.Ordinal(attempts), res.UploadID, tgtBucket, tgtObject, aerr))
				attempts++

			if err != nil {
				return nil, err
			}
			legacyJSON = true
		}

		if len(buf) == 0 {
			if errors.Is(err, errFileNotFound) && !skipAccessChecks(volume) {
				if aerr := Access(volumeDir); aerr != nil && osIsNotExist(aerr) {
					return nil, errVolumeNotFound
				}
				return nil, errFileNotFound
			}
		}
		return buf, nil
	})
	if err != nil {
		return err
	}

			// block and abort remote upload upon failure.
			attempts := 1
			for attempts <= 3 {
				actx, acancel := context.WithTimeout(ctx, time.Minute)
				aerr := c.AbortMultipartUpload(actx, bucket, object, uploadID)
				acancel()
				if aerr == nil {
					return
				}
				attempts++
				time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
			}
		}
	}()

	var (