Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for IsPoolRebalancing (0.24 sec)

  1. cmd/erasure-server-pool.go

    	g := errgroup.WithNErrs(len(z.serverPools))
    	for index := range z.serverPools {
    		index := index
    		// Skip suspended pools or pools participating in rebalance for any new
    		// I/O.
    		if z.IsSuspended(index) || z.IsPoolRebalancing(index) {
    			continue
    		}
    		pool := z.serverPools[index]
    		nSets[index] = pool.setCount
    		g.Go(func() error {
    			// Get the set where it would be placed.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 06:32:14 GMT 2024
    - 80.1K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	if r := z.rebalMeta; r != nil {
    		if r.StoppedAt.IsZero() {
    			return true
    		}
    	}
    	return false
    }
    
    func (z *erasureServerPools) IsPoolRebalancing(poolIndex int) bool {
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	if r := z.rebalMeta; r != nil {
    		if !r.StoppedAt.IsZero() {
    			return false
    		}
    		ps := z.rebalMeta.PoolStats[poolIndex]
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Fri Apr 26 19:29:28 GMT 2024
    - 27.2K bytes
    - Viewed (0)
Back to top