Search Options

Results per page
Sort
Preferred Languages
Advance

Results 1 - 2 of 2 for getRequestsPoolCapacity (0.12 sec)

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