Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for unlocked (0.13 sec)

  1. cmd/erasure-server-pool-rebalance.go

    		return err
    	}
    	defer lock.Unlock(lkCtx)
    
    	ctx = lkCtx.Context()
    	noLockOpts := ObjectOptions{NoLock: true}
    	r := &rebalanceMeta{}
    	err = r.loadWithOpts(ctx, z.serverPools[0], noLockOpts)
    	if err != nil && !errors.Is(err, errConfigNotFound) {
    		return err
    	}
    
    	z.rebalMu.Lock()
    	defer z.rebalMu.Unlock()
    
    	// if not found, we store the memory metadata back
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
  2. cmd/erasure-object.go

    	}
    
    	return dfi.ToObjectInfo(bucket, object, opts.Versioned || opts.VersionSuspended), nil
    }
    
    // Send the successful but partial upload/delete, however ignore
    // if the channel is blocked by other items.
    func (er erasureObjects) addPartial(bucket, object, versionID string) {
    	globalMRFState.addPartialOp(PartialOperation{
    		Bucket:    bucket,
    		Object:    object,
    		VersionID: versionID,
    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-multipart.go

    		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
    		}
    
    		obj, err := er.getObjectInfo(ctx, bucket, object, opts)
    		if err == nil && opts.CheckPrecondFn(obj) {
    			return nil, PreConditionFailed{}
    		}
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
Back to top