Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getLoc (0.03 sec)

  1. cmd/erasure-multipart.go

    	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()
    			defer ns.Unlock(lkctx)
    			opts.NoLock = true
    		}
    
    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

    	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)
    	}
    	// Read metadata associated with the object from all disks.
    	storageDisks := er.getDisks()
    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/erasure-server-pool-rebalance.go

    	rebalSaveStoppedAt
    )
    
    func (z *erasureServerPools) saveRebalanceStats(ctx context.Context, poolIdx int, opts rebalSaveOpts) error {
    	lock := z.serverPools[0].NewNSLock(minioMetaBucket, rebalMetaName)
    	lkCtx, err := lock.GetLock(ctx, globalOperationTimeout)
    	if err != nil {
    		rebalanceLogIf(ctx, fmt.Errorf("failed to acquire write lock on %s/%s: %w", minioMetaBucket, rebalMetaName, err))
    		return err
    	}
    	defer lock.Unlock(lkCtx)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
Back to top