- Sort Score
- Result 10 results
- Languages All
Results 1 - 2 of 2 for getRequestsPoolCapacity (0.34 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/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)