- Sort Score
- Num 10 results
- Language All
Results 1 - 3 of 3 for SwapUint64 (0.06 seconds)
The search processing time has exceeded the limit. The displayed results may be partial.
-
cmd/http-stats.go
} // Converts http stats into struct to be sent back to the client. func (st *HTTPStats) toServerHTTPStats(toLowerKeys bool) ServerHTTPStats { serverStats := ServerHTTPStats{} serverStats.S3RequestsIncoming = atomic.SwapUint64(&st.s3RequestsIncoming, 0) serverStats.S3RequestsInQueue = atomic.LoadInt32(&st.s3RequestsInQueue) serverStats.TotalS3RejectedAuth = atomic.LoadUint64(&st.rejectedRequestsAuth)
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Tue Sep 24 17:13:00 GMT 2024 - 11.4K bytes - Click Count (0) -
cmd/bucket-replication-metrics.go
m.lock.Unlock() }() if m.startTime.IsZero() { return } if endTime.Before(m.startTime) { return } duration := endTime.Sub(m.startTime) bytesSinceLastWindow := atomic.SwapUint64(&m.bytesSinceLastWindow, 0) if m.expMovingAvg == 0 { // Should address initial calculation and should be fine for resuming from 0 m.expMovingAvg = float64(bytesSinceLastWindow) / duration.Seconds() return }
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Thu Aug 15 12:04:40 GMT 2024 - 14.2K bytes - Click Count (0) -
cmd/admin-handlers.go
writeErrorResponseJSON(ctx, w, errorCodes.ToAPIErr(toAPIErrorCode(ctx, err)), r.URL) return } ctx = lkctx.Context() defer nsLock.Unlock(lkctx) timeEnd := time.Now() atomic.SwapInt64(&globalLastClientPerfExtraTime, timeEnd.Sub(timeStart).Nanoseconds()) ctx, cancel := context.WithTimeout(ctx, madmin.MaxClientPerfTimeout) defer cancel() totalRx := int64(0) connectTime := time.Now()
Created: Sun Apr 05 19:28:12 GMT 2026 - Last Modified: Sun Sep 28 20:59:21 GMT 2025 - 99.7K bytes - Click Count (0)