- Sort Score
- Num 10 results
- Language All
Results 1 - 10 of 36 for deadline (0.05 seconds)
-
guava-testlib/src/com/google/common/testing/GcFinalization.java
*/ @SuppressWarnings("removal") // b/487687332 public static void awaitDone(Future<?> future) { if (future.isDone()) { return; } long timeoutSeconds = timeoutSeconds(); long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); do { System.runFinalization(); if (future.isDone()) { return; } System.gc(); try {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 20:19:19 GMT 2026 - 12.3K bytes - Click Count (0) -
android/guava-testlib/src/com/google/common/testing/GcFinalization.java
*/ @SuppressWarnings("removal") // b/487687332 public static void awaitDone(Future<?> future) { if (future.isDone()) { return; } long timeoutSeconds = timeoutSeconds(); long deadline = System.nanoTime() + SECONDS.toNanos(timeoutSeconds); do { System.runFinalization(); if (future.isDone()) { return; } System.gc(); try {Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Thu Mar 12 20:19:19 GMT 2026 - 12.3K bytes - Click Count (0) -
guava/src/com/google/common/collect/Queues.java
* execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make * the timeout arbitrarily inaccurate, given a queue that is slow to drain). */ long deadline = System.nanoTime() + unit.toNanos(timeout); int added = 0; while (added < numElements) { // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 18K bytes - Click Count (0) -
android/guava/src/com/google/common/collect/Queues.java
* execute Queue#drainTo is not added *on top* of waiting for the timeout (which could make * the timeout arbitrarily inaccurate, given a queue that is slow to drain). */ long deadline = System.nanoTime() + unit.toNanos(timeout); int added = 0; while (added < numElements) { // we could rely solely on #poll, but #drainTo might be more efficient when there are multiple
Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 18.2K bytes - Click Count (0) -
android/guava/src/com/google/common/util/concurrent/ServiceManager.java
* reached the {@linkplain State#RUNNING running} state. * * @param timeout the maximum time to wait * @throws TimeoutException if not all of the services have finished starting within the deadline * @throws IllegalStateException if the service manager reaches a state from which it cannot * become {@linkplain #isHealthy() healthy}. * @since 33.4.0 (but since 28.0 in the JRE flavor) */Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Feb 23 19:19:10 GMT 2026 - 33.2K bytes - Click Count (1) -
guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} finally { lock.unlock(); } } @Override public boolean awaitUntil(Date deadline) throws InterruptedException { lock.lock(); try { return condition.awaitUntil(deadline); } finally { lock.unlock(); } } @Override public void signal() { lock.lock();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
android/guava-tests/test/com/google/common/util/concurrent/UninterruptiblesTest.java
} finally { lock.unlock(); } } @Override public boolean awaitUntil(Date deadline) throws InterruptedException { lock.lock(); try { return condition.awaitUntil(deadline); } finally { lock.unlock(); } } @Override public void signal() { lock.lock();Created: Fri Apr 03 12:43:13 GMT 2026 - Last Modified: Mon Mar 16 22:45:21 GMT 2026 - 38.1K bytes - Click Count (0) -
okhttp/src/jvmTest/kotlin/okhttp3/CallTest.kt
// Call 1: set a deadline on the response body. val request1 = Request.Builder().url(server.url("/")).build() val response1 = client.newCall(request1).execute() val body1 = response1.body.source() assertThat(body1.readUtf8()).isEqualTo("abc") body1.timeout().deadline(5, TimeUnit.SECONDS) // Call 2: check for the absence of a deadline on the request body.Created: Fri Apr 03 11:42:14 GMT 2026 - Last Modified: Sun Mar 15 09:02:18 GMT 2026 - 146.5K bytes - Click Count (0) -
callbacks.go
resetBuildClauses = true } if optimizer, ok := stmt.Dest.(StatementModifier); ok { optimizer.ModifyStatement(stmt) } if db.DefaultContextTimeout > 0 { if _, ok := stmt.Context.Deadline(); !ok { stmt.Context, _ = context.WithTimeout(stmt.Context, db.DefaultContextTimeout) } } // assign model values if stmt.Model == nil { stmt.Model = stmt.Dest } else if stmt.Dest == nil {Created: Sun Apr 05 09:35:12 GMT 2026 - Last Modified: Sat Mar 21 11:26:07 GMT 2026 - 8.8K bytes - Click Count (0) -
CHANGELOG/CHANGELOG-1.32.md
- ServiceAccount metadata.annotations[kubernetes.io/enforce-mountable-secrets]: deprecated since v1.32; no removal deadline. Prefer separate namespaces to isolate access to mounted secrets. ([#128396](https://github.com/kubernetes/kubernetes/pull/128396), [@ritazh](https://github.com/ritazh)) [SIG API Machinery, Apps, Auth, CLI and Testing]
Created: Fri Apr 03 09:05:14 GMT 2026 - Last Modified: Thu Feb 26 23:58:21 GMT 2026 - 470.5K bytes - Click Count (0)