Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 3 of 3 for getRequestsPoolCapacity (0.17 sec)

  1. cmd/healthcheck-handler.go

    	}
    	if r.Header.Get(xhttp.MinIOPeerCall) != "" {
    		writeResponse(w, http.StatusOK, nil, mimeNone)
    		return
    	}
    
    	if int(globalHTTPStats.loadRequestsInQueue()) > globalAPIConfig.getRequestsPoolCapacity() {
    		apiErr := getAPIError(ErrBusy)
    		switch r.Method {
    		case http.MethodHead:
    			writeResponse(w, apiErr.HTTPStatusCode, nil, mimeNone)
    		case http.MethodGet:
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Wed Jun 26 07:44:34 UTC 2024
    - 6.9K bytes
    - Viewed (0)
  2. cmd/handler-api.go

    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	if t.clusterDeadline == 0 {
    		return 10 * time.Second
    	}
    
    	return t.clusterDeadline
    }
    
    func (t *apiConfig) getRequestsPoolCapacity() int {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    	return cap(t.requestsPool)
    }
    
    func (t *apiConfig) getRequestsPool() chan struct{} {
    	t.mu.RLock()
    	defer t.mu.RUnlock()
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Thu Sep 26 17:07:10 UTC 2024
    - 10.4K bytes
    - Viewed (0)
  3. cmd/peer-rest-server.go

    	values := v.Values()
    	defer v.Recycle()
    	var prefix string
    	if len(values[peerRESTListenPrefix]) > 1 {
    		return grid.NewRemoteErrString("invalid request (peerRESTListenPrefix)")
    	}
    	globalAPIConfig.getRequestsPoolCapacity()
    	if len(values[peerRESTListenPrefix]) == 1 {
    		if err := event.ValidateFilterRuleValue(values[peerRESTListenPrefix][0]); err != nil {
    			return grid.NewRemoteErr(err)
    		}
    
    Registered: Sun Nov 03 19:28:11 UTC 2024
    - Last Modified: Fri Oct 04 11:32:32 UTC 2024
    - 53.2K bytes
    - Viewed (0)
Back to top