Search Options

Results per page
Sort
Preferred Languages
Advance

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

  1. cmd/handler-api.go

    	}
    
    	return t.requestsPool
    }
    
    // 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  2. 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.
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Tue Sep 24 17:13:00 UTC 2024
    - 11.4K bytes
    - Viewed (0)
Back to top