Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getTransitionWorkers (1.14 sec)

  1. cmd/ilm-config.go

    	mu  sync.RWMutex
    	cfg ilm.Config
    }
    
    func (c *ilmConfig) getExpirationWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.ExpirationWorkers
    }
    
    func (c *ilmConfig) getTransitionWorkers() int {
    	c.mu.RLock()
    	defer c.mu.RUnlock()
    
    	return c.cfg.TransitionWorkers
    }
    
    func (c *ilmConfig) update(cfg ilm.Config) {
    	c.mu.Lock()
    	defer c.mu.Unlock()
    
    	c.cfg = cfg
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Mar 05 02:50:24 UTC 2024
    - 1.3K bytes
    - Viewed (0)
  2. cmd/handler-api.go

    		}
    	}
    
    	return replicationPoolOpts{
    		Priority:    t.replicationPriority,
    		MaxWorkers:  t.replicationMaxWorkers,
    		MaxLWorkers: t.replicationMaxLWorkers,
    	}
    }
    
    func (t *apiConfig) getTransitionWorkers() int {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	if t.transitionWorkers <= 0 {
    		return runtime.GOMAXPROCS(0) / 2
    	}
    
    	return t.transitionWorkers
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 10.4K bytes
    - Viewed (0)
  3. cmd/bucket-lifecycle.go

    // of transition workers.
    func (t *transitionState) Init(objAPI ObjectLayer) {
    	n := globalAPIConfig.getTransitionWorkers()
    	// Prefer ilm.transition_workers over now deprecated api.transition_workers
    	if tw := globalILMConfig.getTransitionWorkers(); tw > 0 {
    		n = tw
    	}
    	t.mu.Lock()
    	defer t.mu.Unlock()
    
    	t.objAPI = objAPI
    	t.updateWorkers(n)
    }
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 33.7K bytes
    - Viewed (0)
Back to top