Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 4 of 4 for newNSLock (0.14 sec)

  1. cmd/erasure-multipart.go

    	partIDLock := er.NewNSLock(bucket, pathJoin(object, uploadID, strconv.Itoa(partID)))
    	plkctx, err := partIDLock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		return PartInfo{}, err
    	}
    
    	ctx = plkctx.Context()
    	defer partIDLock.Unlock(plkctx)
    
    	// Read lock for upload id, only held while reading the upload metadata.
    	uploadIDRLock := er.NewNSLock(bucket, pathJoin(object, uploadID))
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	}
    
    	// This call shouldn't be used for anything other than metadata updates or adding self referential versions.
    	if !srcInfo.metadataOnly {
    		return oi, NotImplemented{}
    	}
    
    	if !dstOpts.NoLock {
    		lk := er.NewNSLock(dstBucket, dstObject)
    		lkctx, err := lk.GetLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return oi, err
    		}
    		ctx = lkctx.Context()
    		defer lk.Unlock(lkctx)
    	}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 80.4K bytes
    - Viewed (0)
  3. cmd/object-api-interface.go

    	o.EvalRetentionBypassFn = f
    }
    
    // ObjectLayer implements primitives for object API layer.
    type ObjectLayer interface {
    	// Locking operations on object.
    	NewNSLock(bucket string, objects ...string) RWLocker
    
    	// Storage operations.
    	Shutdown(context.Context) error
    	NSScanner(ctx context.Context, updates chan<- DataUsageInfo, wantCycle uint32, scanMode madmin.HealScanMode) error
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  4. cmd/object-handlers.go

    		writeErrorResponse(ctx, w, errorCodes.ToAPIErr(ErrEmptyRequestBody), r.URL)
    		return
    	}
    
    	// Take read lock on object, here so subsequent lower-level
    	// calls do not need to.
    	lock := objectAPI.NewNSLock(bucket, object)
    	lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    	if err != nil {
    		writeErrorResponse(ctx, w, toAPIError(ctx, err), r.URL)
    		return
    	}
    	ctx = lkctx.Context()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
Back to top