Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/admin-handlers-pools.go

    		return
    	}
    
    	if z.IsDecommissionRunning() {
    		writeErrorResponseJSON(ctx, w, toAdminAPIErr(ctx, errDecommissionAlreadyRunning), r.URL)
    		return
    	}
    
    	if z.IsRebalanceStarted() {
    		writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(ErrAdminRebalanceAlreadyStarted), r.URL)
    		return
    	}
    
    	vars := mux.Vars(r)
    	v := vars["pool"]
    	byID := vars["by-id"] == "true"
    
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Thu Apr 04 12:04:40 GMT 2024
    - 10.9K 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() bool {
    	z.rebalMu.RLock()
    	defer z.rebalMu.RUnlock()
    
    	if r := z.rebalMeta; r != nil {
    		if r.StoppedAt.IsZero() {
    			return true
    		}
    	}
    	return false
    }
    
    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