Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 10 of 15 for LoadUint64 (0.13 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/metrics-v3-cluster-iam.go

    	lastSyncTime := atomic.LoadUint64(&globalIAMSys.LastRefreshTimeUnixNano)
    	if lastSyncTime != 0 {
    		m.Set(sinceLastSyncMillis, float64((uint64(time.Now().UnixNano())-lastSyncTime)/uint64(time.Millisecond)))
    	}
    	m.Set(syncFailures, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshFailures)))
    	m.Set(syncSuccesses, float64(atomic.LoadUint64(&globalIAMSys.TotalRefreshSuccesses)))
    	return nil
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Thu May 02 08:20:42 UTC 2024
    - 4.5K bytes
    - Viewed (0)
  4. 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)
  5. cmd/data-scanner-metric.go

    	})
    	return i
    }
    
    // lifetime returns the lifetime count of the specified metric.
    func (p *scannerMetrics) lifetime(m scannerMetric) uint64 {
    	if m >= scannerMetricLast {
    		return 0
    	}
    	val := atomic.LoadUint64(&p.operations[m])
    	return val
    }
    
    // lastMinute returns the last minute statistics of a metric.
    // m should be < scannerMetricLastRealtime
    func (p *scannerMetrics) lastMinute(m scannerMetric) AccElem {
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 9.4K bytes
    - Viewed (0)
  6. cmd/os-instrumented.go

    func (o *osMetrics) report() madmin.OSMetrics {
    	var m madmin.OSMetrics
    	m.CollectedAt = time.Now()
    	m.LifeTimeOps = make(map[string]uint64, osMetricLast)
    	for i := range osMetricLast {
    		if n := atomic.LoadUint64(&o.operations[i]); n > 0 {
    			m.LifeTimeOps[i.String()] = n
    		}
    	}
    	if len(m.LifeTimeOps) == 0 {
    		m.LifeTimeOps = nil
    	}
    
    	m.LastMinute.Operations = make(map[string]madmin.TimedAction, osMetricLast)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 6.2K bytes
    - Viewed (0)
  7. 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)
  8. cmd/metrics-v2.go

    	mg := &MetricsGroupV2{
    		cacheInterval:    10 * time.Second,
    		metricsGroupOpts: opts,
    	}
    	mg.RegisterRead(func(_ context.Context) (metrics []MetricV2) {
    		lastSyncTime := atomic.LoadUint64(&globalIAMSys.LastRefreshTimeUnixNano)
    		var sinceLastSyncMillis uint64
    		if lastSyncTime != 0 {
    			sinceLastSyncMillis = (uint64(time.Now().UnixNano()) - lastSyncTime) / uint64(time.Millisecond)
    		}
    
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 133.4K bytes
    - Viewed (0)
  9. 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)
  10. cmd/dynamic-timeouts.go

    	}
    	return &dynamicTimeout{timeout: int64(timeout), minimum: int64(minimum)}
    }
    
    // Timeout returns the current timeout value
    func (dt *dynamicTimeout) Timeout() time.Duration {
    	return time.Duration(atomic.LoadInt64(&dt.timeout))
    }
    
    func (dt *dynamicTimeout) RetryInterval() time.Duration {
    	return dt.retryInterval
    }
    
    // LogSuccess logs the duration of a successful action that
    // did not hit the timeout
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 4.5K bytes
    - Viewed (0)
Back to top