- Sort Score
- Result 10 results
- Languages All
Results 1 - 4 of 4 for getRequestsPoolCapacity (0.26 sec)
-
cmd/listen-notification-handlers.go
// Use buffered channel to take care of burst sends or slow w.Write() mergeCh := make(chan []byte, globalAPIConfig.getRequestsPoolCapacity()*len(globalEndpoints.Hostnames())) localCh := make(chan event.Event, globalAPIConfig.getRequestsPoolCapacity()) // Convert local messages to JSON and send to mergeCh go func() { buf := bytes.NewBuffer(grid.GetByteBuffer()[:0]) enc := json.NewEncoder(buf)
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 6K bytes - Viewed (0) -
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) }
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Thu Apr 04 12:04:40 GMT 2024 - 51.8K bytes - Viewed (0) -
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:
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Wed Apr 03 21:13:20 GMT 2024 - 6.5K bytes - Viewed (0) -
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{}, time.Duration) { t.mu.RLock() defer t.mu.RUnlock()
Go - Registered: Sun May 05 19:28:20 GMT 2024 - Last Modified: Fri May 03 20:08:20 GMT 2024 - 10K bytes - Viewed (0)