Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 6 of 6 for LoadUint64 (0.06 sec)

  1. cmd/http-stats.go

    	serverStats.TotalS3RejectedAuth = atomic.LoadUint64(&st.rejectedRequestsAuth)
    	serverStats.TotalS3RejectedTime = atomic.LoadUint64(&st.rejectedRequestsTime)
    	serverStats.TotalS3RejectedHeader = atomic.LoadUint64(&st.rejectedRequestsHeader)
    	serverStats.TotalS3RejectedInvalid = atomic.LoadUint64(&st.rejectedRequestsInvalid)
    	serverStats.CurrentS3Requests = ServerHTTPAPIStats{
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
  2. cmd/bucket-replication-metrics.go

    	}
    	return ProxyMetric{
    		PutTagTotal: atomic.LoadUint64(&v.PutTagTotal),
    		GetTagTotal: atomic.LoadUint64(&v.GetTagTotal),
    		RmvTagTotal: atomic.LoadUint64(&v.RmvTagTotal),
    		HeadTotal:   atomic.LoadUint64(&v.HeadTotal),
    		GetTotal:    atomic.LoadUint64(&v.GetTotal),
    
    		PutTagFailedTotal: atomic.LoadUint64(&v.PutTagFailedTotal),
    		GetTagFailedTotal: atomic.LoadUint64(&v.GetTagFailedTotal),
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu Aug 15 12:04:40 UTC 2024
    - 14.2K bytes
    - Viewed (0)
  3. cmd/bucket-stats.go

    	}
    	qs.XferStats = make(map[RMetricName]XferStats)
    	qs.QStats = r.qCache.getBucketStats(bucket)
    	qs.TgtXferStats = make(map[string]map[RMetricName]XferStats)
    	qs.MRFStats = ReplicationMRFStats{
    		LastFailedCount: atomic.LoadUint64(&r.mrfStats.LastFailedCount),
    	}
    
    	r.RLock()
    	defer r.RUnlock()
    
    	brs, ok := r.Cache[bucket]
    	if !ok {
    		return qs
    	}
    	for arn := range brs.Stats {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 13.5K bytes
    - Viewed (0)
  4. cmd/perf-tests.go

    	n.lastToConnect = time.Now()
    }
    
    func (n *netPerfRX) Disconnect() {
    	n.Lock()
    	defer n.Unlock()
    	n.activeConnections--
    	if n.firstToDisconnect.IsZero() {
    		n.RXSample = atomic.LoadUint64(&n.RX)
    		n.firstToDisconnect = time.Now()
    	}
    }
    
    func (n *netPerfRX) ActiveConnections() uint64 {
    	n.RLock()
    	defer n.RUnlock()
    	return n.activeConnections
    }
    
    func (n *netPerfRX) Reset() {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 11.7K bytes
    - Viewed (0)
  5. cmd/xl-storage-disk-id-check.go

    	acc := e.cached.Load()
    	if lastT := atomic.LoadInt64(&e.cachedSec); lastT != t {
    		// Check if lastT was changed by someone else.
    		if atomic.CompareAndSwapInt64(&e.cachedSec, lastT, t) {
    			// Now we swap in a new.
    			newAcc := &AccElem{}
    			old := e.cached.Swap(newAcc)
    			var a AccElem
    			a.Size = atomic.LoadInt64(&old.Size)
    			a.Total = atomic.LoadInt64(&old.Total)
    			a.N = atomic.LoadInt64(&old.N)
    			e.mu.Lock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Apr 25 05:41:04 UTC 2025
    - 34.5K bytes
    - Viewed (0)
  6. cmd/bucket-replication-stats.go

    		Queued:        r.qCache.getSiteStats(),
    		ActiveWorkers: r.ActiveWorkers(),
    		Metrics:       r.srStats.get(),
    		Proxied:       r.pCache.getSiteStats(),
    		ReplicaSize:   atomic.LoadInt64(&r.srStats.ReplicaSize),
    		ReplicaCount:  atomic.LoadInt64(&r.srStats.ReplicaCount),
    	}
    	return m
    }
    
    // Get replication metrics for a bucket from this node since this node came up.
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Tue Feb 18 16:25:55 UTC 2025
    - 13.6K bytes
    - Viewed (0)
Back to top