Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for incS3RequestsIncoming (0.19 sec)

  1. cmd/http-stats.go

    	return atomic.LoadInt32(&st.s3RequestsInQueue)
    }
    
    func (st *HTTPStats) addRequestsInQueue(i int32) {
    	atomic.AddInt32(&st.s3RequestsInQueue, i)
    }
    
    func (st *HTTPStats) incS3RequestsIncoming() {
    	// Golang automatically resets to zero if this overflows
    	atomic.AddUint64(&st.s3RequestsIncoming, 1)
    }
    
    // Converts http stats into struct to be sent back to the client.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Sun Mar 10 09:15:15 GMT 2024
    - 11.4K bytes
    - Viewed (0)
  2. cmd/handler-api.go

    }
    
    // maxClients throttles the S3 API calls
    func maxClients(f http.HandlerFunc) http.HandlerFunc {
    	return func(w http.ResponseWriter, r *http.Request) {
    		globalHTTPStats.incS3RequestsIncoming()
    
    		if r.Header.Get(globalObjectPerfUserMetadata) == "" {
    			if val := globalServiceFreeze.Load(); val != nil {
    				if unlock, ok := val.(chan struct{}); ok && unlock != nil {
    					// Wait until unfrozen.
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 09:22:27 GMT 2024
    - 10K bytes
    - Viewed (0)
Back to top