Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 13 for toObjectErr (0.42 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/data-usage.go

    	if err != nil {
    		buf, err = readConfig(ctx, objAPI, dataUsageObjNamePath+".bkp")
    		if err != nil {
    			if errors.Is(err, errConfigNotFound) {
    				return DataUsageInfo{}, nil
    			}
    			return DataUsageInfo{}, toObjectErr(err, minioMetaBucket, dataUsageObjNamePath)
    		}
    	}
    
    	var dataUsageInfo DataUsageInfo
    	json := jsoniter.ConfigCompatibleWithStandardLibrary
    	if err = json.Unmarshal(buf, &dataUsageInfo); err != nil {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu May 09 00:51:34 UTC 2024
    - 5.6K bytes
    - Viewed (0)
  7. 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)
  8. 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)
  9. cmd/object-api-errors.go

    	"errors"
    	"fmt"
    	"io"
    )
    
    // Converts underlying storage error. Convenience function written to
    // handle all cases where we have known types of errors returned by
    // underlying storage layer.
    func toObjectErr(oerr error, params ...string) error {
    	if oerr == nil {
    		return nil
    	}
    
    	// Unwarp the error first
    	err := unwrapAll(oerr)
    
    	if err == context.Canceled {
    		return context.Canceled
    	}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  10. 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)
Back to top