- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for maxLWorkers (0.04 sec)
-
cmd/bucket-replication.go
workers = WorkerAutoDefault failedWorkers = MRFWorkerAutoDefault } if maxWorkers > 0 && workers > maxWorkers { workers = maxWorkers } if maxWorkers > 0 && failedWorkers > maxWorkers { failedWorkers = maxWorkers } maxLWorkers := LargeWorkerCount if opts.MaxLWorkers > 0 { maxLWorkers = opts.MaxLWorkers } pool := &ReplicationPool{
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 118K bytes - Viewed (0) -
cmd/handler-api.go
if t.replicationPriority == "" { return replicationPoolOpts{ Priority: "auto", MaxWorkers: WorkerMaxLimit, MaxLWorkers: LargeWorkerCount, } } return replicationPoolOpts{ Priority: t.replicationPriority, MaxWorkers: t.replicationMaxWorkers, MaxLWorkers: t.replicationMaxLWorkers, } } func (t *apiConfig) getTransitionWorkers() int { t.mu.RLock()
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Tue Feb 18 16:25:55 UTC 2025 - 10.4K bytes - Viewed (0) -
cmd/notification.go
// further discussion advised. Remove this comment and remove the worker model // for this function in future. maxWorkers := runtime.GOMAXPROCS(0) / 2 ng := WithNPeersThrottled(len(sys.peerClients), maxWorkers) for idx, client := range sys.peerClients { if client == nil { continue } client := client ng.Go(ctx, func() error {
Registered: Sun Sep 07 19:28:11 UTC 2025 - Last Modified: Fri Aug 29 02:39:48 UTC 2025 - 45.9K bytes - Viewed (0)