- Sort Score
- Result 10 results
- Languages All
Results 41 - 50 of 87 for bursty (0.27 sec)
-
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/registry/PersistentDaemonRegistryTest.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri May 24 00:09:57 UTC 2024 - 5.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/DaemonReportStatusIntegrationSpec.groovy
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 3.4K bytes - Viewed (0) -
src/internal/trace/testdata/testprog/stress-start-stop.go
// Copyright 2023 The Go Authors. All rights reserved. // Use of this source code is governed by a BSD-style // license that can be found in the LICENSE file. // Tests a many interesting cases (network, syscalls, a little GC, busy goroutines, // blocked goroutines, LockOSThread, pipes, and GOMAXPROCS). //go:build ignore package main import ( "bytes" "io" "log" "net" "os" "runtime" "runtime/trace" "sync"
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 17 18:48:18 UTC 2024 - 2.7K bytes - Viewed (0) -
platforms/core-runtime/daemon-protocol/src/main/java/org/gradle/launcher/daemon/protocol/DaemonUnavailable.java
* See the License for the specific language governing permissions and * limitations under the License. */ package org.gradle.launcher.daemon.protocol; /** * Returned when the daemon is busy running a different command. */ public class DaemonUnavailable extends Message { private final String reason; public DaemonUnavailable(String reason) { this.reason = reason; }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu May 09 04:50:46 UTC 2024 - 965 bytes - Viewed (0) -
pilot/cmd/pilot-discovery/app/cmd.go
"Maximum QPS when communicating with the kubernetes API") c.PersistentFlags().IntVar(&serverArgs.RegistryOptions.KubeOptions.KubernetesAPIBurst, "kubernetesApiBurst", 160, "Maximum burst for throttle when communicating with the kubernetes API") // Attach the Istio logging options to the command. loggingOptions.AttachCobraFlags(c) // Attach the Istio Ctrlz options to the command.
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri Apr 12 16:44:32 UTC 2024 - 8.5K bytes - Viewed (0) -
pilot/pkg/status/distribution/state.go
// in the mesh. These values can be configured using environment variables for tuning (see pilot/pkg/features) restConfig.QPS = float32(features.StatusQPS) restConfig.Burst = features.StatusBurst var err error if c.dynamicClient, err = dynamic.NewForConfig(restConfig); err != nil { scope.Fatalf("Could not connect to kubernetes: %s", err) } // configmap informer
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue May 23 17:08:31 UTC 2023 - 7.7K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/DaemonLogFileStateProbe.groovy
import org.gradle.launcher.daemon.logging.DaemonMessages import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Busy import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Canceled import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Idle
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.6K bytes - Viewed (0) -
src/cmd/cgo/internal/testcarchive/testdata/main6.c
#include <stddef.h> #include <sys/time.h> #include "libgo6.h" int main(int argc, char **argv) { struct timeval tvstart, tvnow; int diff; gettimeofday(&tvstart, NULL); go_start_profile(); // Busy wait so we have something to profile. // If we just sleep the profiling signal will never fire. while (1) { gettimeofday(&tvnow, NULL);
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Fri May 12 11:59:56 UTC 2023 - 830 bytes - Viewed (0) -
staging/src/k8s.io/apiserver/pkg/storage/etcd3/compact.go
// By default, we save the most recent 5 minutes data and compact versions > 5minutes ago. // It should be enough for slow watchers and to tolerate burst. // TODO: We might keep a longer history (12h) in the future once storage API can take advantage of past version of keys. func StartCompactor(ctx context.Context, client *clientv3.Client, compactInterval time.Duration) {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Aug 17 02:54:36 UTC 2022 - 5.6K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/integTest/groovy/org/gradle/launcher/daemon/testing/DaemonsEventSequence.groovy
} } processChanges() } private checkForDaemonsStateChange() { def busy = registry.notIdle.size() def idle = registry.idle.size() def currentState = new DaemonsState(busy, idle) if (!lastDaemonsState.matches(currentState)) { putOnChangeQueue(currentState) lastDaemonsState = currentState
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.5K bytes - Viewed (0)