Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for unlock (0.03 sec)

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

    }
    
    func (z *erasureServerPools) StartRebalance() {
    	z.rebalMu.Lock()
    	if z.rebalMeta == nil || !z.rebalMeta.StoppedAt.IsZero() { // rebalance not running, nothing to do
    		z.rebalMu.Unlock()
    		return
    	}
    	ctx, cancel := context.WithCancel(GlobalContext)
    	z.rebalMeta.cancel = cancel // to be used when rebalance-stop is called
    	z.rebalMu.Unlock()
    
    	z.rebalMu.RLock()
    	participants := make([]bool, len(z.rebalMeta.PoolStats))
    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

    			nsUnlocker()
    		}
    	}()
    
    	// Acquire lock
    	if !opts.NoLock {
    		lock := er.NewNSLock(bucket, object)
    		lkctx, err := lock.GetRLock(ctx, globalOperationTimeout)
    		if err != nil {
    			return nil, err
    		}
    		ctx = lkctx.Context()
    
    		// Release lock when the metadata is verified, and reader
    		// is ready to be read.
    		//
    		// This is possible to be lock free because
    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

    	}
    
    	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))
    	rlkctx, err := uploadIDRLock.GetRLock(ctx, globalOperationTimeout)
    	if err != nil {
    		return PartInfo{}, err
    	}
    	ctx = rlkctx.Context()
    	defer uploadIDRLock.RUnlock(rlkctx)
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 47.3K bytes
    - Viewed (0)
  4. cmd/object-api-interface.go

    	CreatedAt         time.Time // only for site replication
    	NoLock            bool      // does not lock the make bucket call if set to 'true'
    }
    
    // DeleteBucketOptions provides options for DeleteBucket calls.
    type DeleteBucketOptions struct {
    	NoLock     bool             // does not lock the delete bucket call if set to 'true'
    	NoRecreate bool             // do not recreate bucket on delete failures
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 17.5K bytes
    - Viewed (0)
  5. cmd/object-handlers.go

    		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()
    	defer lock.RUnlock(lkctx)
    
    	getObjectNInfo := objectAPI.GetObjectNInfo
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  6. docs/en/docs/release-notes.md

    ```Python
    async def do_something():
        try:
            yield something
        finally:
            some_cleanup()
    ```
    
    ...that way the `finally` block is run regardless of any exception that might happen.
    
    ### Features
    
    Registered: Sun Sep 07 07:19:17 UTC 2025
    - Last Modified: Fri Sep 05 12:48:45 UTC 2025
    - 544.1K bytes
    - Viewed (0)
Back to top