MCPcopy Index your code
hub / github.com/rclone/rclone / abortMultiPartUpload

Method abortMultiPartUpload

backend/oracleobjectstorage/oracleobjectstorage.go:638–653  ·  view source on GitHub ↗
(ctx context.Context, bucketName, bucketPath, uploadID *string)

Source from the content-addressed store, hash-verified

636}
637
638func (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
656func (f *Fs) cleanUpBucket(ctx context.Context, bucket string, maxAge time.Duration,

Callers 2

cleanUpBucketMethod · 0.95
AbortMethod · 0.80

Calls 3

shouldRetryFunction · 0.70
StringMethod · 0.65
CallMethod · 0.45

Tested by

no test coverage detected