Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for CheckPrecondFn (0.1 sec)

  1. cmd/object-api-utils.go

    // reader. This ignores any object properties.
    func NewGetObjectReaderFromReader(r io.Reader, oi ObjectInfo, opts ObjectOptions, cleanupFns ...func()) (*GetObjectReader, error) {
    	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,
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 08 15:29:58 UTC 2024
    - 37.1K bytes
    - Viewed (0)
  2. cmd/erasure-multipart.go

    // operation(s) on the object.
    func (er erasureObjects) newMultipartUpload(ctx context.Context, bucket string, object string, opts ObjectOptions) (*NewMultipartUploadResult, error) {
    	if opts.CheckPrecondFn != nil {
    		if !opts.NoLock {
    			ns := er.NewNSLock(bucket, object)
    			lkctx, err := ns.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return nil, err
    			}
    			ctx = lkctx.Context()
    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/s3-zip-handlers.go

    		return
    	}
    
    	if r.Header.Get(xhttp.Range) != "" {
    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidRange), r.URL)
    		return
    	}
    
    	// Validate pre-conditions if any.
    	opts.CheckPrecondFn = func(oi ObjectInfo) bool {
    		if _, err := DecryptObjectInfo(&oi, r); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return true
    		}
    
    		return checkPreconditions(ctx, w, r, oi, opts)
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Mon Jun 10 15:31:51 UTC 2024
    - 15.8K bytes
    - Viewed (0)
  4. cmd/object-multipart-handlers.go

    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    
    	if opts.PreserveETag != "" ||
    		r.Header.Get(xhttp.IfMatch) != "" ||
    		r.Header.Get(xhttp.IfNoneMatch) != "" {
    		opts.CheckPrecondFn = func(oi ObjectInfo) bool {
    			if _, err := DecryptObjectInfo(&oi, r); err != nil {
    				writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    				return true
    			}
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Aug 31 18:25:48 UTC 2024
    - 39.2K bytes
    - Viewed (0)
  5. cmd/erasure-server-pool.go

    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    		unlockOnDefer = true
    	}
    
    	checkPrecondFn := opts.CheckPrecondFn
    	opts.CheckPrecondFn = nil // do not need to apply pre-conditions at lower layer.
    	opts.NoLock = true        // no locks needed at lower levels for getObjectInfo()
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sun Sep 29 22:40:36 UTC 2024
    - 89.8K bytes
    - Viewed (0)
  6. cmd/object-api-interface.go

    	PartNumberMarker    int                 // used in GetObjectAttributes. Signals the part number after which results should be returned
    	PartNumber          int                 // only useful in case of GetObject/HeadObject
    	CheckPrecondFn      CheckPreconditionFn // only set during GetObject/HeadObject/CopyObjectPart preconditional valuation
    	EvalMetadataFn      EvalMetadataFn      // only set for retention settings, meant to be used only when updating metadata in-place.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Aug 22 21:57:20 UTC 2024
    - 17.3K bytes
    - Viewed (0)
  7. cmd/object-handlers.go

    		if errors.Is(rangeErr, errInvalidRange) {
    			writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrInvalidRange), r.URL)
    			return
    		}
    	}
    
    	// Validate pre-conditions if any.
    	opts.CheckPrecondFn = func(oi ObjectInfo) bool {
    		if _, err := DecryptObjectInfo(&oi, r); err != nil {
    			writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    			return true
    		}
    
    		if oi.UserTags != "" {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Sat Oct 05 05:16:15 UTC 2024
    - 117.4K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, "PutObject", object, &er)
    	}
    
    	data := r.Reader
    
    	if opts.CheckPrecondFn != nil {
    		if !opts.NoLock {
    			ns := er.NewNSLock(bucket, object)
    			lkctx, err := ns.GetLock(ctx, globalOperationTimeout)
    			if err != nil {
    				return ObjectInfo{}, 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)
Back to top