Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 10 for PreconditionFailed (0.14 sec)

  1. cmd/object-api-errors.go

    	return errors.As(err, &signatureDoesNotMatch)
    }
    
    // PreConditionFailed - Check if copy precondition failed
    type PreConditionFailed struct{}
    
    func (e PreConditionFailed) Error() string {
    	return "At least one of the pre-conditions you specified did not hold"
    }
    
    func isErrPreconditionFailed(err error) bool {
    	_, ok := err.(PreConditionFailed)
    	return ok
    }
    
    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/utils.go

    	case "SlowDownWrite":
    		err = InsufficientWriteQuorum{Bucket: bucket, Object: object}
    	case "SlowDownRead":
    		err = InsufficientReadQuorum{Bucket: bucket, Object: object}
    	case "PreconditionFailed":
    		err = PreConditionFailed{}
    	case "InvalidRange":
    		err = InvalidRange{}
    	case "BucketAlreadyOwnedByYou":
    		err = BucketAlreadyOwnedByYou{}
    	case "BucketNotEmpty":
    		err = BucketNotEmpty{}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Aug 13 22:22:04 UTC 2024
    - 31.9K bytes
    - Viewed (0)
  3. cmd/object-api-utils.go

    	if opts.CheckPrecondFn != nil && opts.CheckPrecondFn(oi) {
    		// Call the cleanup funcs
    		for i := len(cleanupFns) - 1; i >= 0; i-- {
    			cleanupFns[i]()
    		}
    		return nil, PreConditionFailed{}
    	}
    	return &GetObjectReader{
    		ObjInfo:    oi,
    		Reader:     r,
    		cleanUpFns: cleanupFns,
    	}, nil
    }
    
    // ObjReaderFn is a function type that takes a reader and returns
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  4. cmd/erasure-multipart.go

    			ctx = lkctx.Context()
    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    		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)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 44.7K bytes
    - Viewed (0)
  5. internal/rest/client.go

    		// instead, see cmd/storage-rest-server.go for ideas.
    		if c.HealthCheckFn != nil && resp.StatusCode == http.StatusPreconditionFailed {
    			err = fmt.Errorf("Marking %s offline temporarily; caused by PreconditionFailed with drive ID mismatch", c.url.Host)
    			logger.LogOnceIf(ctx, logSubsys, err, c.url.Host)
    			c.MarkOffline(err)
    		}
    		defer xhttp.DrainBody(resp.Body)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Jul 26 12:55:01 UTC 2024
    - 14.7K bytes
    - Viewed (0)
  6. cmd/api-errors.go

    		Description:    "A header you provided implies functionality that is not implemented",
    		HTTPStatusCode: http.StatusNotImplemented,
    	},
    	ErrPreconditionFailed: {
    		Code:           "PreconditionFailed",
    		Description:    "At least one of the pre-conditions you specified did not hold",
    		HTTPStatusCode: http.StatusPreconditionFailed,
    	},
    	ErrRequestTimeTooSkewed: {
    		Code:           "RequestTimeTooSkewed",
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Oct 01 22:13:18 UTC 2024
    - 92.1K bytes
    - Viewed (0)
  7. cmd/batch-handlers.go

    				success := true
    				if err := r.ReplicateToTarget(ctx, api, c, result, retry); err != nil {
    					if miniogo.ToErrorResponse(err).Code == "PreconditionFailed" {
    						// pre-condition failed means we already have the object copied over.
    						return
    					}
    					// object must be deleted concurrently, allow these failures but do not count them
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 18 15:32:09 UTC 2024
    - 62.2K bytes
    - Viewed (0)
  8. cmd/bucket-replication.go

    	} else {
    		_, rinfo.Err = c.PutObject(ctx, tgt.Bucket, object, r, size, "", "", putOpts)
    	}
    	if rinfo.Err != nil {
    		if minio.ToErrorResponse(rinfo.Err).Code != "PreconditionFailed" {
    			rinfo.ReplicationStatus = replication.Failed
    			replLogIf(ctx, fmt.Errorf("unable to replicate for object %s/%s(%s): to (target: %s): %w",
    				bucket, objInfo.Name, objInfo.VersionID, tgt.EndpointURL(), rinfo.Err))
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 10 06:49:55 UTC 2024
    - 116.1K bytes
    - Viewed (0)
  9. cmd/erasure-object.go

    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    		if err == nil && opts.CheckPrecondFn(obj) {
    			return objInfo, PreConditionFailed{}
    		}
    		if err != nil && !isErrVersionNotFound(err) && !isErrObjectNotFound(err) && !isErrReadQuorum(err) {
    			return objInfo, err
    		}
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Oct 31 22:10:24 UTC 2024
    - 78.8K bytes
    - Viewed (0)
  10. cmd/erasure-server-pool.go

    			}, toObjectErr(errMethodNotAllowed, bucket, object)
    		}
    		return nil, err
    	}
    
    	// check preconditions before reading the stream.
    	if checkPrecondFn != nil && checkPrecondFn(objInfo) {
    		return nil, PreConditionFailed{}
    	}
    
    	opts.NoLock = true
    	gr, err = z.serverPools[zIdx].GetObjectNInfo(ctx, bucket, object, rs, h, opts)
    	if err != nil {
    		return nil, err
    	}
    
    	if unlockOnDefer {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
Back to top