Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for Nabors (0.21 sec)

  1. cmd/erasure-server-pool.go

    			continue
    		}
    		return ListPartsInfo{}, err
    	}
    	return ListPartsInfo{}, InvalidUploadID{
    		Bucket:   bucket,
    		Object:   object,
    		UploadID: uploadID,
    	}
    }
    
    // Aborts an in-progress multipart operation on hashedSet based on the object name.
    func (z *erasureServerPools) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) error {
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  2. cmd/batch-handlers.go

    	var uploadedParts []CompletePart
    	res, err := api.NewMultipartUpload(context.Background(), tgtBucket, tgtObject, opts)
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    			// block and abort remote upload upon failure.
    			attempts := 1
    			for attempts <= 3 {
    				aerr := api.AbortMultipartUpload(ctx, tgtBucket, tgtObject, res.UploadID, ObjectOptions{})
    				if aerr == nil {
    					return
    				}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 55.2K bytes
    - Viewed (0)
  3. cmd/erasure-sets.go

    	set := s.getHashedSet(object)
    	return set.ListObjectParts(ctx, bucket, object, uploadID, partNumberMarker, maxParts, opts)
    }
    
    // Aborts an in-progress multipart operation on hashedSet based on the object name.
    func (s *erasureSets) AbortMultipartUpload(ctx context.Context, bucket, object, uploadID string, opts ObjectOptions) error {
    	set := s.getHashedSet(object)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 37.7K bytes
    - Viewed (5)
  4. cmd/bucket-replication.go

    			return err
    		}
    		attempts++
    		time.Sleep(time.Duration(rand.Int63n(int64(time.Second))))
    	}
    	if err != nil {
    		return err
    	}
    
    	defer func() {
    		if err != nil {
    			// 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()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Wed May 01 01:09:56 GMT 2024
    - 112.2K bytes
    - Viewed (1)
Back to top