- Sort Score
- Result 10 results
- Languages All
Results 1 - 3 of 3 for active_workers (0.11 sec)
-
cmd/bucket-replication.go
p.lrgworkers = p.lrgworkers[:len(p.lrgworkers)-1] xioutil.SafeClose(worker) } } // ActiveWorkers returns the number of active workers handling replication traffic. func (p *ReplicationPool) ActiveWorkers() int { return int(atomic.LoadInt32(&p.activeWorkers)) } // ActiveMRFWorkers returns the number of active workers handling replication failures.
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Oct 10 06:49:55 UTC 2024 - 116.1K bytes - Viewed (0) -
cmd/site-replication.go
sm.Metrics = make(map[string]madmin.SRMetric) for _, peer := range peerSMetricsList { sm.ActiveWorkers.Avg += peer.ActiveWorkers.Avg sm.ActiveWorkers.Curr += peer.ActiveWorkers.Curr if peer.ActiveWorkers.Max > sm.ActiveWorkers.Max { sm.ActiveWorkers.Max += peer.ActiveWorkers.Max } sm.Queued.Avg.Bytes += peer.Queued.Avg.Bytes sm.Queued.Avg.Count += peer.Queued.Avg.Count
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 185.1K bytes - Viewed (0) -
cmd/metrics-v2.go
maxQueueBytes.Value = qt.Max.Bytes maxQueueCount.Value = qt.Max.Count } activeWorkersCount.Value = float64(qs.ActiveWorkers.Curr) avgActiveWorkersCount.Value = float64(qs.ActiveWorkers.Avg) maxActiveWorkersCount.Value = float64(qs.ActiveWorkers.Max) if len(qs.XferStats) > 0 { tots := qs.XferStats[Total] currTransferRate.Value = tots.Curr
Registered: Sun Nov 03 19:28:11 UTC 2024 - Last Modified: Thu Aug 15 12:04:40 UTC 2024 - 131.9K bytes - Viewed (0)