Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for toObjectErr (0.07 sec)

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  2. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Jan 30 20:43:25 UTC 2024
    - 36.8K bytes
    - Viewed (0)
  3. cmd/peer-s3-client.go

    			return madmin.HealResultItem{}, poolErr
    		}
    	}
    
    	for i, err := range errs {
    		if err == nil {
    			return healBucketResults[i], nil
    		}
    	}
    
    	return madmin.HealResultItem{}, toObjectErr(errVolumeNotFound, bucket)
    }
    
    // ListBuckets lists buckets across all nodes and returns a consistent view:
    //   - Return an error when a pool cannot return N/2+1 valid bucket information
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:26:05 UTC 2024
    - 15.4K bytes
    - Viewed (0)
  4. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 02 17:50:41 UTC 2024
    - 34.4K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 12 16:23:16 UTC 2024
    - 30.7K bytes
    - Viewed (0)
  6. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  7. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  8. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 22 15:30:50 UTC 2024
    - 34.7K bytes
    - Viewed (0)
Back to top