Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. 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)
  2. 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)
  3. 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)
  4. 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)
  5. cmd/site-replication-metrics.go

    		}
    		rt.ErrCounts["AccessDenied"]++
    	}
    }
    
    func (rt *RTimedMetrics) merge(o RTimedMetrics) (n RTimedMetrics) {
    	n.SinceUptime.Bytes = atomic.LoadInt64(&rt.SinceUptime.Bytes) + atomic.LoadInt64(&o.SinceUptime.Bytes)
    	n.SinceUptime.Count = atomic.LoadInt64(&rt.SinceUptime.Count) + atomic.LoadInt64(&o.SinceUptime.Count)
    
    	n.LastMinute = n.LastMinute.merge(rt.LastMinute)
    	n.LastMinute = n.LastMinute.merge(o.LastMinute)
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 8.2K bytes
    - Viewed (0)
  6. cmd/consolelogger.go

    }
    
    // Stats returns the target statistics.
    func (sys *HTTPConsoleLoggerSys) Stats() types.TargetStats {
    	return types.TargetStats{
    		TotalMessages:  atomic.LoadInt64(&sys.totalMessages),
    		FailedMessages: atomic.LoadInt64(&sys.failedMessages),
    		QueueLength:    0,
    	}
    }
    
    // Content returns the console stdout log
    func (sys *HTTPConsoleLoggerSys) Content() (logs []log.Entry) {
    	sys.RLock()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 5.4K bytes
    - Viewed (0)
Back to top