(ctx context.Context, bucketName, bucketPath, uploadID *string)
| 636 | } |
| 637 | |
| 638 | func (f *Fs) abortMultiPartUpload(ctx context.Context, bucketName, bucketPath, uploadID *string) (err error) { |
| 639 | if uploadID == nil || *uploadID == "" { |
| 640 | return nil |
| 641 | } |
| 642 | request := objectstorage.AbortMultipartUploadRequest{ |
| 643 | NamespaceName: common.String(f.opt.Namespace), |
| 644 | BucketName: bucketName, |
| 645 | ObjectName: bucketPath, |
| 646 | UploadId: uploadID, |
| 647 | } |
| 648 | err = f.pacer.Call(func() (bool, error) { |
| 649 | resp, err := f.srv.AbortMultipartUpload(ctx, request) |
| 650 | return shouldRetry(ctx, resp.HTTPResponse(), err) |
| 651 | }) |
| 652 | return err |
| 653 | } |
| 654 | |
| 655 | // cleanUpBucket removes all pending multipart uploads for a given bucket over the age of maxAge |
| 656 | func (f *Fs) cleanUpBucket(ctx context.Context, bucket string, maxAge time.Duration, |
no test coverage detected