- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for UpdateWorkers (0.1 sec)
-
cmd/bucket-lifecycle.go
} return res } // UpdateWorkers at the end of this function leaves n goroutines waiting for // transition tasks func (t *transitionState) UpdateWorkers(n int) { t.mu.Lock() defer t.mu.Unlock() if t.objAPI == nil { // Init hasn't been called yet. return } t.updateWorkers(n) } func (t *transitionState) updateWorkers(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) -
cmd/handler-api.go
t.replicationMaxWorkers = cfg.ReplicationMaxWorkers t.replicationMaxLWorkers = cfg.ReplicationMaxLWorkers // N B api.transition_workers will be deprecated if globalTransitionState != nil { globalTransitionState.UpdateWorkers(cfg.TransitionWorkers) } t.transitionWorkers = cfg.TransitionWorkers t.staleUploadsExpiry = cfg.StaleUploadsExpiry t.deleteCleanupInterval = cfg.DeleteCleanupInterval t.enableODirect = cfg.EnableODirect
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Sep 26 17:07:10 UTC 2024 - 10.4K bytes - Viewed (0) -
cmd/config-current.go
if err != nil { errs = append(errs, fmt.Errorf("Unable to apply ilm config: %w", err)) } else { if globalTransitionState != nil { globalTransitionState.UpdateWorkers(ilmCfg.TransitionWorkers) } if globalExpiryState != nil { globalExpiryState.ResizeWorkers(ilmCfg.ExpirationWorkers) } globalILMConfig.update(ilmCfg) } } globalServerConfigMu.Lock()
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Tue Sep 03 18:23:41 UTC 2024 - 30.1K bytes - Viewed (0)