Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for isErrReadQuorum (0.05 sec)

  1. cmd/erasure-multipart-conditional_test.go

    				// Precondition fails if object exists (ETag is not empty)
    				return oi.ETag != ""
    			},
    		}
    
    		_, err := obj.NewMultipartUpload(ctx, bucket, object, opts)
    		if !isErrReadQuorum(err) {
    			t.Errorf("Expected read quorum error when if-none-match is used with quorum failure, got: %v", err)
    		}
    	})
    
    	t.Run("if-match with wrong ETag and read quorum failure", func(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 6.9K bytes
    - Viewed (0)
  2. cmd/erasure-object-conditional_test.go

    				return oi.ETag != ""
    			},
    		}
    
    		_, err := obj.PutObject(ctx, bucket, object,
    			mustGetPutObjReader(t, bytes.NewReader([]byte("new-value")),
    				int64(len("new-value")), "", ""), opts)
    		if !isErrReadQuorum(err) {
    			t.Errorf("Expected read quorum error when if-none-match is used with quorum failure, got: %v", err)
    		}
    	})
    
    	t.Run("if-match with read quorum failure", func(t *testing.T) {
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Oct 24 04:05:31 UTC 2025
    - 4.9K bytes
    - Viewed (0)
  3. cmd/object-api-errors.go

    	if errors.Is(err, errVolumeNotFound) {
    		return true
    	}
    
    	var bkNotFound BucketNotFound
    	return errors.As(err, &bkNotFound)
    }
    
    // isErrReadQuorum check if the error type is InsufficientReadQuorum
    func isErrReadQuorum(err error) bool {
    	var rquorum InsufficientReadQuorum
    	return errors.As(err, &rquorum)
    }
    
    // isErrWriteQuorum check if the error type is InsufficientWriteQuorum
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  4. cmd/erasure-server-pool.go

    		if opts.SkipRebalancing && z.IsPoolRebalancing(pinfo.Index) {
    			continue
    		}
    		if pinfo.Err == nil {
    			// found a pool
    			return pinfo, z.poolsWithObject(poolObjInfos, opts), nil
    		}
    
    		if isErrReadQuorum(pinfo.Err) && !opts.MetadataChg {
    			// read quorum is returned when the object is visibly
    			// present but its unreadable, we simply ask the writes to
    			// schedule to this pool instead. If there is no quorum
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 89.2K bytes
    - Viewed (0)
  5. cmd/bucket-replication.go

    			// version being purged is already not found on target.
    			if !rinfo.VersionPurgeStatus.Empty() {
    				rinfo.VersionPurgeStatus = replication.VersionPurgeComplete
    				return rinfo
    			}
    		case isErrReadQuorum(serr), isErrWriteQuorum(serr):
    			// destination has some quorum issues, perform removeObject() anyways
    			// to complete the operation.
    		default:
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 118.2K bytes
    - Viewed (0)
  6. cmd/object-handlers.go

    	gr, err := getObjectNInfo(ctx, bucket, object, rs, r.Header, opts)
    	if err != nil {
    		var (
    			reader *GetObjectReader
    			perr   error
    		)
    
    		if (isErrObjectNotFound(err) || isErrVersionNotFound(err) || isErrReadQuorum(err)) && (gr == nil || !gr.ObjInfo.DeleteMarker) {
    			proxytgts := getProxyTargets(ctx, bucket, object, opts)
    			if !proxytgts.Empty() {
    				globalReplicationStats.Load().incProxy(bucket, getObjectAPI, false)
    Registered: Sun Dec 28 19:28:13 UTC 2025
    - Last Modified: Sun Sep 28 20:59:21 UTC 2025
    - 120.6K bytes
    - Viewed (0)
Back to top