Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for SwapUint64 (0.04 sec)

  1. 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)
    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

    		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
    	}
    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/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()
    Registered: Sun Sep 07 19:28:11 UTC 2025
    - Last Modified: Fri Aug 29 02:39:48 UTC 2025
    - 99.6K bytes
    - Viewed (0)
Back to top