- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for IsPoolRebalancing (0.67 sec)
-
cmd/erasure-server-pool.go
g := errgroup.WithNErrs(len(z.serverPools)) for index := range z.serverPools { // 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.
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 89.1K bytes - Viewed (0) -
cmd/erasure-server-pool-rebalance.go
return false } for _, ps := range r.PoolStats { if ps.Participating && ps.Info.Status != rebalCompleted { 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 := r.PoolStats[poolIndex]
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Thu Sep 04 20:47:24 UTC 2025 - 28.9K bytes - Viewed (0)