Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for IsRebalanceStarted (0.68 sec)

  1. cmd/admin-handlers-pools.go

    		return
    	}
    
    	if z.IsDecommissionRunning() {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errDecommissionAlreadyRunning), r.URL)
    		return
    	}
    
    	if z.IsRebalanceStarted(ctx) {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminRebalanceAlreadyStarted), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    	v := vars["pool"]
    	byID := vars["by-id"] == "true"
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 11K bytes
    - Viewed (0)
  2. cmd/erasure-server-pool-rebalance.go

    }
    
    func (r *rebalanceMeta) save(ctx context.Context, store objectIO) error {
    	return r.saveWithOpts(ctx, store, ObjectOptions{})
    }
    
    func (z *erasureServerPools) IsRebalanceStarted(ctx context.Context) bool {
    	_ = z.loadRebalanceMeta(ctx)
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	r := z.rebalMeta
    	if r == nil {
    		return false
    	}
    	if !r.StoppedAt.IsZero() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Sep 04 20:47:24 UTC 2025
    - 28.9K bytes
    - Viewed (0)
Back to top