Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Aug 09 02:05:14 UTC 2024
    - 22.1K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    		if err == nil && opts.CheckPrecondFn(obj) {
    			return nil, PreConditionFailed{}
    		}
    		if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) {
    			return nil, err
    		}
    	}
    
    	userDefined := cloneMSS(opts.UserDefined)
    	if opts.PreserveETag != "" {
    		userDefined["etag"] = opts.PreserveETag
    	}
    	onlineDisks := er.getDisks()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  3. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  4. cmd/bucket-replication.go

    			// version being purged is already not found on target.
    			if !rinfo.VersionPurgeStatus.Empty() {
    				rinfo.VersionPurgeStatus = Complete
    				return
    			}
    		case isErrReadQuorum(serr), isErrWriteQuorum(serr):
    			// destination has some quorum issues, perform removeObject() anyways
    			// to complete the operation.
    		default:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  5. 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 Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  6. cmd/erasure-object.go

    		if err == nil && opts.CheckPrecondFn(obj) {
    			return objInfo, PreConditionFailed{}
    		}
    		if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) {
    			return objInfo, err
    		}
    	}
    
    	// Validate input data size and it can never be less than -1.
    	if data.Size() < -1 {
    		bugLogIf(ctx, errInvalidArgument, logger.ErrorKind)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
Back to top