- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 27 for inFlight (0.13 sec)
-
src/cmd/go/internal/cache/prog.go
return // quietly } if err == io.EOF { c.mu.Lock() inFlight := len(c.inFlight) c.mu.Unlock() base.Fatalf("GOCACHEPROG exited pre-Close with %v pending requests", inFlight) } base.Fatalf("error reading JSON from GOCACHEPROG: %v", err) } c.mu.Lock() ch, ok := c.inFlight[res.ID] delete(c.inFlight, res.ID) c.mu.Unlock() if ok { ch <- res } else {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Aug 14 19:23:25 UTC 2023 - 11.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/server_run_options.go
} if s.MaxRequestsInFlight < 0 { errors = append(errors, fmt.Errorf("--max-requests-inflight can not be negative value")) } if s.MaxMutatingRequestsInFlight < 0 { errors = append(errors, fmt.Errorf("--max-mutating-requests-inflight can not be negative value")) } if s.RequestTimeout.Nanoseconds() < 0 {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 24 21:53:51 UTC 2023 - 15.4K bytes - Viewed (0) -
cluster/gce/gci/configure-kubeapiserver.sh
if [[ "${NUM_NODES}" -gt 3000 ]]; then params=$(append-param-if-not-present "${params}" "max-requests-inflight" 3000) params=$(append-param-if-not-present "${params}" "max-mutating-requests-inflight" 1000) elif [[ "${NUM_NODES}" -gt 500 ]]; then params=$(append-param-if-not-present "${params}" "max-requests-inflight" 1500)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Fri Jun 07 11:08:30 UTC 2024 - 25.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/genericapiserver_graceful_termination_test.go
<-inflight.blockedCh w.WriteHeader(http.StatusOK) }) s.Handler.NonGoRestfulMux.Handle(inflight.url, handler) return inflight } func setupInFlightWatchRequestHandler(s *GenericAPIServer) *inFlightRequest { inflight := &inFlightRequest{ blockedCh: make(chan struct{}), startedCh: make(chan struct{}), resultCh: make(chan result), url: "/apis/watches.group/v1/namespaces/foo/bar?watch=true", }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Apr 29 18:59:21 UTC 2024 - 38.3K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/server/options/server_run_options_test.go
MinRequestTimeout: 1800, JSONPatchMaxCopyBytes: 10 * 1024 * 1024, MaxRequestBodyBytes: 10 * 1024 * 1024, }, expectErr: "--max-requests-inflight can not be negative value", }, { name: "Test when MaxMutatingRequestsInFlight is negative value", testOptions: &ServerRunOptions{ AdvertiseAddress: netutils.ParseIPSloppy("192.168.10.10"),
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 10.9K bytes - Viewed (0) -
src/test/java/jcifs/tests/SessionTest.java
SmbTransportInternal t = (SmbTransportInternal) sess.getTransport() ) { int before = t.getInflightRequests(); if ( before > 0 ) { log.warn("Have existing inflight requests"); } f.exists(); assertEquals(before, t.getInflightRequests()); } } } @Test // BUG #14
Registered: Wed Jun 12 15:45:55 UTC 2024 - Last Modified: Thu Jan 05 13:09:03 UTC 2023 - 15.8K bytes - Viewed (0) -
pkg/scheduler/framework/plugins/dynamicresources/structuredparameters_test.go
"k8s.io/kubernetes/test/utils/ktesting" "k8s.io/utils/ptr" ) func TestModel(t *testing.T) { testcases := map[string]struct { slices resourceSliceLister claims assumeCacheLister inFlight map[types.UID]resourceapi.ResourceClaimStatus wantResources resources wantErr bool }{ "empty": {}, "slice-list-error": { slices: sliceError("slice list error"), wantErr: true,
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Mar 27 09:27:01 UTC 2024 - 34.8K bytes - Viewed (0) -
tensorflow/c/eager/c_api_experimental.h
// maximum number of in flight async nodes. Enqueuing of additional async ops // after the limit is reached blocks until some inflight nodes finishes. // The effect is bounding the memory held by inflight TensorHandles that are // referenced by the inflight nodes. // A recommended value has not been established. // A value of 0 removes the limit, which is the behavior of TensorFlow 2.11.
Registered: Sun Jun 16 05:45:23 UTC 2024 - Last Modified: Wed Feb 21 22:37:46 UTC 2024 - 39.5K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/util/flowcontrol/apf_controller.go
// when using apiserver's default total server concurrency of 600 (--max-requests-inflight=400, --max-mutating-requests-inflight=200). // This ensures that clusters with relatively high inflight requests will continue to use a max seats of 10 // while clusters with lower inflight requests will use max seats no greater than nominalCL/handSize.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Sat May 04 18:33:12 UTC 2024 - 48.8K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/endpoints/metrics/metrics.go
currentInflightRequests = compbasemetrics.NewGaugeVec( &compbasemetrics.GaugeOpts{ Subsystem: APIServerComponent, Name: "current_inflight_requests", Help: "Maximal number of currently used inflight request limit of this apiserver per request kind in last second.", StabilityLevel: compbasemetrics.STABLE, }, []string{"request_kind"}, ) currentInqueueRequests = compbasemetrics.NewGaugeVec(
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Sep 27 07:29:19 UTC 2023 - 35K bytes - Viewed (0)