Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for loadRebalanceMeta (0.16 sec)

  1. cmd/admin-handlers-pools.go

    		return
    	}
    
    	writeSuccessResponseJSON(w, b)
    	// Notify peers to load rebalance.bin and start rebalance routine if they happen to be
    	// participating pool's leader node
    	globalNotificationSys.LoadRebalanceMeta(ctx, true)
    }
    
    func (a adminAPIHandlers) RebalanceStatus(w http.ResponseWriter, r *http.Request) {
    	ctx := r.Context()
    
    	objectAPI, _ := validateAdminReq(ctx, w, r, policy.RebalanceAdminAction)
    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

    	PoolStats       []*rebalanceStats  `msg:"rss"`    // Per-pool rebalance stats keyed by pool index
    }
    
    var errRebalanceNotStarted = errors.New("rebalance not started")
    
    func (z *erasureServerPools) loadRebalanceMeta(ctx context.Context) error {
    	r := &rebalanceMeta{}
    	if err := r.load(ctx, z.serverPools[0]); err == nil {
    		z.rebalMu.Lock()
    		z.rebalMeta = r
    		z.updateRebalanceStats(ctx)
    		z.rebalMu.Unlock()
    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