Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 11 for toObjectErr (0.06 sec)

  1. cmd/erasure-object.go

    	if err != nil {
    		return objInfo, toObjectErr(err, bucket, object)
    	}
    	objInfo = fi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended)
    	if fi.Deleted {
    		if opts.VersionID == "" || opts.DeleteMarker {
    			return objInfo, toObjectErr(errFileNotFound, bucket, object)
    		}
    		// Make sure to return object info to provide extra information.
    		return objInfo, toObjectErr(errMethodNotAllowed, bucket, object)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		return pi, toObjectErr(errInvalidArgument)
    	}
    
    	uploadIDPath := er.getUploadIDDir(bucket, object, uploadID)
    	// Validates if upload ID exists.
    	fi, _, err := er.checkUploadIDExists(ctx, bucket, object, uploadID, true)
    	if err != nil {
    		if errors.Is(err, errVolumeNotFound) {
    			return pi, toObjectErr(err, bucket)
    		}
    		return pi, toObjectErr(err, bucket, object, uploadID)
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  3. cmd/erasure-object_test.go

    	if err != nil {
    		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    			t.Errorf("Expected GetObject to fail with %v, but failed with %v", toObjectErr(errErasureReadQuorum, bucket, object), err)
    		}
    	}
    	if gr != nil {
    		_, err = io.Copy(io.Discard, gr)
    		if err != toObjectErr(errErasureReadQuorum, bucket, object) {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 38.3K bytes
    - Viewed (0)
  4. cmd/peer-s3-client.go

    			return madmin.HealResultItem{}, poolErr
    		}
    	}
    
    	if healBucketErr := reduceWriteQuorumErrs(ctx, errs, bucketOpIgnoredErrs, len(errs)/2+1); healBucketErr != nil {
    		return madmin.HealResultItem{}, toObjectErr(healBucketErr, bucket)
    	}
    
    	res := madmin.HealResultItem{
    		Type:     madmin.HealItemBucket,
    		Bucket:   bucket,
    		SetCount: -1, // explicitly set an invalid value -1, for bucket heal scenario
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 15.6K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    			return toObjectErr(err, bucket)
    		}
    
    		select {
    		case <-ctx.Done():
    			return ctx.Err()
    		case r, found := <-results:
    			if found {
    				if r.Err != nil {
    					s3LogIf(ctx, fmt.Errorf("unable to verify if the bucket %s is empty: %w", bucket, r.Err))
    					return toObjectErr(r.Err, bucket)
    				}
    				return toObjectErr(errVolumeNotEmpty, bucket)
    			}
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 89.1K bytes
    - Viewed (0)
  6. cmd/erasure-healing.go

    	// Healing directories handle it separately.
    	if HasSuffix(object, SlashSeparator) {
    		hr, err := er.healObjectDir(healCtx, bucket, object, opts.DryRun, opts.Remove)
    		return hr, toObjectErr(err, bucket, object)
    	}
    
    	storageDisks := er.getDisks()
    	storageEndpoints := er.getEndpoints()
    
    	// When versionID is empty, we read directly from the `null` versionID for healing.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.6K bytes
    - Viewed (0)
  7. cmd/metacache-set.go

    		// Read metadata associated with the object from all disks.
    		fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, minioMetaBucket, o.objectPath(0), ObjectOptions{}, true)
    		if err != nil {
    			switch toObjectErr(err, minioMetaBucket, o.objectPath(0)).(type) {
    			case ObjectNotFound, InsufficientReadQuorum:
    				retryWait()
    				continue
    			}
    			// Allow one fast retry for other errors.
    			if retries > 0 {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 30.7K bytes
    - Viewed (0)
  8. cmd/utils.go

    	case "EntityTooSmall":
    		err = PartTooSmall{}
    	case "ReplicationPermissionCheck":
    		err = ReplicationPermissionCheck{}
    	}
    
    	if minioErr.StatusCode == http.StatusMethodNotAllowed {
    		err = toObjectErr(errMethodNotAllowed, bucket, object)
    	}
    	return err
    }
    
    // returns 'true' if either string has space in the
    // - beginning of a string
    // OR
    // - end of a string
    func hasSpaceBE(s string) bool {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33K bytes
    - Viewed (0)
  9. cmd/test-utils_test.go

    	for i := 0; i < n-1; i++ {
    		j = i + rand.Intn(n-i)
    		s[i], s[j] = s[j], s[i]
    	}
    	return s
    }
    
    func TestToErrIsNil(t *testing.T) {
    	if toObjectErr(nil) != nil {
    		t.Errorf("Test expected to return nil, failed instead got a non-nil value %s", toObjectErr(nil))
    	}
    	if toStorageErr(nil) != nil {
    		t.Errorf("Test expected to return nil, failed instead got a non-nil value %s", toStorageErr(nil))
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 77K bytes
    - Viewed (0)
  10. cmd/data-usage-cache.go

    		r.Close()
    		return err != nil, nil
    	}
    
    	// Caches are read+written without locks,
    	retries := 0
    	for retries < 5 {
    		retry, err := load(name, time.Minute)
    		if err != nil {
    			return toObjectErr(err, dataUsageBucket, name)
    		}
    		if !retry {
    			break
    		}
    		retry, err = load(name+".bkp", 30*time.Second)
    		if err == nil && !retry {
    			// Only return when we have valid data from the backup
    			break
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 34.7K bytes
    - Viewed (0)
Back to top