- Sort Score
- Result 10 results
- Languages All
Results 101 - 110 of 370 for elided (0.1 sec)
-
subprojects/core/src/main/java/org/gradle/process/internal/worker/DefaultSingleRequestWorkerProcessBuilder.java
boolean hasResult = receiver.awaitNextResult(); workerProcess.waitForStop(); if (!hasResult) { // Reached the end of input, worker has exited without failing throw new IllegalStateException(String.format("No response was received from %s but the worker process has finished.", getBaseName())); }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Mon Dec 04 09:27:37 UTC 2023 - 5.7K bytes - Viewed (0) -
android/guava-tests/test/com/google/common/util/concurrent/InterruptibleTaskTest.java
throws InterruptedException { while (!isThreadBlockedOnInstanceOf(t, blocker)) { if (t.getState() == Thread.State.TERMINATED) { throw new RuntimeException("Thread " + t + " exited unexpectedly"); } Thread.sleep(1); } } private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) {
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
throws InterruptedException { while (!isThreadBlockedOnInstanceOf(t, blocker)) { if (t.getState() == Thread.State.TERMINATED) { throw new RuntimeException("Thread " + t + " exited unexpectedly"); } Thread.sleep(1); } } private static boolean isThreadBlockedOnInstanceOf(Thread t, Class<?> blocker) {
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Wed Sep 06 17:04:31 UTC 2023 - 6.6K bytes - Viewed (0) -
pkg/kubelet/kuberuntime/kuberuntime_termination_order.go
return time.Since(start).Seconds() } } return time.Since(start).Seconds() } // containerTerminated should be called once the container with the speecified name has exited. func (o *terminationOrdering) containerTerminated(name string) { if ch, ok := o.terminated[name]; ok { close(ch) }
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Wed Oct 18 00:07:21 UTC 2023 - 3.8K bytes - Viewed (0) -
cni/pkg/repair/repaircontroller.go
if c.cfg.InitContainerName != "" && container.Name != c.cfg.InitContainerName { continue } // For safety, check the containers *current* status. If the container // successfully exited, we NEVER want to identify this pod as broken. // If the pod is going to fail, the failure state will show up in // LastTerminationState eventually. if state := container.State.Terminated; state != nil {
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Sat Feb 10 00:31:55 UTC 2024 - 10.4K bytes - Viewed (0) -
src/cmd/go/go_unix_test.go
err = cmd.Wait() ee, _ := err.(*exec.ExitError) if ee == nil { t.Fatalf("unexpectedly finished with nonzero status") } if len(ee.Stderr) > 0 { t.Logf("stderr:\n%s", ee.Stderr) } if !ee.Exited() { t.Fatalf("'go test' did not exit after interrupt: %v", err) } t.Logf("interrupted tests without deadlocking")
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Tue Sep 19 16:17:55 UTC 2023 - 3.5K bytes - Viewed (0) -
src/runtime/vdso_test.go
} if err != nil { if err := err.(*exec.ExitError); err != nil && err.Sys().(syscall.WaitStatus).Signaled() { if !bytes.Contains(out, []byte("+++ killed by")) { // strace itself occasionally crashes. // Here, it exited with a signal, but // the strace log didn't report any // signal from the child process. t.Log(err) testenv.SkipFlaky(t, 63734) } } t.Fatal(err) }
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Jan 17 19:47:47 UTC 2024 - 3.7K bytes - Viewed (0) -
pkg/kubelet/pleg/generic.go
// is introduced here to complete the state transition scenarios. type plegContainerState string const ( plegContainerRunning plegContainerState = "running" plegContainerExited plegContainerState = "exited" plegContainerUnknown plegContainerState = "unknown" plegContainerNonExistent plegContainerState = "non-existent" ) func convertState(state kubecontainer.State) plegContainerState { switch state {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jun 04 06:25:43 UTC 2024 - 19.3K bytes - Viewed (0) -
cmd/kube-apiserver/app/options/validation.go
// note: While the cluster might be dualstack (i.e. pods with multiple IPs), the user may choose // to only ingress traffic within and into the cluster on one IP family only. this family is decided // by the range set on --service-cluster-ip-range. If/when the user decides to use dual stack services // the Secondary* must be of different IPFamily than --service-cluster-ip-range if secondaryServiceClusterIPRangeUsed {
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Oct 31 21:05:06 UTC 2023 - 6.2K bytes - Viewed (0) -
testing/performance/src/templates/native-dependents-resources/googleTest/libs/googleTest/1.7.0/include/gtest/internal/gtest-death-test-internal.h
virtual TestRole AssumeRole() = 0; // Waits for the death test to finish and returns its status. virtual int Wait() = 0; // Returns true if the death test passed; that is, the test process // exited during the test, its exit status matches a user-supplied // predicate, and its stderr output matches a user-supplied regular // expression. // The user-supplied predicate may be a macro expression rather
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 13.1K bytes - Viewed (0)