- Sort Score
- Result 10 results
- Languages All
Results 131 - 140 of 367 for exit_a (0.25 sec)
-
android/guava-tests/test/com/google/common/util/concurrent/AbstractFutureTest.java
Registered: Wed Jun 12 16:38:11 UTC 2024 - Last Modified: Tue Jun 11 16:13:05 UTC 2024 - 46.7K bytes - Viewed (0) -
staging/src/k8s.io/apiserver/plugin/pkg/audit/buffered/buffered.go
// events added prior to that moment are batched and sent to the delegate backend. func (b *bufferedBackend) Shutdown() { // Wait until the routine spawned in Run method exits. <-b.shutdownCh // Wait until all sending routines exit. // // - When b.shutdownCh is closed, we know that the goroutine in Run has terminated. // - This means that processIncomingEvents has terminated.
Registered: Sat Jun 15 01:39:40 UTC 2024 - Last Modified: Tue Jul 26 17:14:05 UTC 2022 - 9.1K bytes - Viewed (0) -
testing/internal-integ-testing/src/main/groovy/org/gradle/integtests/fixtures/ProcessFixture.groovy
* Blocks until the process represented by {@link #pid} has exited. */ void waitForFinish() { if (pid == null) { throw new RuntimeException("Unable to wait for process to finish because provided pid is null!") } if (OperatingSystem.current().unix) { ConcurrentTestUtil.poll { bash("ps -o pid= -p $pid; exit 0").trim() == "" }
Registered: Wed Jun 12 18:38:38 UTC 2024 - Last Modified: Thu Apr 04 07:21:38 UTC 2024 - 5.6K bytes - Viewed (0) -
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) -
releasenotes/notes/exit-if-sds-socket-not-found.yaml
Adam Sayah <******@****.***> 1689115366 -0700
Registered: Fri Jun 14 15:00:06 UTC 2024 - Last Modified: Tue Jul 11 22:42:46 UTC 2023 - 313 bytes - Viewed (0) -
src/cmd/link/internal/s390x/obj.go
Reloc1: elfreloc1, RelocSize: 24, SetupPLT: elfsetupplt, }, } return arch, theArch } func archinit(ctxt *ld.Link) { switch ctxt.HeadType { default: ld.Exitf("unknown -H option: %v", ctxt.HeadType) case objabi.Hlinux: // s390x ELF ld.Elfinit(ctxt) ld.HEADR = ld.ELFRESERVE if *ld.FlagRound == -1 { *ld.FlagRound = 0x10000 } if *ld.FlagTextAddr == -1 {
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Sep 13 19:32:19 UTC 2023 - 2.9K 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
select { case <-c: case <-remainingGrace.C: // grace period expired, so immediately exit 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) -
src/cmd/internal/test2json/test2json.go
} // Write writes the test input to the converter. func (c *Converter) Write(b []byte) (int, error) { c.input.write(b) return len(b), nil } // Exited marks the test process as having exited with the given error. func (c *Converter) Exited(err error) { if err == nil { if c.result != "skip" { c.result = "pass" } } else { c.result = "fail" } } const marker = byte(0x16) // ^V
Registered: Wed Jun 12 16:32:35 UTC 2024 - Last Modified: Wed Nov 09 17:33:07 UTC 2022 - 14.5K bytes - Viewed (0)