- Sort Score
- Result 10 results
- Languages All
Results 61 - 70 of 291 for bursty (0.22 sec)
-
istioctl/pkg/cli/context.go
// We are running a one-off command locally, so we don't need to worry too much about rate limiting // Bumping this up greatly decreases install time config.QPS = 50 config.Burst = 100 }) if err != nil { return nil, err } return kube.NewCLIClient(kube.NewClientConfigForRestConfig(rc), kube.WithRevision(revision)) } func NewCLIContext(rootFlags *RootFlags) Context {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Apr 02 08:32:06 UTC 2024 - 6.4K bytes - Viewed (0) -
cmd/kube-scheduler/app/server_test.go
}, wantClientConnection: &componentbaseconfig.ClientConnectionConfiguration{ Kubeconfig: configKubeconfig, ContentType: "application/vnd.kubernetes.protobuf", QPS: 50, Burst: 100, }, }, { name: "leader election CLI args, without --config arg", flags: []string{ "--leader-elect=false", "--leader-elect-lease-duration=2h",
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Apr 24 18:25:29 UTC 2024 - 14.2K bytes - Viewed (0) -
android/guava/src/com/google/common/hash/Striped64.java
transient volatile int busy; /** Package-private default constructor */ Striped64() {} /** CASes the base field. */ final boolean casBase(long cmp, long val) { return UNSAFE.compareAndSwapLong(this, baseOffset, cmp, val); } /** CASes the busy field from 0 to 1 to acquire lock. */ final boolean casBusy() {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Fri Jun 07 22:25:23 UTC 2024 - 11.5K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/exec/StartBuildOrRespondWithBusy.java
import org.gradle.launcher.daemon.server.api.DaemonStoppedException; import org.gradle.launcher.daemon.server.api.DaemonUnavailableException; /** * Updates the daemon idle/busy status, sending a DaemonUnavailable result back to the client if the daemon is busy. */ public class StartBuildOrRespondWithBusy extends BuildCommandOnly { private static final Logger LOGGER = Logging.getLogger(StartBuildOrRespondWithBusy.class);
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.8K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/server/DaemonRegistryUpdater.java
} public void onStartActivity() { LOGGER.info("Marking the daemon as busy, address: {}", connectorAddress); try { daemonRegistry.markState(connectorAddress, Busy); } catch (DaemonRegistry.EmptyRegistryException e) { LOGGER.warn("Cannot mark daemon as busy because the registry is empty."); } } public void onCompleteActivity() {
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/server/DaemonExpirationStrategyTest.groovy
import org.gradle.launcher.daemon.server.api.DaemonStateControl import org.gradle.internal.time.MockClock import spock.lang.Specification import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Busy abstract class DaemonExpirationStrategyTest extends Specification { DaemonRegistry registry def setup() { // Start with a new registry on each test. registry = new EmbeddedDaemonRegistry()
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 2.1K bytes - Viewed (0) -
src/net/nss_test.go
action: "b", }, { status: "x", action: "y", }, }, }, {source: "c"}, }, }, }, }, // Ubuntu Trusty w/ avahi-daemon, libavahi-* etc installed. { name: "ubuntu_trusty_avahi", in: ubuntuTrustyAvahi, want: &nssConf{ sources: map[string][]nssSource{ "passwd": {{source: "compat"}},
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Nov 15 20:15:51 UTC 2022 - 3.4K bytes - Viewed (0) -
platforms/ide/tooling-api/src/test/groovy/org/gradle/tooling/internal/consumer/loader/SynchronizedToolingImplementationLoaderTest.groovy
def loader = new SynchronizedToolingImplementationLoader(target) def "blocks and reports progress when busy"() { when: start { loader.create(distro, factory, _ as InternalBuildProgressListener, params, cancellationToken) } async { thread.blockUntil.busy loader.create(distro, factory, _ as InternalBuildProgressListener, params, cancellationToken) }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Tue Sep 26 14:49:20 UTC 2023 - 2.9K bytes - Viewed (0) -
cmd/listen-notification-handlers.go
setEventStreamHeaders(w) // Listen Publisher and peer-listen-client uses nonblocking send and hence does not wait for slow receivers. // 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())
Registered: Sun Jun 16 00:44:34 UTC 2024 - Last Modified: Fri May 24 23:05:23 UTC 2024 - 6K bytes - Viewed (0) -
pkg/kubelet/apis/config/validation/validation_test.go
configure: func(conf *kubeletconfig.KubeletConfiguration) *kubeletconfig.KubeletConfiguration { conf.EventBurst = -1 return conf }, errMsg: "invalid configuration: eventBurst (--event-burst) -1 must not be a negative number", }, { name: "invalid EventRecordQPS", configure: func(conf *kubeletconfig.KubeletConfiguration) *kubeletconfig.KubeletConfiguration { conf.EventRecordQPS = -1 return conf
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Mar 05 21:10:42 UTC 2024 - 28.7K bytes - Viewed (0)