Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for active_workers (0.11 sec)

  1. 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)
  2. 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)
  3. 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)
Back to top