- Sort Score
- Result 10 results
- Languages All
Results 71 - 80 of 227 for bursty (0.28 sec)
-
platforms/core-runtime/launcher/src/test/groovy/org/gradle/launcher/daemon/client/DefaultDaemonConnectorTest.groovy
import spock.lang.Specification import static org.gradle.internal.nativeintegration.services.NativeServices.NativeServicesMode import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Busy import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Idle class DefaultDaemonConnectorTest extends Specification { def javaHome = new File("tmp") def connectTimeoutSecs = 1
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 10:50:51 UTC 2024 - 6.4K bytes - Viewed (0) -
platforms/core-runtime/launcher/src/main/java/org/gradle/launcher/daemon/registry/DaemonInfo.java
import java.io.IOException; import java.io.Serializable; import java.util.Date; import java.util.List; import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Busy; import static org.gradle.launcher.daemon.server.api.DaemonStateControl.State.Idle; /** * Provides information about a daemon that is potentially available to do some work. */
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Fri Sep 22 09:29:13 UTC 2023 - 5.2K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; public final class InterruptibleTaskTest extends TestCase { // Regression test for a deadlock where a task could be stuck busy waiting for the task to // transition to DONE public void testInterruptThrows() throws Exception { final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
import junit.framework.TestCase; import org.checkerframework.checker.nullness.qual.Nullable; public final class InterruptibleTaskTest extends TestCase { // Regression test for a deadlock where a task could be stuck busy waiting for the task to // transition to DONE public void testInterruptThrows() throws Exception { final CountDownLatch isInterruptibleRegistered = new CountDownLatch(1); InterruptibleTask<@Nullable Void> task =
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
src/runtime/mgcwork.go
work.wbufSpans.free.remove(s) work.wbufSpans.busy.insert(s) } unlock(&work.wbufSpans.lock) } if s == nil { systemstack(func() { s = mheap_.allocManual(workbufAlloc/pageSize, spanAllocWorkBuf) }) if s == nil { throw("out of memory") } // Record the new span in the busy list. lock(&work.wbufSpans.lock) work.wbufSpans.busy.insert(s) unlock(&work.wbufSpans.lock) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Mon Mar 25 19:53:03 UTC 2024 - 12.9K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/daemon/LegacyDaemon.groovy
logFileProbe = new DaemonLogFileStateProbe(daemonLog, context) } else { logFileProbe = new DaemonLogFileStateProbe(daemonLog, context, "Daemon is busy, sleeping until state changes", "Daemon is idle, sleeping until state change") } } protected void waitForState(State state) { def timer = Time.startCountdownTimer(STATE_CHANGE_TIMEOUT)
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed May 29 15:22:16 UTC 2024 - 2.3K bytes - Viewed (0) -
subprojects/core/src/integTest/groovy/org/gradle/api/CrossProcessFileLockIntegrationTest.groovy
class CrossProcessFileLockIntegrationTest extends AbstractIntegrationSpec { @ToBeFixedForConfigurationCache(skip = INVESTIGATE) def "the task history lock can be acquired when the initial owner is busy executing tasks"() { createDirs("a", "b") settingsFile << "include 'a', 'b'" file("a/src/main/java/A.java") << "public class A {}" file("b/src/main/java/B.java") << "public class B {}"
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Wed Apr 03 15:21:23 UTC 2024 - 2.7K bytes - Viewed (0) -
cluster/gce/gci/configure-helper.sh
local -r src_dir="${KUBE_HOME}/kube-manifests/kubernetes/gci-trusty" local -r dst_dir="/etc/kubernetes/$1/$2" copy-manifests "${src_dir}/$2" "${dst_dir}" } # A function that downloads extra addons from a URL and puts them in the GCI # manifests directory. function download-extra-addons { local -r out_dir="${KUBE_HOME}/kube-manifests/kubernetes/gci-trusty/gce-extras" mkdir -p "${out_dir}"
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Mon Jun 10 22:07:47 UTC 2024 - 141.1K bytes - Viewed (0) -
cni/pkg/nodeagent/server.go
func buildKubeClient(kubeConfig string) (kube.Client, error) { // Used by validation kubeRestConfig, err := kube.DefaultRestConfig(kubeConfig, "", func(config *rest.Config) { config.QPS = 80 config.Burst = 160 }) if err != nil { return nil, fmt.Errorf("failed creating kube config: %v", err) } client, err := kube.NewClient(kube.NewClientConfigForRestConfig(kubeRestConfig), "") if err != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Fri May 31 21:45:18 UTC 2024 - 7.2K bytes - Viewed (0) -
pkg/scheduler/apis/config/validation/validation_test.go
}, Parallelism: 8, ClientConnection: componentbaseconfig.ClientConnectionConfiguration{ AcceptContentTypes: "application/json", ContentType: "application/json", QPS: 10, Burst: 10, }, LeaderElection: componentbaseconfig.LeaderElectionConfiguration{ ResourceLock: "leases", LeaderElect: true, LeaseDuration: metav1.Duration{Duration: 30 * time.Second},
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Thu Apr 25 06:27:01 UTC 2024 - 12.2K bytes - Viewed (0)