- Sort Score
- Result 10 results
- Languages All
Results 1 - 10 of 80 for inFlight (0.17 sec)
-
staging/src/k8s.io/apiserver/pkg/server/filters/watch_termination_test.go
} } if test.wg == nil { return } if test.wg.inflight != 0 { t.Errorf("expected wait group inflight to be zero, but got: %d", test.wg.inflight) } if test.wgInvokedExpected != test.wg.invoked { t.Errorf("expected wait group Add to be invoked: %d times, but got: %d", test.wgInvokedExpected, test.wg.invoked)
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Feb 27 15:49:49 UTC 2023 - 5.2K bytes - Viewed (0) -
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) -
pkg/kubelet/server/metrics/metrics.go
}, []string{"method", "path", "server_type", "long_running"}, ) // HTTPInflightRequests tracks the number of the inflight http requests. HTTPInflightRequests = metrics.NewGaugeVec( &metrics.GaugeOpts{ Subsystem: kubeletSubsystem, Name: "http_inflight_requests", Help: "Number of the inflight http requests", StabilityLevel: metrics.ALPHA, }, []string{"method", "path", "server_type", "long_running"},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Jan 19 14:33:37 UTC 2022 - 3.5K 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) -
src/internal/trace/order.go
if idx < 0 { return 0, fmt.Errorf("tried to end event %v, but not in-flight", go122.Specs()[st].Name) } // Swap remove. desc := s.inFlight[idx].desc s.inFlight[idx], s.inFlight[len(s.inFlight)-1] = s.inFlight[len(s.inFlight)-1], s.inFlight[idx] s.inFlight = s.inFlight[:len(s.inFlight)-1] return desc, nil } // seqCounter represents a global sequence counter for a resource. type seqCounter struct {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Jun 03 14:56:25 UTC 2024 - 52.4K bytes - Viewed (0) -
android/guava/src/com/google/common/util/concurrent/ListenableFuture.java
* * <pre>{@code * final String name = ...; * inFlight.add(name); * ListenableFuture<Result> future = service.query(name); * future.addListener(new Runnable() { * public void run() { * processedCount.incrementAndGet(); * inFlight.remove(name); * lastProcessed.set(name); * logger.info("Done with {0}", name); * } * }, executor);
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Mon Jun 26 21:13:41 UTC 2023 - 8K 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/filters/maxinflight.go
fcmetrics "k8s.io/apiserver/pkg/util/flowcontrol/metrics" "k8s.io/klog/v2" ) const ( // Constant for the retry-after interval on rate limiting. retryAfter = "1" // How often inflight usage metric should be updated. Because // the metrics tracks maximal value over period making this // longer will increase the metric value. inflightUsageMetricUpdatePeriod = time.Second ) var (
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon May 08 11:34:15 UTC 2023 - 6.9K bytes - Viewed (0) -
pkg/envoy/admin.go
package envoy import ( "bytes" "fmt" "io" "net/http" "strings" "istio.io/istio/pkg/log" ) // DrainListeners drains inbound listeners of Envoy so that inflight requests // can gracefully finish and even continue making outbound calls as needed. func DrainListeners(adminPort uint32, inboundonly bool, skipExit bool) error { var drainURL string if inboundonly {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Thu Oct 19 20:22:09 UTC 2023 - 1.8K bytes - Viewed (0)