Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for ResizeWorkers (0.08 sec)

  1. cmd/bucket-lifecycle.go

    	workers := make([]chan expiryOp, 0, n)
    	es.workers.Store(&workers)
    	es.ResizeWorkers(n)
    	return es
    }
    
    func (es *expiryState) getWorkerCh(h uint64) chan<- expiryOp {
    	w := es.workers.Load()
    	if w == nil || len(*w) == 0 {
    		return nil
    	}
    	workers := *w
    	return workers[h%uint64(len(workers))]
    }
    
    func (es *expiryState) ResizeWorkers(n int) {
    	if n == 0 {
    		n = 100
    	}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Oct 23 15:35:37 UTC 2024
    - 33.7K bytes
    - Viewed (0)
  2. cmd/config-current.go

    		} else {
    			if globalTransitionState != nil {
    				globalTransitionState.UpdateWorkers(ilmCfg.TransitionWorkers)
    			}
    			if globalExpiryState != nil {
    				globalExpiryState.ResizeWorkers(ilmCfg.ExpirationWorkers)
    			}
    			globalILMConfig.update(ilmCfg)
    		}
    	}
    	globalServerConfigMu.Lock()
    	defer globalServerConfigMu.Unlock()
    	if globalServerConfig != nil {
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 03 18:23:41 UTC 2024
    - 30.1K bytes
    - Viewed (0)
Back to top