Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for addRequestsInQueue (0.18 sec)

  1. cmd/handler-api.go

    			return
    		}
    
    		globalHTTPStats.addRequestsInQueue(1)
    
    		if tc, ok := r.Context().Value(mcontext.ContextTraceKey).(*mcontext.TraceCtxt); ok {
    			tc.FuncName = "s3.MaxClients"
    		}
    
    		deadlineTimer := time.NewTimer(deadline)
    		defer deadlineTimer.Stop()
    
    		select {
    		case pool <- struct{}{}:
    			defer func() { <-pool }()
    			globalHTTPStats.addRequestsInQueue(-1)
    			f.ServeHTTP(w, r)
    Go
    - Registered: Sun Apr 28 19:28:10 GMT 2024
    - Last Modified: Mon Apr 08 09:22:27 GMT 2024
    - 10K bytes
    - Viewed (0)
  2. cmd/http-stats.go

    	totalS3Canceled         HTTPAPIStats
    }
    
    func (st *HTTPStats) loadRequestsInQueue() int32 {
    	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)
    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)
Back to top