- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for MaxWorkers (0.04 sec)
-
cmd/bucket-replication.go
mrfWorkers = min(p.mrfWorkerSize+1, MRFWorkerAutoDefault) } } if maxWorkers > 0 && workers > maxWorkers { workers = maxWorkers } if maxWorkers > 0 && mrfWorkers > maxWorkers { mrfWorkers = maxWorkers } if maxLWorkers <= 0 { maxLWorkers = LargeWorkerCount } p.priority = pri p.maxWorkers = maxWorkers p.mu.Unlock() p.ResizeWorkers(workers, 0)
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
defer t.mu.RUnlock() 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 {
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)