Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 5 of 5 for Munlock (0.04 sec)

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

    	z.rebalMu.Lock()
    	defer z.rebalMu.Unlock()
    
    	r := z.rebalMeta
    	if r == nil {
    		return
    	}
    
    	r.PoolStats[poolIdx].update(bucket, fi)
    }
    
    const (
    	rebalMetaName = "rebalance.bin"
    	rebalMetaFmt  = 1
    	rebalMetaVer  = 1
    )
    
    func (z *erasureServerPools) nextRebalBucket(poolIdx int) (string, bool) {
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	r := z.rebalMeta
    	if r == nil {
    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

    		// - xl.meta metadata is still verified for quorum under lock()
    		//   however writing the response doesn't need to serialize
    		//   concurrent writers
    		unlockOnDefer = true
    		nsUnlocker = func() { lock.RUnlock(lkctx) }
    	}
    
    	fi, metaArr, onlineDisks, err := er.getObjectFileInfo(ctx, bucket, object, opts, true)
    	if err != nil {
    		return nil, toObjectErr(err, bucket, object)
    	}
    
    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-handlers.go

    	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
    
    	gopts := opts
    	gopts.NoLock = true // We already have a lock, we can live with it.
    	objInfo, err := getObjectInfo(ctx, bucket, object, gopts)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Sun Sep 07 16:13:09 UTC 2025
    - 120.6K bytes
    - Viewed (0)
  5. docs/en/docs/release-notes.md

    * 👥 Update FastAPI People. PR [#4752](https://github.com/tiangolo/fastapi/pull/4752) by [@github-actions[bot]](https://github.com/apps/github-actions).
    * âž– Temporarily remove typer-cli from dependencies and upgrade Black to unblock Pydantic CI. PR [#4754](https://github.com/tiangolo/fastapi/pull/4754) by [@tiangolo](https://github.com/tiangolo).
    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