Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 8 of 8 for CheckPrecondFn (0.21 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,
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Mon Mar 11 11:55:34 GMT 2024
    - 35.6K bytes
    - Viewed (1)
  2. 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Tue Apr 09 10:41:25 GMT 2024
    - 15.8K bytes
    - Viewed (0)
  3. 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.
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 17K bytes
    - Viewed (0)
  4. 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()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Fri May 03 20:08:20 GMT 2024
    - 80.5K bytes
    - Viewed (0)
  5. 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 {
    		// Lock the object before reading.
    		lk := er.NewNSLock(bucket, object)
    		lkctx, err := lk.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		rctx := lkctx.Context()
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun Apr 28 17:53:50 GMT 2024
    - 43K bytes
    - Viewed (0)
  6. 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
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu Mar 28 17:44:56 GMT 2024
    - 39K bytes
    - Viewed (0)
  7. cmd/object-handlers.go

    					return
    				}
    			}
    		}
    
    		if errors.Is(err, cache.ErrKeyMissing) {
    			update = true
    		}
    	}
    
    	// 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)
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Thu May 02 20:15:54 GMT 2024
    - 125.2K bytes
    - Viewed (0)
  8. cmd/erasure-object.go

    	if !opts.NoAuditLog {
    		auditObjectErasureSet(ctx, 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
    			}
    Go
    - Registered: Sun May 05 19:28:20 GMT 2024
    - Last Modified: Sun May 05 16:56:21 GMT 2024
    - 77.2K bytes
    - Viewed (2)
Back to top